Hello,
I've had good luck implementing `Value` to have Flink (1.19, not sure
about earlier versions) use my custom serialization code for a
particular type. More details in the docs here:
https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/dev/datastream/fault-tolerance/serializati
easible, so how best I can do
this using coGroup.
Thanks
Sachin
On Wed, Aug 7, 2024 at 10:41 AM Kirill Ternovsky
wrote:
Hi Sachin,
You should be able to use `coGroup`:
```
streamA.coGroup(streamB)
.where(StreamAFieldFSelector).isEqualTo(StreamBFieldFSelector)
Hi Sachin,
You should be able to use `coGroup`:
```
streamA.coGroup(streamB)
.where(StreamAFieldFSelector).isEqualTo(StreamBFieldFSelector)
.window(/*your windowing spec*/)
.apply(/*your cogroup function*/)
```
Your coGroup function will look something like:
```
@Override
public void
