pluto
pluto copied to clipboard
Serialization of generic types in operators with state
Currently, there are operators that have generics in their states. If these are not Serializable, the serialization process will inevitably fail.
-
ReduceByKeyOperator: Key/Value ofHashMap -
ApplyStatefulOperator:state of theApplyStatefulFunction(not exactly a generic, but likewise must implement Serializable) -
FixedSizeWindowOperator,CountWindowOperator,SessionWindowOperator: the type of data inWindow
We must address these in a separate way.