FileSystem源表

功能描述

本节介绍FileSystem源表的定义，以及创建源表时使用的参数和示例代码。

前提条件

注意事项

• 创建Flink OpenSource SQL作业时，在作业编辑界面的“运行参数”处，“Flink版本”需要选择“1.12”，勾选“保存作业日志”并设置保存作业日志的OBS桶，方便后续查看作业日志。
• 数据类型的使用，请参考Format章节。

语法格式

1
2
3
4
5
6
7

create table dataGenSource(
   amount int
) with (
   'connector' = 'filesystem',
   'path' = 'obs://longyuan/source-files',
   'format' = 'csv'
);

参数说明

常见问题

无