从同一个source里select,在flink sql中用statement set 执行两条insert语句到不同的sink表即可
Jiabao Sun 于2023年12月29日周五 16:55写道:
> Hi,
>
> 使用 SQL 的话不太好实现写入多个路径,
> 使用 DataStream 的话可以考虑自己实现一个 RichSinkFunction。
>
> Best,
> Jiabao
>
> On 2023/12/29 08:37:34 jinzhuguang wrote:
> > Flink版本:1.16.0
> >
> > 看官网上的案例:
> > CREATE TA
Hi,
使用 SQL 的话不太好实现写入多个路径,
使用 DataStream 的话可以考虑自己实现一个 RichSinkFunction。
Best,
Jiabao
On 2023/12/29 08:37:34 jinzhuguang wrote:
> Flink版本:1.16.0
>
> 看官网上的案例:
> CREATE TABLE MyUserTable (
> column_name1 INT,
> column_name2 STRING,
> ...
> part_name1 INT,
> part_name2 STRING
> ) PARTITION