跳到主要内容
版本: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"
}