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

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

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

李博 bluemind 2018-11-14 13:38:49 浏览794
展开阅读全文

创建 HDFS 结果表

DDL定义

Flink Batch支持使用HDFS作为结果输出。示例代码如下。


  1. create table odps_output(
  2. id int,
  3. user_name VARCHAR,
  4. content VARCHAR
  5. ) with (
  6. type = 'hdfs',
  7. path = 'hdfs://hdfsroot/test.csv',
  8. converter='xxx',
  9. converterClass='com.blink.test.converterToCSV'
  10. );

WITH参数说明

参数 注释说明 备注
path 必选
lineDelimiter 行分隔符 必选
charset 字符集 UTF-8
converter 转换器名称 将batch输出转换成各种格式文件的转换器的名称
converterClass 转换器的类 将batch输出转换成各种格式文件的类名

注意

目前还没有默认的converter实现,如果有写HDFS的需求,请您提交工单。

本文转自实时计算——创建HDFS结果表

网友评论

登录后评论
0/500
评论