Hi Flavio,
for the user code logic Flink uses exclusively Java serialization. What you
can do, though, is to override the readObject and writeObject methods which
are used by Java serialization. Within the methods you can serialize the
other object you’re referencing.
Cheers,
Till
On Mon, Jul
Hi to all,
in my Flink job I initialize some java object that doesn't implement
serializable to use it within some Flink function (i.e. map or flatMap). At
the moment the only way to achieve that is to keep those operators as
private classes in the main one and reference to static fields or implem
