Hi Madan,
serialization happens at different positions with different mechanisms.
For records that are travelling in the stream the serializer that is
defined by the type information is used (print
env.addSource().getType()). However, whether records are serialized or
not depends on the so-ca
Hi,
I am trying to understand serialization part when a environment is
executed. Taking a simple environment for ex.,
env.addSource(...).keyBy(...).sum(...).addSink(...).execute. I would like
to understand when and where serialization happens and what are all
serialized, operators,functions etc.,
