|
Change Parameter Type keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public restoreKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState List<KeyGroupsStateHandle>, kvStateRegistry TaskKvStateRegistry) : KeyedStateBackend<K> in class org.apache.flink.runtime.state.filesystem.FsStateBackend |
From |
To |
|
Change Parameter Type keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public createKeyedStateBackend(keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange) : KeyedStateBackend<K> in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Parameter Type keyGroupAssigner : KeyGroupAssigner<K> to maxParallelism : int in method public KeyGroupStreamPartitioner(keySelector KeySelector<T,K>, maxParallelism int) in class org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitioner |
From |
To |
|
Change Parameter Type keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public restoreKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState List<KeyGroupsStateHandle>, kvStateRegistry TaskKvStateRegistry) : KeyedStateBackend<K> in class org.apache.flink.test.streaming.runtime.StateBackendITCase.FailingStateBackend |
From |
To |
|
Change Parameter Type keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public KeyedStateBackend(kvStateRegistry TaskKvStateRegistry, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange) in class org.apache.flink.runtime.state.KeyedStateBackend |
From |
To |
|
Change Parameter Type keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public restoreKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState List<KeyGroupsStateHandle>, kvStateRegistry TaskKvStateRegistry) : KeyedStateBackend<K> in class org.apache.flink.runtime.state.memory.MemoryStateBackend |
From |
To |
|
Change Parameter Type keyGroupAssigner : KeyGroupAssigner<?> to numberOfKeGroups : int in method private createTaskConfig(partitioner KeySelector<?,?>, keySerializer TypeSerializer<?>, numberOfKeGroups int) : StreamConfig in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Parameter Type keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method protected restoreKeyedBackend(keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, state List<KeyGroupsStateHandle>, env Environment) : KeyedStateBackend<K> in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Change Parameter Type keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public HeapKeyedStateBackend(kvStateRegistry TaskKvStateRegistry, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange) in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Parameter Type keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public RocksDBKeyedStateBackend(jobId JobID, operatorIdentifier String, instanceBasePath File, dbOptions DBOptions, columnFamilyOptions ColumnFamilyOptions, kvStateRegistry TaskKvStateRegistry, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange) in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Parameter Type keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public createKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, kvStateRegistry TaskKvStateRegistry) : KeyedStateBackend<K> in class org.apache.flink.test.streaming.runtime.StateBackendITCase.FailingStateBackend |
From |
To |
|
Change Parameter Type keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public createKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, kvStateRegistry TaskKvStateRegistry) : KeyedStateBackend<K> in class org.apache.flink.runtime.state.filesystem.FsStateBackend |
From |
To |
|
Change Parameter Type keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public abstract restoreKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState List<KeyGroupsStateHandle>, kvStateRegistry TaskKvStateRegistry) : KeyedStateBackend<K> in class org.apache.flink.runtime.state.AbstractStateBackend |
From |
To |
|
Change Parameter Type keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public RocksDBKeyedStateBackend(jobId JobID, operatorIdentifier String, instanceBasePath File, dbOptions DBOptions, columnFamilyOptions ColumnFamilyOptions, kvStateRegistry TaskKvStateRegistry, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoreState List<KeyGroupsStateHandle>) in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Change Parameter Type keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public abstract createKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, kvStateRegistry TaskKvStateRegistry) : KeyedStateBackend<K> in class org.apache.flink.runtime.state.AbstractStateBackend |
From |
To |
|
Change Parameter Type keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public createKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, kvStateRegistry TaskKvStateRegistry) : KeyedStateBackend<K> in class org.apache.flink.runtime.state.memory.MemoryStateBackend |
From |
To |
|
Change Parameter Type keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public createKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, kvStateRegistry TaskKvStateRegistry) : KeyedStateBackend<K> in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend |
From |
To |
|
Change Parameter Type keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public HeapKeyedStateBackend(kvStateRegistry TaskKvStateRegistry, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState List<KeyGroupsStateHandle>) in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Parameter Type keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public restoreKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState List<KeyGroupsStateHandle>, kvStateRegistry TaskKvStateRegistry) : KeyedStateBackend<K> in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend |
From |
To |
|
Change Parameter Type keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method protected createKeyedBackend(keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, env Environment) : KeyedStateBackend<K> in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Rename Parameter keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method protected restoreKeyedBackend(keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, state List<KeyGroupsStateHandle>, env Environment) : KeyedStateBackend<K> in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Rename Parameter keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public HeapKeyedStateBackend(kvStateRegistry TaskKvStateRegistry, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange) in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Rename Parameter keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public RocksDBKeyedStateBackend(jobId JobID, operatorIdentifier String, instanceBasePath File, dbOptions DBOptions, columnFamilyOptions ColumnFamilyOptions, kvStateRegistry TaskKvStateRegistry, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange) in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Rename Parameter keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method protected createKeyedBackend(keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, env Environment) : KeyedStateBackend<K> in class org.apache.flink.runtime.state.StateBackendTestBase |
From |
To |
|
Rename Parameter classLoader : ClassLoader to cl : ClassLoader in method public getNumberOfKeyGroups(cl ClassLoader) : Integer in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Rename Parameter keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public abstract restoreKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState List<KeyGroupsStateHandle>, kvStateRegistry TaskKvStateRegistry) : KeyedStateBackend<K> in class org.apache.flink.runtime.state.AbstractStateBackend |
From |
To |
|
Rename Parameter keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public KeyedStateBackend(kvStateRegistry TaskKvStateRegistry, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange) in class org.apache.flink.runtime.state.KeyedStateBackend |
From |
To |
|
Rename Parameter keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public HeapKeyedStateBackend(kvStateRegistry TaskKvStateRegistry, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState List<KeyGroupsStateHandle>) in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Rename Parameter keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public restoreKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState List<KeyGroupsStateHandle>, kvStateRegistry TaskKvStateRegistry) : KeyedStateBackend<K> in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend |
From |
To |
|
Rename Parameter keyGroupAssigner : KeyGroupAssigner<?> to numberOfKeGroups : int in method private createTaskConfig(partitioner KeySelector<?,?>, keySerializer TypeSerializer<?>, numberOfKeGroups int) : StreamConfig in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Rename Parameter keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public createKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, kvStateRegistry TaskKvStateRegistry) : KeyedStateBackend<K> in class org.apache.flink.test.streaming.runtime.StateBackendITCase.FailingStateBackend |
From |
To |
|
Rename Parameter keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public createKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, kvStateRegistry TaskKvStateRegistry) : KeyedStateBackend<K> in class org.apache.flink.runtime.state.filesystem.FsStateBackend |
From |
To |
|
Rename Parameter keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public restoreKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState List<KeyGroupsStateHandle>, kvStateRegistry TaskKvStateRegistry) : KeyedStateBackend<K> in class org.apache.flink.runtime.state.filesystem.FsStateBackend |
From |
To |
|
Rename Parameter keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public createKeyedStateBackend(keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange) : KeyedStateBackend<K> in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Rename Parameter keyGroupAssigner : KeyGroupAssigner<K> to maxParallelism : int in method public KeyGroupStreamPartitioner(keySelector KeySelector<T,K>, maxParallelism int) in class org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitioner |
From |
To |
|
Rename Parameter keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public RocksDBKeyedStateBackend(jobId JobID, operatorIdentifier String, instanceBasePath File, dbOptions DBOptions, columnFamilyOptions ColumnFamilyOptions, kvStateRegistry TaskKvStateRegistry, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoreState List<KeyGroupsStateHandle>) in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend |
From |
To |
|
Rename Parameter keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public restoreKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState List<KeyGroupsStateHandle>, kvStateRegistry TaskKvStateRegistry) : KeyedStateBackend<K> in class org.apache.flink.test.streaming.runtime.StateBackendITCase.FailingStateBackend |
From |
To |
|
Rename Parameter keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public createKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, kvStateRegistry TaskKvStateRegistry) : KeyedStateBackend<K> in class org.apache.flink.runtime.state.memory.MemoryStateBackend |
From |
To |
|
Rename Parameter keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public abstract createKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, kvStateRegistry TaskKvStateRegistry) : KeyedStateBackend<K> in class org.apache.flink.runtime.state.AbstractStateBackend |
From |
To |
|
Rename Parameter keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public restoreKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, restoredState List<KeyGroupsStateHandle>, kvStateRegistry TaskKvStateRegistry) : KeyedStateBackend<K> in class org.apache.flink.runtime.state.memory.MemoryStateBackend |
From |
To |
|
Rename Parameter keyGroupAssigner : KeyGroupAssigner<K> to numberOfKeyGroups : int in method public createKeyedStateBackend(env Environment, jobID JobID, operatorIdentifier String, keySerializer TypeSerializer<K>, numberOfKeyGroups int, keyGroupRange KeyGroupRange, kvStateRegistry TaskKvStateRegistry) : KeyedStateBackend<K> in class org.apache.flink.contrib.streaming.state.RocksDBStateBackend |
From |
To |