创建CSV结果表
Flink可以将CSV格式文件作为目标表输出。示例如下。
create table csv_source(id varchar,name varchar) with (type ='csv',path = 'hdfs://hdfsroot/csvpath/test.csv',...);
WITH参数
通用配置:
| 参数 | 注释说明 | 备注 |
|---|---|---|
| path | 文件路径 | 文件路径可以是oss/hdfs |
| fieldDelim | 列分隔符 | 默认为’,’，支持Java风格字符串转义 |
| lineDelim | 行分隔符 | 默认为’\n’，支持Java风格字符串转义 |
| override | 是否覆盖同名文件 | 默认为true |
本文转自实时计算——创建CSV结果表