|
Change Parameter Type newSerializer : NS to newSerializer : TypeSerializer<TestType> in method public resolveSchemaCompatibility(newSerializer TypeSerializer<TestType>) : TypeSerializerSchemaCompatibility<TestType> in class org.apache.flink.runtime.state.StateBackendMigrationTestBase.TestSerializerSnapshot |
From |
To |
|
Change Parameter Type newSerializer : NS to newSerializer : TypeSerializer<Long> in method public resolveSchemaCompatibility(newSerializer TypeSerializer<Long>) : TypeSerializerSchemaCompatibility<Long> in class org.apache.flink.test.migration.TypeSerializerSnapshotMigrationITCase.TestSerializerSnapshot |
From |
To |
|
Change Parameter Type newSerializer : NS to newSerializer : TypeSerializer<T> in method public resolveSchemaCompatibility(newSerializer TypeSerializer<T>) : TypeSerializerSchemaCompatibility<T> in class org.apache.flink.api.common.typeutils.CompositeSerializerSnapshot |
From |
To |
|
Change Parameter Type newSerializer : NS to newSerializer : TypeSerializer<T> in method public resolveSchemaCompatibility(newSerializer TypeSerializer<T>) : TypeSerializerSchemaCompatibility<T> in class org.apache.flink.api.common.typeutils.TypeSerializerSnapshot |
From |
To |
|
Change Parameter Type reconfiguredNewSerializer : NS to reconfiguredNewSerializer : TypeSerializer<T> in method private TypeSerializerSchemaCompatibility(resultType Type, reconfiguredNewSerializer TypeSerializer<T>) in class org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility |
From |
To |
|
Change Parameter Type newSerializer : NS to newSerializer : TypeSerializer<Either<L,R>> in method public resolveSchemaCompatibility(newSerializer TypeSerializer<Either<L,R>>) : TypeSerializerSchemaCompatibility<Either<L,R>> in class org.apache.flink.api.java.typeutils.runtime.EitherSerializerConfigSnapshot |
From |
To |
|
Change Parameter Type newSerializer : NS to newSerializer : TypeSerializer<T> in method public resolveSchemaCompatibility(newSerializer TypeSerializer<T>) : TypeSerializerSchemaCompatibility<T> in class org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot |
From |
To |
|
Change Parameter Type newSerializer : NS to newSerializer : TypeSerializer<VoidNamespace> in method public resolveSchemaCompatibility(newSerializer TypeSerializer<VoidNamespace>) : TypeSerializerSchemaCompatibility<VoidNamespace> in class org.apache.flink.runtime.state.StateBackendMigrationTestBase.CustomVoidNamespaceSerializerSnapshot |
From |
To |
|
Change Parameter Type newSerializer : NS to newSerializer : TypeSerializer<T> in method public resolveSchemaCompatibility(newSerializer TypeSerializer<T>) : TypeSerializerSchemaCompatibility<T> in class org.apache.flink.formats.avro.typeutils.AvroSerializerSnapshot |
From |
To |
|
Change Parameter Type newSerializer : NS to newSerializer : TypeSerializer<T> in method public resolveSchemaCompatibility(newSerializer TypeSerializer<T>) : TypeSerializerSchemaCompatibility<T> in class org.apache.flink.api.common.typeutils.BackwardsCompatibleSerializerSnapshot |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<Either<L,R>,NS> to TypeSerializerSchemaCompatibility<Either<L,R>> in method private checkJavaSerializerCompatibility(serializer EitherSerializer<L,R>) : TypeSerializerSchemaCompatibility<Either<L,R>> in class org.apache.flink.api.java.typeutils.runtime.EitherSerializerConfigSnapshot |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<T,NS> to TypeSerializerSchemaCompatibility<T> in method public compatibleAfterMigration() : TypeSerializerSchemaCompatibility<T> in class org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<T,NS> to TypeSerializerSchemaCompatibility<T> in method public resolveSchemaCompatibility(newSerializer TypeSerializer<T>) : TypeSerializerSchemaCompatibility<T> in class org.apache.flink.api.common.typeutils.BackwardsCompatibleSerializerSnapshot |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<T,NS> to TypeSerializerSchemaCompatibility<T> in method public resolveSchemaCompatibility(newSerializer TypeSerializer<T>) : TypeSerializerSchemaCompatibility<T> in class org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<T,S> to TypeSerializerSchemaCompatibility<T> in method protected abstract outerCompatibility(serializer S) : TypeSerializerSchemaCompatibility<T> in class org.apache.flink.api.common.typeutils.CompositeSerializerSnapshot |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<T,NS> to TypeSerializerSchemaCompatibility<T> in method public resolveSchemaCompatibility(newSerializer TypeSerializer<T>) : TypeSerializerSchemaCompatibility<T> in class org.apache.flink.api.common.typeutils.TypeSerializerSnapshot |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<Long,NS> to TypeSerializerSchemaCompatibility<Long> in method public resolveSchemaCompatibility(newSerializer TypeSerializer<Long>) : TypeSerializerSchemaCompatibility<Long> in class org.apache.flink.test.migration.TypeSerializerSnapshotMigrationITCase.TestSerializerSnapshot |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<T,NS> to TypeSerializerSchemaCompatibility<T> in method public compatibleAsIs() : TypeSerializerSchemaCompatibility<T> in class org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<TestType,NS> to TypeSerializerSchemaCompatibility<TestType> in method public resolveSchemaCompatibility(newSerializer TypeSerializer<TestType>) : TypeSerializerSchemaCompatibility<TestType> in class org.apache.flink.runtime.state.StateBackendMigrationTestBase.TestSerializerSnapshot |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<T,NS> to TypeSerializerSchemaCompatibility<T> in method public incompatible() : TypeSerializerSchemaCompatibility<T> in class org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<T,NS> to TypeSerializerSchemaCompatibility<T> in method private avroCompatibilityToFlinkCompatibility(compatibility SchemaPairCompatibility) : TypeSerializerSchemaCompatibility<T> in class org.apache.flink.formats.avro.typeutils.AvroSerializerSnapshot |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<Either<L,R>,EitherSerializer<L,R>> to TypeSerializerSchemaCompatibility<Either<L,R>> in method protected outerCompatibility(serializer EitherSerializer<L,R>) : TypeSerializerSchemaCompatibility<Either<L,R>> in class org.apache.flink.api.java.typeutils.runtime.EitherSerializerSnapshot |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<C[],GenericArraySerializer<C>> to TypeSerializerSchemaCompatibility<C[]> in method protected outerCompatibility(serializer GenericArraySerializer<C>) : TypeSerializerSchemaCompatibility<C[]> in class org.apache.flink.api.common.typeutils.base.GenericArraySerializerConfigSnapshot |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<T,NS> to TypeSerializerSchemaCompatibility<T> in method public resolveSchemaCompatibility(newSerializer TypeSerializer<T>) : TypeSerializerSchemaCompatibility<T> in class org.apache.flink.api.common.typeutils.CompositeSerializerSnapshot |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<T,NS> to TypeSerializerSchemaCompatibility<T> in method package resolveSchemaCompatibility(writerSchema Schema, readerSchema Schema) : TypeSerializerSchemaCompatibility<T> in class org.apache.flink.formats.avro.typeutils.AvroSerializerSnapshot |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<T,NS> to TypeSerializerSchemaCompatibility<T> in method public resolveSchemaCompatibility(newSerializer TypeSerializer<T>) : TypeSerializerSchemaCompatibility<T> in class org.apache.flink.formats.avro.typeutils.AvroSerializerSnapshot |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<Either<L,R>,NS> to TypeSerializerSchemaCompatibility<Either<L,R>> in method public resolveSchemaCompatibility(newSerializer TypeSerializer<Either<L,R>>) : TypeSerializerSchemaCompatibility<Either<L,R>> in class org.apache.flink.api.java.typeutils.runtime.EitherSerializerConfigSnapshot |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<VoidNamespace,NS> to TypeSerializerSchemaCompatibility<VoidNamespace> in method public resolveSchemaCompatibility(newSerializer TypeSerializer<VoidNamespace>) : TypeSerializerSchemaCompatibility<VoidNamespace> in class org.apache.flink.runtime.state.StateBackendMigrationTestBase.CustomVoidNamespaceSerializerSnapshot |
From |
To |
|
Change Return Type CollectionSerializerConfigSnapshot<List<T>,T> to TypeSerializerSnapshot<List<T>> in method public snapshotConfiguration() : TypeSerializerSnapshot<List<T>> in class org.apache.flink.api.common.typeutils.base.ListSerializer |
From |
To |
|
Change Return Type TypeSerializerSchemaCompatibility<E,X> to TypeSerializerSchemaCompatibility<E> in method private resolveCompatibility(serializer TypeSerializer<?>, snapshot TypeSerializerSnapshot<?>) : TypeSerializerSchemaCompatibility<E> in class org.apache.flink.api.common.typeutils.CompositeSerializerSnapshot |
From |
To |
|
Change Variable Type rightCompatibility : TypeSerializerSchemaCompatibility<?,?> to rightCompatibility : TypeSerializerSchemaCompatibility<?> in method private checkJavaSerializerCompatibility(serializer EitherSerializer<L,R>) : TypeSerializerSchemaCompatibility<Either<L,R>> in class org.apache.flink.api.java.typeutils.runtime.EitherSerializerConfigSnapshot |
From |
To |
|
Change Variable Type compatResult : TypeSerializerSchemaCompatibility<PublicEnum,?> to compatResult : TypeSerializerSchemaCompatibility<PublicEnum> in method public testConfigurationSnapshotSerialization() : void in class org.apache.flink.api.common.typeutils.base.EnumSerializerTest |
From |
To |
|
Change Variable Type leftCompatibility : TypeSerializerSchemaCompatibility<?,?> to leftCompatibility : TypeSerializerSchemaCompatibility<?> in method private checkJavaSerializerCompatibility(serializer EitherSerializer<L,R>) : TypeSerializerSchemaCompatibility<Either<L,R>> in class org.apache.flink.api.java.typeutils.runtime.EitherSerializerConfigSnapshot |
From |
To |
|
Change Variable Type compatResult : TypeSerializerSchemaCompatibility<TestUserClass,?> to compatResult : TypeSerializerSchemaCompatibility<TestUserClass> in method public testReconfigureRepopulateNonregisteredSubclassSerializerCache() : void in class org.apache.flink.api.java.typeutils.runtime.PojoSerializerTest |
From |
To |
|
Change Variable Type compatResult : TypeSerializerSchemaCompatibility<SubTestUserClassA,?> to compatResult : TypeSerializerSchemaCompatibility<SubTestUserClassA> in method public testReconfigureWithDifferentPojoType() : void in class org.apache.flink.api.java.typeutils.runtime.PojoSerializerTest |
From |
To |
|
Change Variable Type stateCompatibility : TypeSerializerSchemaCompatibility<V,?> to stateCompatibility : TypeSerializerSchemaCompatibility<V> in method private tryRegisterStateTable(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<?,V>, snapshotTransformer StateSnapshotTransformer<V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type compatResult : TypeSerializerSchemaCompatibility<TestClassB,?> to compatResult : TypeSerializerSchemaCompatibility<TestClassB> in method public testMigrationStrategyWithDifferentKryoType() : void in class org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializerCompatibilityTest |
From |
To |
|
Change Variable Type compatResult : TypeSerializerSchemaCompatibility<TestUserClass,?> to compatResult : TypeSerializerSchemaCompatibility<TestUserClass> in method public testReconfigureDifferentSubclassRegistrationOrder() : void in class org.apache.flink.api.java.typeutils.runtime.PojoSerializerTest |
From |
To |
|
Change Variable Type compatResult : TypeSerializerSchemaCompatibility<TestUserClass,?> to compatResult : TypeSerializerSchemaCompatibility<TestUserClass> in method public testReconfigureWithDifferentFieldOrder() : void in class org.apache.flink.api.java.typeutils.runtime.PojoSerializerTest |
From |
To |
|
Change Variable Type compatibility : TypeSerializerSchemaCompatibility<T,TypeSerializer<T>> to compatibility : TypeSerializerSchemaCompatibility<T> in method public resolveCompatibilityResult(precedingSerializerConfigSnapshot TypeSerializerSnapshot<T>, newSerializer TypeSerializer<T>) : CompatibilityResult<T> in class org.apache.flink.api.common.typeutils.CompatibilityUtil |
From |
To |
|
Change Variable Type compatResult : TypeSerializerSchemaCompatibility<TestClass,?> to compatResult : TypeSerializerSchemaCompatibility<TestClass> in method public testMigrationStrategyForDifferentRegistrationOrder() : void in class org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializerCompatibilityTest |
From |
To |
|
Change Variable Type keyCompatibility : TypeSerializerSchemaCompatibility<K,?> to keyCompatibility : TypeSerializerSchemaCompatibility<K> in method public getBroadcastState(stateDescriptor MapStateDescriptor<K,V>) : BroadcastState<K,V> in class org.apache.flink.runtime.state.DefaultOperatorStateBackend |
From |
To |
|
Change Variable Type compatibilityResult : TypeSerializerSchemaCompatibility<T,?> to compatibilityResult : TypeSerializerSchemaCompatibility<T> in method private tryRegisterPriorityQueueMetaInfo(stateName String, byteOrderedElementSerializer TypeSerializer<T>) : Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Variable Type stateCompatibility : TypeSerializerSchemaCompatibility<SV,?> to stateCompatibility : TypeSerializerSchemaCompatibility<SV> in method private migrateStateIfNecessary(newMetaInfo RegisteredKeyValueStateBackendMetaInfo<N,SV>, stateDesc StateDescriptor<S,SV>, namespaceSerializer TypeSerializer<N>, stateSerializer TypeSerializer<SV>, stateInfo Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>) : RegisteredKeyValueStateBackendMetaInfo<N,SV> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Variable Type compatibilityResult : TypeSerializerSchemaCompatibility<T,?> to compatibilityResult : TypeSerializerSchemaCompatibility<T> in method public create(stateName String, byteOrderedElementSerializer TypeSerializer<T>) : KeyGroupedInternalPriorityQueue<T> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type namespaceCompatibility : TypeSerializerSchemaCompatibility<N,?> to namespaceCompatibility : TypeSerializerSchemaCompatibility<N> in method private migrateStateIfNecessary(newMetaInfo RegisteredKeyValueStateBackendMetaInfo<N,SV>, stateDesc StateDescriptor<S,SV>, namespaceSerializer TypeSerializer<N>, stateSerializer TypeSerializer<SV>, stateInfo Tuple2<ColumnFamilyHandle,RegisteredStateMetaInfoBase>) : RegisteredKeyValueStateBackendMetaInfo<N,SV> in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Variable Type strategy : TypeSerializerSchemaCompatibility<T,? extends TypeSerializer<T>> to strategy : TypeSerializerSchemaCompatibility<T> in method public testSnapshotConfigurationAndReconfigure() : void in class org.apache.flink.api.common.typeutils.SerializerTestBase |
From |
To |
|
Change Variable Type result : TypeSerializerSchemaCompatibility<ElementT,TypeSerializer<ElementT>> to result : TypeSerializerSchemaCompatibility<ElementT> in method public snapshotIsCompatibleWithTheCurrentSerializer() : void in class org.apache.flink.api.common.typeutils.TypeSerializerSnapshotMigrationTestBase |
From |
To |
|
Change Variable Type valueCompatibility : TypeSerializerSchemaCompatibility<V,?> to valueCompatibility : TypeSerializerSchemaCompatibility<V> in method public getBroadcastState(stateDescriptor MapStateDescriptor<K,V>) : BroadcastState<K,V> in class org.apache.flink.runtime.state.DefaultOperatorStateBackend |
From |
To |
|
Change Variable Type outerCompatibility : TypeSerializerSchemaCompatibility<T,S> to outerCompatibility : TypeSerializerSchemaCompatibility<T> in method public resolveSchemaCompatibility(newSerializer TypeSerializer<T>) : TypeSerializerSchemaCompatibility<T> in class org.apache.flink.api.common.typeutils.CompositeSerializerSnapshot |
From |
To |
|
Change Variable Type stateCompatibility : TypeSerializerSchemaCompatibility<S,?> to stateCompatibility : TypeSerializerSchemaCompatibility<S> in method private getListState(stateDescriptor ListStateDescriptor<S>, mode OperatorStateHandle.Mode) : ListState<S> in class org.apache.flink.runtime.state.DefaultOperatorStateBackend |
From |
To |
|
Change Variable Type typedSerializer : X to typedSerializer : TypeSerializer<E> in method private resolveCompatibility(serializer TypeSerializer<?>, snapshot TypeSerializerSnapshot<?>) : TypeSerializerSchemaCompatibility<E> in class org.apache.flink.api.common.typeutils.CompositeSerializerSnapshot |
From |
To |
|
Change Variable Type namespaceCompatibility : TypeSerializerSchemaCompatibility<N,?> to namespaceCompatibility : TypeSerializerSchemaCompatibility<N> in method private tryRegisterStateTable(namespaceSerializer TypeSerializer<N>, stateDesc StateDescriptor<?,V>, snapshotTransformer StateSnapshotTransformer<V>) : StateTable<K,N,V> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type compatResult : TypeSerializerSchemaCompatibility<TestClass,?> to compatResult : TypeSerializerSchemaCompatibility<TestClass> in method public testMigrationStrategyForRemovedAvroDependency() : void in class org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializerCompatibilityTest |
From |
To |
|
Change Variable Type compatibility : TypeSerializerSchemaCompatibility<?,?> to compatibility : TypeSerializerSchemaCompatibility<?> in method public resolveSchemaCompatibility(newSerializer TypeSerializer<T>) : TypeSerializerSchemaCompatibility<T> in class org.apache.flink.api.common.typeutils.CompositeSerializerSnapshot |
From |
To |
|
Change Variable Type compatResult : TypeSerializerSchemaCompatibility<TestUserClass,?> to compatResult : TypeSerializerSchemaCompatibility<TestUserClass> in method public testReconfigureWithPreviouslyNonregisteredSubclasses() : void in class org.apache.flink.api.java.typeutils.runtime.PojoSerializerTest |
From |
To |