Re: Flink Lookup Filter Pushdown

2020-04-27 Thread Jark Wu
Hi forideal, Currently, dimension table join requires at least one join key. That is the `u_id` in your example. The join key will be used as lookup key. If you have some additional filters on dimension table, that's fine, Flink will help to filter the fetched data. That means Flink supports follo

Flink Lookup Filter Pushdown

2020-04-27 Thread forideal
Hello, my friend. I have a dimension table. createtabledim_u_score(u_idbigint,varchar,score_adouble,score_bdouble)with{xxx}Inascene The condition of lookup is fliter score_a > 0.9 In another scenario The condition of lookup is fliter score_b > 1 In Flink, at present, lookup join can use on to