查看现有link
sqoop:000> show link
+-----------+------------------------+---------+
| Name | Connector Name | Enabled |
+-----------+------------------------+---------+
| mysqllink | generic-jdbc-connector | true |
| mysql2 | generic-jdbc-connector | true |
+-----------+------------------------+---------+
删除link
sqoop:000> delete link -name mysqllink
sqoop:000> show link
+--------+------------------------+---------+
| Name | Connector Name | Enabled |
+--------+------------------------+---------+
| mysql2 | generic-jdbc-connector | true |
+--------+------------------------+---------+
sqoop:000> delete link -name mysql2
sqoop:000> show link
+------+----------------+---------+
| Name | Connector Name | Enabled |
+------+----------------+---------+
+------+----------------+---------+
创建mysql link
sqoop:000> show connector
+------------------------+---------+------------------------------------------------------------+----------------------+
| Name | Version | Class | Supported Directions |
+------------------------+---------+------------------------------------------------------------+----------------------+
| generic-jdbc-connector | 1.99.7 | org.apache.sqoop.connector.jdbc.GenericJdbcConnector | FROM/TO |
| kite-connector | 1.99.7 | org.apache.sqoop.connector.kite.KiteConnector | FROM/TO |
| oracle-jdbc-connector | 1.99.7 | org.apache.sqoop.connector.jdbc.oracle.OracleJdbcConnector | FROM/TO |
| ftp-connector | 1.99.7 | org.apache.sqoop.connector.ftp.FtpConnector | TO |
| hdfs-connector | 1.99.7 | org.apache.sqoop.connector.hdfs.HdfsConnector | FROM/TO |
| kafka-connector | 1.99.7 | org.apache.sqoop.connector.kafka.KafkaConnector | TO |
| sftp-connector | 1.99.7 | org.apache.sqoop.connector.sftp.SftpConnector | TO |
+------------------------+---------+------------------------------------------------------------+----------------------+
sqoop:000> create link -c generic-jdbc-connector
Creating link for connector with name generic-jdbc-connector Please fill following values to create new link object
Name: mysqllink
Database connection
Driver class: com.mysql.jdbc.Driver
Connection String: jdbc:mysql://127.0.0.1:3306/test
Username: root
Password: ****
Fetch Size: 30
Connection Properties: There are currently 0 values in the map: entry#
SQL Dialect
Identifier enclose: New link was successfully created with validation status OK and name mysqllink
查看新建的链接:
sqoop:000> show link
+-----------+------------------------+---------+
| Name | Connector Name | Enabled |
+-----------+------------------------+---------+
| mysqllink | generic-jdbc-connector | true |
+-----------+------------------------+---------+
创建hdfs链接
sqoop:000> create link -c hdfs-connector
Creating link for connector with name hdfs-connector Please fill following values to create new link object
Name: hdfslink
HDFS cluster
URI: localhost:9000
Conf directory: /root/hadoop/hadoop-2.7.4/etc/hadoop
Additional configs:: There are currently 0 values in the map: entry#
New link was successfully created with validation status OK and name hdfslink
sqoop:000> show link
+-----------+------------------------+---------+
| Name | Connector Name | Enabled |
+-----------+------------------------+---------+
| mysqllink | generic-jdbc-connector | true |
| hdfslink | hdfs-connector | true |