flink-1.11连接hive或filesystem问题

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

flink-1.11连接hive或filesystem问题

酷酷的浑蛋
1. Create hive表(...)with(...)
我发现写入hive只能根据checkpoint去提交分区?可以按照文件大小或者间隔时间来生成吗?


2. Create table (connector=filesystem,format=json) with(…)
这种方式format只能等于json? 我怎么按照分隔符写入hdfs?