1. Sql

1.1.1. Description

使用SQL处理数据,使用的是flink的sql语法,支持其各种udf

1.1.2. Options

name type required default value
sql string yes -
common-options string no -
common options [string]

Transform 组件通用参数,详情参照 Transform

1.1.3. Examples

{
    "source_table_name": "FileSourceTable",
    "result_table_name": "sql_table19",
    "plugin_name": "Sql",
    "sql": "select hostid, auth from  FileSourceTable where metric='CPU' "
}

results matching ""

    No results matching ""