useOldPlanner()就不会有这个问题。
张健
useOldPlanner()就不会有这个问题。
张健
useOldPlanner()就不会有这个问题。
张健
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&q
hi,
我现在有个需求是一个source进来,然后根据数据里的字段 分发写入
clickhouse多张表中(比如用户行为事件,上报进来有多种,不同的事件写入不同的表中),我想用Flink的Jdbc
sink来做,但看接口貌似不能直接实现这样的功能。
这个是要自定义一个sink来做嘛?有没有什么简单的实现方式?
--
张健
大家好:
想问下目前 flink mysql sink想要实现按时间分库分表 有什么配置项可以使用嘛?
我目前的需求是数据源经过一个简单的etl处理写入到mysql中,供业务实时查询。由于业务场景只需要查询当天的数据(历史数据有另外的离线模块处理),所以想每天的数据单独写入一张表中(表名为xx_MMDD)这样。但目前Flink
JDBC sink是要指定表名的。请问下有什么简单的实现方案嘛?或者说对于我这样的场景有什么更好的实现方式嘛?
多谢。
--
张健