blob: 7ec7335922021e0db7b31d19936cd94d77ce8192 [file] [log] [blame] [view]
# Console Connector介绍
## 语法
```sql
CREATE TABLE console_table (
id BIGINT,
name VARCHAR,
age INT
) WITH (
type='console',
geaflow.dsl.console.skip = true
)
```
## 参数
| 参数名 | 是否必须 | 描述 |
| -------- | -------- |------------------------|
| geaflow.dsl.console.skip | | 是否跳过日志,即无任何输出,默认为false |
## 示例
```sql
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;
```