Console Connector介绍

语法

CREATE TABLE console_table (
  id BIGINT,
  name VARCHAR,
  age INT
) WITH (
    type='console',
    geaflow.dsl.console.skip = true
)

参数

参数名	是否必须	描述
geaflow.dsl.console.skip	否	是否跳过日志，即无任何输出，默认为false

示例

CREATE TABLE file_source (
  id BIGINT,
  name VARCHAR,
  age INT
) WITH (
    type='file',
    geaflow.dsl.file.path = '/path/to/file'
);

CREATE TABLE console_sink (
  id BIGINT,
  name VARCHAR,
  age INT
) WITH (
    type='console'
);

INSERT INTO console_sink
SELECT * FROM file_source;