Tzu-Li (Gordon) Tai created FLINK-6191:
------------------------------------------
Summary: Make non-primitive, internal built-in serializers reconfigurable
Key: FLINK-6191
URL:
https://issues.apache.org/jira/browse/FLINK-6191 Project: Flink
Issue Type: Sub-task
Components: Type Serialization System
Reporter: Tzu-Li (Gordon) Tai
Assignee: Tzu-Li (Gordon) Tai
This sub-task follows after FLINK-6190.
For non-primitive type serializers internally created by Flink, we need to allow them to be reconfigurable whenever we detect a change between the previous and current serializer configuration.
Most notably, this is relevant for the `KryoSerializer` and `PojoSerializer` which are affected by the configuration, as well as composite types which can potentially have nested serializers (e.g. `GenericArraySerializer`).
Since not all serializers require / reconfiguration, we propose to have a extended abstract base class for these:
{code}
@Internal
public abstract class ReconfigurableTypeSerializer<T> extends TypeSerializer<T> {
void abstract reconfigure(SerializersConfig serializersConfig);
}
{code}
This class is also used as a tag, to check if a serializer needs to be reconfigured when serializer configuration change is detected.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)