Hi casel, 我们在生产中有类似的做法,可以考虑实现一个udtf,监听apollo的配置,根据配置选择是否filter数据。
Best, Yu Chen > 2023年11月20日 21:05,Xuyang <xyzhong...@163.com> 写道: > > Hi, > 是否可以将这个”配置维表“换成流表,利用flink cdc,改动这个配置表的时候,监听字段cdc变化,同时下游上流join呢? > > > > > -- > > Best! > Xuyang > > > > > > 在 2023-11-20 19:24:47,"casel.chen" <casel_c...@126.com> 写道: >> 我有一个flink >> sql作业过滤条件customer_id是需要根据用户配置来定的,类似于Apollo配置中心,是否可以通过定义一张配置维表来实现呢?设置TTL定期去获取最新配置。 >> >> >> create table customer_conf_tbl ( >> customer_id STRING >> ) with ( >> 'connector' = 'apollo', >> '其他属性' .... >> ); >> select * from biz_table where customer_id in (select >> string_split(customer_id, ',') from customer_conf_tbl) >> >> >> 如果要做成配置实时更新作用于sql作业的话又该如何实现呢?