更新时间：2024-07-10 GMT+08:00
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' ); |
参数说明
|
参数 |
是否必选 |
默认参数 |
数据类型 |
说明 |
|---|---|---|---|---|
|
connector |
是 |
无 |
String |
固定位filesystem。 |
|
path |
是 |
无 |
String |
OBS路径。 |
|
format |
是 |
无 |
String |
文件格式。 支持csv、parquet格式。 |
常见问题
无
父主题： 创建源表
