更新时间:2022-09-14 18:35:45
Parquet是一种高性能的列式存储格式。您可以在Parquet的官网对这种存储格式做更详情的了解。
Flink可以读取Parquet格式数据作为输入。示例如下。
create table metaq_stream(
x varchar,
y varchar,
z varchar
) with (
type='parquet',
filePath='oss://rootpath/test.parquet'
);
false
true
实时计算Flink > 独享模式 > Batch(试用) > 创建源表 —— 创建ORC源表
实时计算Flink > 独享模式 > Batch(试用) > 创建源表 —— 创建DataHub源表 请输入关键词
实时计算Flink > 独享模式 > Batch(试用) > 创建源表 —— 创建MetaQ (MQ)源表
实时计算Flink - 独享模式 - Batch(试用)- 创建源表 —— 创建CSV源表
实时计算Flink > 独享模式 > Batch(试用) > 创建源表 —— 创建OSS源表
实时计算Flink > 独享模式 > Batch(试用) > 创建源表 —— 创建HDFS源表
实时计算Flink > 独享模式 > Batch(试用) > 创建结果表 —— 创建HDFS结果表
实时计算Flink > 独享模式 > Batch(试用) > 创建源表 —— 创建Parquet源表
实时计算Flink > 独享模式 > Batch(试用) > 创建结果表 —— 创建CSV结果表