hi, Shubin Ruan
如果字段是可枚举的，应该是可以用这种模式写入的。 DataStream<> input = ...; input.filter(...).addSink(sink1); input.filter(...).addSink(sink2); input.filter(...).addSink(sink3); 但这种一个是感觉不太灵活，当上报数据增加类型就要改代码。另一个是如果这个值枚举比较多，这样写起来也挺烦的。 -- 张健 在 2020-10-30 17:19:56，"Shubin Ruan" <zjuruanshu...@163.com> 写道： >Hi，张健: > > > 感觉可以根据数据里的字段定义不同的侧输出，然后将各个侧输出通过 jdbc sink 到对应表中。 > > >Best, >Shubin Ruan > > > > >在 2020-10-30 16:10:33，"张健" <zhangjian19921...@163.com> 写道： >>hi， >> >> >>我现在有个需求是一个source进来，然后根据数据里的字段 分发写入 >>clickhouse多张表中（比如用户行为事件，上报进来有多种，不同的事件写入不同的表中），我想用Flink的Jdbc >>sink来做，但看接口貌似不能直接实现这样的功能。 >> >> >>这个是要自定义一个sink来做嘛？有没有什么简单的实现方式？ >> >> >> >> >> >> >> >>-- >> >>张健
