flink中的executionconfig.getdefaultkryoserializerclasses(…)v.s.executionconfig.getdefaultkryoserializers(…)

sirbozc5  于 2021-06-26  发布在  Flink
关注(0)|答案(0)|浏览(172)

在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;
}

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题