实时计算Flink > 独享模式 > Batch(试用) > 创建结果表 —— 创建CSV结果表

  1. 云栖社区>
  2. 博客>
  3. 正文

实时计算Flink > 独享模式 > Batch(试用) > 创建结果表 —— 创建CSV结果表

李博 bluemind 2018-11-14 13:37:11 浏览829
展开阅读全文

创建CSV结果表

Flink可以将CSV格式文件作为目标表输出。示例如下。


  1. create table csv_source(
  2. id varchar,
  3. name varchar
  4. ) with (
  5. type ='csv',
  6. path = 'hdfs://hdfsroot/csvpath/test.csv',
  7. ...
  8. );

WITH参数

通用配置:

参数 注释说明 备注
path 文件路径 文件路径可以是oss/hdfs
fieldDelim 列分隔符 默认为’,’,支持Java风格字符串转义
lineDelim 行分隔符 默认为’\n’,支持Java风格字符串转义
override 是否覆盖同名文件 默认为true
本文转自实时计算——创建CSV结果表

网友评论

登录后评论
0/500
评论