Hi yxy, As Hang mentioned, I think lookup join matches your requirements too. You can refer to doc [1] to get more detailed information.
[1] https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/sql/queries/joins/#lookup-join Best, Shammon FY On Sat, May 6, 2023 at 5:54 PM Hang Ruan <ruanhang1...@gmail.com> wrote: > Hi, yxy, > > I think this scenario could be resolved by a lookup join or a UDF. We can > store the ratio in the mysql table. Then we could read it by a lookup join > or implement a UDF to read the ratio. > > Best, > Hang > > yxy <yangxuey...@nantian.com.cn> 于2023年5月6日周六 15:14写道： > >> Hello, we have a business scenario. We have a real-time process to >> calculate how much red envelopes should be given to them for each >> transaction. For example, if a customer pays $100, we will give him a >> rebate of one thousandth. We currently use flinksql to Realize this >> function, but we found that flinksql cannot dynamically adjust this ratio. >> We want to know can flinksql implement broadcast tables like this? >> Broadcast the ratio? > >
