实时计算Flink > 独享模式 > Batch(试用) > 创建源表 —— 创建Parquet源表

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

实时计算Flink > 独享模式 > Batch(试用) > 创建源表 —— 创建Parquet源表

李博 bluemind 2018-11-14 13:35:01 浏览967
展开阅读全文

创建Parquet源表

Parquet是一种高性能的列式存储格式。您可以在Parquet的官网对这种存储格式做更详情的了解。

Flink可以读取Parquet格式数据作为输入。示例如下。


  1. create table metaq_stream(
  2. x varchar,
  3. y varchar,
  4. z varchar
  5. ) with (
  6. type='parquet',
  7. filePath='oss://rootpath/test.parquet'
  8. );

WITH参数

参数 注释说明 备注
filePath 文件路径 支持oss/hdfs的文件系统
enumerateNestedFiles 递归读取目录下的所有文件 默认是falsetrue表示递归读取。
本文转自实时计算——创建Parquet源表


网友评论

登录后评论
0/500
评论