Hi all, I want to implement a join operator which can use different strategies for joining tuples. I saw that with CoProcessFunction I am able to implement low-level joins [1]. However, I do know how to decide between different algorithms to join my tuples.
On the other hand, to do a broadcast join I will need to use the broadcast operator [2] which yields a BroadcastStream. Therefore, I am not sure if I will need to implement my own operator to do this or if it is still possible to do with CoProcessFunction. Does anyone have some clues for this matter? Thanks [1] https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/stream/operators/process_function.html#low-level-joins [2] https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/state/broadcast_state.html *--* *-- Felipe Gutierrez* *-- skype: felipe.o.gutierrez* *--* *https://felipeogutierrez.blogspot.com <https://felipeogutierrez.blogspot.com>*
