Hive
Hive sink connector
Description
Write Rows to Apache Hive.
提示
Engine Supported and plugin name
- Spark: Hive
- Flink
Options
name | type | required | default value |
---|---|---|---|
sql | string | no | - |
source_table_name | string | no | - |
result_table_name | string | no | - |
sink_columns | string | no | - |
save_mode | string | no | - |
partition_by | Array[string] | no | - |
sql [string]
Hive sql:the whole insert data sql, such as insert into/overwrite $table select * from xxx_table
, If this option exists, other options will be ignored.
Source_table_name [string]
Datasource of this plugin.
result_table_name [string]
The output hive table name if the sql
option doesn't specified.
save_mode [string]
Same with option spark.mode
in Spark, combined with result_table_name
if the sql
option doesn't specified.
sink_columns [string]
Specify the selected fields which write to result_table_name, separated by commas, combined with result_table_name
if the sql
option doesn't specified.
partition_by [Array[string]]
Hive partition fields, combined with result_table_name
if the sql
option doesn't specified.
Example
sink {
Hive {
sql = "insert overwrite table seatunnel.test1 partition(province) select name,age,province from myTable2"
}
}
sink {
Hive {
source_table_name = "myTable2"
result_table_name = "seatunnel.test1"
save_mode = "overwrite"
sink_columns = "name,age,province"
partition_by = ["province"]
}
}