TestHarness has setup(TypeSerializer outputSerializer) method, which allows to
set serializer for primary output. Still unclear how to set side output
serializers for MockOutput.
Alexey
From: Alexey Trenikhun
Sent: Saturday, February 2, 2019 10:39 AM
To: user@
Hi Aggarwal How about keyBy(LargeMessageID) first, then assemble these
fragments back into LargeMessages, then keyBy(MeyKey)?
Best,
Congxian
Aggarwal, Ajay 于2019年2月2日周六 上午5:42写道：
> I am new to Flink. I am trying to figure out if there is an operator that
> provides reverse functionality of K
