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