|
Rename Method public registerKryoSerializer(type Class<?>, serializerClass Class<? extends Serializer<?>>) : void renamed to public registerTypeWithKryoSerializer(type Class<?>, serializerClass Class<? extends Serializer<?>>) : void in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Rename Method public registerKryoSerializer(type Class<?>, serializer Serializer<?>) : void renamed to public registerTypeWithKryoSerializer(type Class<?>, serializer Serializer<?>) : void in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Rename Method public registerKryoSerializer(type Class<?>, serializer Serializer<?>) : void renamed to public registerTypeWithKryoSerializer(type Class<?>, serializer Serializer<?>) : void in class org.apache.flink.api.common.ExecutionConfig |
From |
To |
|
Rename Method public registerKryoSerializer(type Class<?>, serializerClass Class<? extends Serializer<?>>) : void renamed to public registerTypeWithKryoSerializer(type Class<?>, serializerClass Class<? extends Serializer<?>>) : void in class org.apache.flink.api.java.ExecutionEnvironment |
From |
To |
|
Rename Method public registerKryoSerializer(type Class<?>, serializer Serializer<?>) : void renamed to public registerTypeWithKryoSerializer(type Class<?>, serializer Serializer<?>) : void in class org.apache.flink.api.java.ExecutionEnvironment |
From |
To |
|
Change Variable Type e : Map.Entry<Class<?>,Serializer<?>> to e : ExecutionConfig.Entry<Class<?>,Serializer<?>> in method private checkKryoInitialized() : void in class org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer |
From |
To |
|
Change Variable Type result : Set<Class<?>> to result : List<Class<?>> in method public getRegisteredKryoTypes() : List<Class<?>> in class org.apache.flink.api.common.ExecutionConfig |
From |
To |
|
Change Variable Type e : Map.Entry<Class<?>,Class<? extends Serializer<?>>> to e : ExecutionConfig.Entry<Class<?>,Class<? extends Serializer<?>>> in method private checkKryoInitialized() : void in class org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer |
From |
To |
|
Change Variable Type registeredPojoTypes : Set<Class<?>> to registeredPojoTypes : List<Class<?>> in method public PojoSerializer(clazz Class<T>, fieldSerializers TypeSerializer<?>[], fields Field[], executionConfig ExecutionConfig) in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer |
From |
To |
|
Change Variable Type source : TestInputView to source : ComparatorTestBase.TestInputView in method public testForwardEOFExceptionWhileDeserializing() : void in class org.apache.flink.api.java.typeutils.runtime.kryo.KryoGenericTypeSerializerTest |
From |
To |
|
Change Attribute Type registeredTypes : Set<Class<?>> to registeredTypes : List<Class<?>> in class org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer |
From |
To |
|
Change Attribute Type registeredKryoTypes : Set<Class<?>> to registeredKryoTypes : List<Class<?>> in class org.apache.flink.api.common.ExecutionConfig |
From |
To |
|
Change Attribute Type registeredPojoTypes : Set<Class<?>> to registeredPojoTypes : List<Class<?>> in class org.apache.flink.api.common.ExecutionConfig |
From |
To |
|
Change Attribute Type registeredSerializers : Map<Class<?>,Serializer<?>> to registeredTypesWithSerializers : List<ExecutionConfig.Entry<Class<?>,Serializer<?>>> in class org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer |
From |
To |
|
Change Attribute Type registeredSerializersClasses : Map<Class<?>,Class<? extends Serializer<?>>> to registeredTypesWithSerializerClasses : List<ExecutionConfig.Entry<Class<?>,Class<? extends Serializer<?>>>> in class org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer |
From |
To |