Skip to main content
Version: 2.1.0

Common Options

Sink Common Options [Flink]

Sink Plugin common parameters​

nametyperequireddefault value
source_table_namestringno-

source_table_name [string]​

When source_table_name is not specified, the current plugin is processing the data set (dataStream/dataset) output by the previous plugin in the configuration file;

When source_table_name is specified, the current plugin is processing the data set corresponding to this parameter.

Examples​

source {
FakeSourceStream {
result_table_name = "fake"
field_name = "name,age"
}
}

transform {
sql {
source_table_name = "fake"
sql = "select name from fake"
result_table_name = "fake_name"
}
sql {
source_table_name = "fake"
sql = "select age from fake"
result_table_name = "fake_age"
}
}

sink {
console {
source_table_name = "fake_name"
}
}

If source_table_name is not specified, the console outputs the data of the last transform, and if it is set to fake_name , it will output the data of fake_name