跳到主要内容
版本:2.3.0-beta

Hive

Hive sink connector

Description

Write Rows to Apache Hive.

提示

Engine Supported and plugin name

  • Spark: Hive
  • Flink

Options

nametyperequireddefault value
sqlstringno-
source_table_namestringno-
result_table_namestringno-
sink_columnsstringno-
save_modestringno-
partition_byArray[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"]
}
}