创建 HDFS 结果表
DDL定义
Flink Batch支持使用HDFS作为结果输出。示例代码如下。
create table odps_output(id int,user_name VARCHAR,content VARCHAR) with (type = 'hdfs',path = 'hdfs://hdfsroot/test.csv',converter='xxx',converterClass='com.blink.test.converterToCSV');
WITH参数说明
| 参数 | 注释说明 | 备注 |
|---|---|---|
| path | 无 | 必选 |
| lineDelimiter | 行分隔符 | 必选 |
| charset | 字符集 | UTF-8 |
| converter | 转换器名称 | 将batch输出转换成各种格式文件的转换器的名称 |
| converterClass | 转换器的类 | 将batch输出转换成各种格式文件的类名 |
注意
目前还没有默认的converter实现，如果有写HDFS的需求，请您提交工单。
本文转自实时计算——创建HDFS结果表
