Skip to main content
Version: 2.1.0

Sql

Transform plugin : SQL [Flink]

Description​

Use SQL to process data, use flink sql grammar, and support its various udf

Options​

nametyperequireddefault value
sqlstringyes-
common-optionsstringno-

common options [string]​

Transform plugin common parameters, please refer to Transform Plugin for details

Examples​

sql {
sql = "select name, age from fake"
}