博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
实时计算Flink > 独享模式 > Batch(试用) > 创建结果表 —— 创建HDFS结果表
阅读量:7111 次
发布时间:2019-06-28

本文共 453 字,大约阅读时间需要 1 分钟。

创建 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的需求,请您提交工单。

本文转自实时计算——

转载地址:http://comhl.baihongyu.com/

你可能感兴趣的文章
我的友情链接
查看>>
python 数据结构 tree 的插入和遍历
查看>>
Linux学习时遇到的问题5
查看>>
虚拟桌面发展的下一个里程碑,构建在CWC之上的软件定义工作空间
查看>>
Map,Map.Entry<K,V>源码分析
查看>>
看<连城诀>有感
查看>>
VTK隐函数之vtkPlane
查看>>
3、Juniper SSG550M STATUS状态灯呈红色(内存条问题)
查看>>
Docker学习——三大组件【镜像、容器、仓库】的应用(二)
查看>>
mysql原理详解及部署
查看>>
taokeeper 架设与部署
查看>>
IIS配置Sencha touch
查看>>
elasticsearch文档-analysis
查看>>
拦截请求返回值的方法
查看>>
我的编程之路
查看>>
yum软件包详解
查看>>
安装hadoop和配置hadoop,启动namenode和设置免密登录的详细解析!
查看>>
Spark Streaming:大规模流式数据处理
查看>>
解决Spring Cloud中Feign/Ribbon第一次请求失败的方法
查看>>
Elasticsearch——分页查询From&Size VS scroll
查看>>