|
Rename Method public testCurrentSchemaSerializerForRestoredStateSerializerProvider() : void renamed to public testCurrentSchemaSerializerForLazilyRegisteredStateSerializerProvider() : void in class org.apache.flink.runtime.state.StateSerializerProviderTest |
From |
To |
|
Rename Method public testUnionListStateMigration() : void renamed to private testOperatorUnionListStateUpgrade(initialAccessDescriptor ListStateDescriptor<TestType>, newAccessDescriptorAfterRestore ListStateDescriptor<TestType>) : void in class org.apache.flink.runtime.state.StateBackendMigrationTestBase |
From |
To |
|
Rename Method public fromRestoredState(stateSerializerSnapshot TypeSerializerSnapshot<T>) : StateSerializerProvider<T> renamed to public fromPreviousSerializerSnapshot(stateSerializerSnapshot TypeSerializerSnapshot<T>) : StateSerializerProvider<T> in class org.apache.flink.runtime.state.StateSerializerProvider |
From |
To |
|
Rename Method public testCurrentSchemaSerializerForNewStateSerializerProvider() : void renamed to public testCurrentSchemaSerializerForEagerlyRegisteredStateSerializerProvider() : void in class org.apache.flink.runtime.state.StateSerializerProviderTest |
From |
To |
|
Rename Method public fromNewState(registeredStateSerializer TypeSerializer<T>) : StateSerializerProvider<T> renamed to public fromNewRegisteredSerializer(registeredStateSerializer TypeSerializer<T>) : StateSerializerProvider<T> in class org.apache.flink.runtime.state.StateSerializerProvider |
From |
To |
|
Rename Method public testRegisterNewSerializerWithNewStateSerializerProviderShouldFail() : void renamed to public testRegisterNewSerializerWithEagerlyRegisteredStateSerializerProviderShouldFail() : void in class org.apache.flink.runtime.state.StateSerializerProviderTest |
From |
To |
|
Rename Method public testRegisterIncompatibleSerializer() : void renamed to public testLazilyRegisterIncompatibleSerializer() : void in class org.apache.flink.runtime.state.StateSerializerProviderTest |
From |
To |
|
Rename Method public testRegisterNewCompatibleAsIsSerializer() : void renamed to public testLazilyRegisterNewCompatibleAsIsSerializer() : void in class org.apache.flink.runtime.state.StateSerializerProviderTest |
From |
To |
|
Rename Method public testPreviousSchemaSerializerForRestoredStateSerializerProvider() : void renamed to public testPreviousSchemaSerializerForLazilyRegisteredStateSerializerProvider() : void in class org.apache.flink.runtime.state.StateSerializerProviderTest |
From |
To |
|
Rename Method public testRegisterNewSerializerTwiceWithNewStateSerializerProviderShouldFail() : void renamed to public testRegisterNewSerializerTwiceWithLazilyRegisteredStateSerializerProviderShouldFail() : void in class org.apache.flink.runtime.state.StateSerializerProviderTest |
From |
To |
|
Rename Method public testKeyedStateRegistrationFailsIfNewNamespaceSerializerIsNotCompatible() : void renamed to private testNamespaceSerializerUpgrade(initialNamespaceSerializer TypeSerializer<TestType>, newNamespaceSerializerAfterRestore TypeSerializer<TestType>) : void in class org.apache.flink.runtime.state.StateBackendMigrationTestBase |
From |
To |
|
Rename Method public testUnionListStateRegistrationFailsIfNewSerializerIsIncompatible() : void renamed to private testOperatorPartitionableListStateUpgrade(initialAccessDescriptor ListStateDescriptor<TestType>, newAccessDescriptorAfterRestore ListStateDescriptor<TestType>) : void in class org.apache.flink.runtime.state.StateBackendMigrationTestBase |
From |
To |
|
Rename Method public testStateBackendCreationFailsIfNewKeySerializerIsNotCompatible() : void renamed to private testKeySerializerUpgrade(initialKeySerializer TypeSerializer<TestType>, newKeySerializer TypeSerializer<TestType>) : void in class org.apache.flink.runtime.state.StateBackendMigrationTestBase |
From |
To |
|
Rename Method public testPreviousSchemaSerializerForNewStateSerializerProvider() : void renamed to public testPreviousSchemaSerializerForEagerlyRegisteredStateSerializerProvider() : void in class org.apache.flink.runtime.state.StateSerializerProviderTest |
From |
To |
|
Rename Method public testRegisterNewCompatibleAfterMigrationSerializer() : void renamed to public testLazilyRegisterNewCompatibleAfterMigrationSerializer() : void in class org.apache.flink.runtime.state.StateSerializerProviderTest |
From |
To |