Hive source connector
Read data from Hive.
In order to use this connector, You must ensure your spark/flink cluster already integrated hive. The tested hive version is 2.3.9.
Tips: Hive Sink Connector can not add partition field to the output data now
Read all the data in a split in a pollNext call. What splits are read will be saved in snapshot.
name | type | required | default value |
---|---|---|---|
table_name | string | yes | - |
metastore_uri | string | yes | - |
Target Hive table name eg: db1.table1
Hive metastore uri
Hive { table_name = "default.seatunnel_orc" metastore_uri = "thrift://namenode001:9083" }