Hi, I have a Pojo class provided by some library. Say A.class I can create a type info factory of the same like:
public class ATypeInfoFactory extends TypeInfoFactory<A> { @Override public TypeInformation<A> createTypeInfo( Type t, Map<String, TypeInformation<?>> genericParameters) { Map<String, TypeInformation<?>> fields = new HashMap<>() { { ... } }; return Types.POJO(A.class, fields); } } Now I want to register this type information whenever A class's object is serialized or de-serialized in Flink state. How can I register this to the StreamExecutionEnvironment. Thanks Sachin