Hi, Youzha In general `CoGroup` is for the window based operation. How it could satisfy your requirements depends on your specific scenario. But if you want to look at the mysql table as a dimension table. There might be other two ways: 1. Using Table/Sql SDK. You could find a sql example(temporal join the JDBC table as a dimension table) in the table jdbc connector [1] and more join information in the [2] 2. Using DataStream SDK. Maybe you could see whether the `AsycIO` function could satisfy your requirements. You could find the example in [3].
[1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/jdbc.html#how-to-create-a-jdbc-table [2] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/streaming/joins.html [3] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/stream/operators/asyncio.html Best, Guowei On Mon, Nov 16, 2020 at 11:20 PM Youzha <yuza.ras...@gmail.com> wrote: > Hi i want to do join reference between kafka with mysql table reference. > how can i do this thing with flink stream. does coGroup function can handle > this ? or anyone have java sample code with this case? i’ve read some > article that said if cogroup function can do left outer join. but i’m still > confuse to implement it because i just learned flink stream. > > > need advice pls. >
