Re: flink sql作业如何支持配置流?

2023-11-20 文章 Yu Chen
Hi casel, 我们在生产中有类似的做法,可以考虑实现一个udtf,监听apollo的配置,根据配置选择是否filter数据。 Best, Yu Chen > 2023年11月20日 21:05,Xuyang 写道: > > Hi, >是否可以将这个”配置维表“换成流表,利用flink cdc,改动这个配置表的时候,监听字段cdc变化,同时下游上流join呢? > > > > > -- > >Best! >Xuyang > > > > > > 在 2023-11-20 19:24:47,"casel.chen" 写道: >>

flink sql作业如何支持配置流?

2023-11-20 文章 casel.chen
我有一个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