在flink exuctionconfig中,有两种方法: getDefaultKryoSerializers
以及 getDefaultKryoSerializerClasses
. 我们一直在使用 getDefaultKryoSerializers
具体如下:
env.addDefaultKryoSerializer(Event, TBaseSerializer.class)
我们什么时候需要使用 getDefaultKryoSerializerClasses
而不是 getDefaultKryoSerializers
?
/**
* Returns the registered default Kryo Serializers.
*/
public LinkedHashMap<Class<?>, SerializableSerializer<?>>
getDefaultKryoSerializers() {
return defaultKryoSerializers;
}
/**
* Returns the registered default Kryo Serializer classes.
*/
public LinkedHashMap<Class<?>, Class<? extends Serializer<?>>>
getDefaultKryoSerializerClasses() {
return defaultKryoSerializerClasses;
}
暂无答案!
目前还没有任何答案,快来回答吧!