|
Change Parameter Type backend : StateBackend<?> to backend : AbstractStateBackend in method public DbStateBackend(backendConfig DbBackendConfig, backend AbstractStateBackend) in class org.apache.flink.contrib.streaming.state.DbStateBackend |
From |
To |
|
Change Parameter Type backend : StateBackend<?> to backend : AbstractStateBackend in method public setStateBackend(backend AbstractStateBackend) : void in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Change Parameter Type kvStates : HashMap<String,KvStateSnapshot<?,?,?>> to kvStates : HashMap<String,KvStateSnapshot<?,?,?,?,?>> in method public setKvStates(kvStates HashMap<String,KvStateSnapshot<?,?,?,?,?>>) : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskState |
From |
To |
|
Change Parameter Type backend : StateBackend<?> to backend : AbstractStateBackend in method public setStateBackend(backend AbstractStateBackend) : StreamExecutionEnvironment in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Change Parameter Type out : StateBackend.CheckpointStateOutputView to out : AbstractStateBackend.CheckpointStateOutputView in method protected writeToState(out AbstractStateBackend.CheckpointStateOutputView) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.Context |
From |
To |
|
Change Parameter Type key : K to key : Tuple2<K,N> in method public put(key Tuple2<K,N>, value Optional<V>) : Optional<V> in class org.apache.flink.contrib.streaming.state.LazyDbValueState.StateCache |
From |
To |
|
Change Parameter Type m : Map<? extends K,? extends Optional<V>> to m : Map<? extends Tuple2<K,N>,? extends Optional<V>> in method public putAll(m Map<? extends Tuple2<K,N>,? extends Optional<V>>) : void in class org.apache.flink.contrib.streaming.state.LazyDbValueState.StateCache |
From |
To |
|
Change Parameter Type out : StateBackend.CheckpointStateOutputView to out : AbstractStateBackend.CheckpointStateOutputView in method protected writeToState(out AbstractStateBackend.CheckpointStateOutputView) : void in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator.Context |
From |
To |
|
Change Parameter Type key : K to key : Tuple2<K,N> in method private getFromDatabaseOrNull(key Tuple2<K,N>) : V in class org.apache.flink.contrib.streaming.state.LazyDbValueState.StateCache |
From |
To |
|
Change Parameter Type backend : StateBackend<?> to backend : AbstractStateBackend in method public setStateBackend(backend AbstractStateBackend) : void in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Change Parameter Type next : Entry<K,Optional<V>> to next : Entry<Tuple2<K,N>,Optional<V>> in method public add(next Entry<Tuple2<K,N>,Optional<V>>, timestamp long) : void in class org.apache.flink.contrib.streaming.state.LazyDbValueState.BatchInserter |
From |
To |
|
Change Parameter Type eldest : Entry<K,Optional<V>> to eldest : Entry<Tuple2<K,N>,Optional<V>> in method protected removeEldestEntry(eldest Entry<Tuple2<K,N>,Optional<V>>) : boolean in class org.apache.flink.contrib.streaming.state.LazyDbValueState.StateCache |
From |
To |
|
Change Variable Type snapshot1 : KvStateSnapshot<Integer,String,DbStateBackend> to snapshot1 : KvStateSnapshot<Integer,Integer,ValueState<String>,ValueStateDescriptor<String>,DbStateBackend> in method public testCaching() : void in class org.apache.flink.contrib.streaming.state.DbStateBackendTest |
From |
To |
|
Change Variable Type snapshots : HashMap<String,KvStateSnapshot<?,?,?>> to partitionedSnapshots : HashMap<String,KvStateSnapshot<?,?,?,?,?>> in method public snapshotOperatorState(checkpointId long, timestamp long) : StreamTaskState in class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Change Variable Type os : StateBackend.CheckpointStateOutputStream to os : AbstractStateBackend.CheckpointStateOutputStream in method public testOversizedStateStream() : void in class org.apache.flink.runtime.state.MemoryStateBackendTest |
From |
To |
|
Change Variable Type kvStates : HashMap<String,KvStateSnapshot<?,?,?>> to kvStates : HashMap<String,KvStateSnapshot<?,?,?,?,?>> in method public discardState() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskState |
From |
To |
|
Change Variable Type configuredBackend : StateBackend<?> to stateBackend : AbstractStateBackend in method public createStateBackend(operatorIdentifier String, keySerializer TypeSerializer<?>) : AbstractStateBackend in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Variable Type restored : KvState<Integer,String,DbStateBackend> to restored : KvState<Integer,Integer,ValueState<String>,ValueStateDescriptor<String>,DbStateBackend> in method public testCaching() : void in class org.apache.flink.contrib.streaming.state.DbStateBackendTest |
From |
To |
|
Change Variable Type values : Iterator<KvStateSnapshot<?,?,?>> to values : Iterator<KvStateSnapshot<?,?,?,?,?>> in method public discardState() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskState |
From |
To |
|
Change Variable Type stream4 : StateBackend.CheckpointStateOutputStream to stream4 : AbstractStateBackend.CheckpointStateOutputStream in method public testStateOutputStream() : void in class org.apache.flink.hdfstests.FileStateBackendTest |
From |
To |
|
Change Variable Type kvState : KvStateSnapshot<?,?,?> to kvState : KvStateSnapshot<?,?,?,?,?> in method public StreamTaskStateList(states StreamTaskState[]) in class org.apache.flink.streaming.runtime.tasks.StreamTaskStateList |
From |
To |
|
Change Variable Type next : Entry<K,Optional<V>> to next : Entry<Tuple2<K,N>,Optional<V>> in method private evictIfFull() : void in class org.apache.flink.contrib.streaming.state.LazyDbValueState.StateCache |
From |
To |
|
Change Variable Type out : StateBackend.CheckpointStateOutputView to out : AbstractStateBackend.CheckpointStateOutputView in method public snapshotOperatorState(checkpointId long, timestamp long) : StreamTaskState in class org.apache.flink.streaming.runtime.operators.windowing.AbstractAlignedProcessingTimeWindowOperator |
From |
To |
|
Change Variable Type out : StateBackend.CheckpointStateOutputView to out : AbstractStateBackend.CheckpointStateOutputView in method public snapshotOperatorState(checkpointId long, timestamp long) : StreamTaskState in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Change Variable Type restored2 : KvState<Integer,String,DbStateBackend> to restored2 : KvState<Integer,Integer,ValueState<String>,ValueStateDescriptor<String>,DbStateBackend> in method public testKeyValueState() : void in class org.apache.flink.contrib.streaming.state.DbStateBackendTest |
From |
To |
|
Change Variable Type entryIterator : Iterator<Entry<K,Optional<V>>> to entryIterator : Iterator<Entry<Tuple2<K,N>,Optional<V>>> in method private evictIfFull() : void in class org.apache.flink.contrib.streaming.state.LazyDbValueState.StateCache |
From |
To |
|
Change Variable Type stateBackend : StateBackend<?> to stateBackend : AbstractStateBackend in method public snapshotOperatorState(checkpointId long, timestamp long) : StreamTaskState in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator |
From |
To |
|
Change Variable Type lastSeenState : OperatorState<Long> to lastSeenState : ValueState<Long> in method public onEventTime(time long, window GlobalWindow, ctx TriggerContext) : TriggerResult in class org.apache.flink.streaming.examples.windowing.SessionWindowing.SessionTrigger |
From |
To |
|
Change Variable Type count : OperatorState<Long> to count : ValueState<Long> in method public onElement(element Object, timestamp long, window W, ctx TriggerContext) : TriggerResult in class org.apache.flink.streaming.api.windowing.triggers.CountTrigger |
From |
To |
|
Change Variable Type out : StateBackend.CheckpointStateOutputView to out : AbstractStateBackend.CheckpointStateOutputView in method public snapshotOperatorState(checkpointId long, timestamp long) : StreamTaskState in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator |
From |
To |
|
Change Variable Type lastElementState : OperatorState<T> to lastElementState : ValueState<T> in method public onElement(element T, timestamp long, window W, ctx TriggerContext) : TriggerResult in class org.apache.flink.streaming.api.windowing.triggers.DeltaTrigger |
From |
To |
|
Change Variable Type stream : StateBackend.CheckpointStateOutputStream to stream : AbstractStateBackend.CheckpointStateOutputStream in method public testEmptyState() : void in class org.apache.flink.runtime.state.FsCheckpointStateOutputStreamTest |
From |
To |
|
Change Variable Type snapshot2 : KvStateSnapshot<Integer,String,DbStateBackend> to snapshot2 : KvStateSnapshot<Integer,Integer,ValueState<String>,ValueStateDescriptor<String>,DbStateBackend> in method public testKeyValueState() : void in class org.apache.flink.contrib.streaming.state.DbStateBackendTest |
From |
To |
|
Change Variable Type stream4 : StateBackend.CheckpointStateOutputStream to stream4 : AbstractStateBackend.CheckpointStateOutputStream in method public testStateOutputStream() : void in class org.apache.flink.runtime.state.FileStateBackendTest |
From |
To |
|
Change Variable Type fsState : AbstractFileState to fsState : AbstractFileStateHandle in method public testCheckpointsRemovedWithJobManagerBackendOnShutdown() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type s : KvStateSnapshot<?,?,?> to s : KvStateSnapshot<?,?,?,?,?> in method public discardState() : void in class org.apache.flink.streaming.runtime.tasks.StreamTaskState |
From |
To |
|
Change Variable Type kvStates : HashMap<String,KvStateSnapshot<?,?,?>> to kvStates : HashMap<String,KvStateSnapshot<?,?,?,?,?>> in method public StreamTaskStateList(states StreamTaskState[]) in class org.apache.flink.streaming.runtime.tasks.StreamTaskStateList |
From |
To |
|
Change Variable Type os : StateBackend.CheckpointStateOutputStream to os : AbstractStateBackend.CheckpointStateOutputStream in method public testStateStream() : void in class org.apache.flink.runtime.state.MemoryStateBackendTest |
From |
To |
|
Change Variable Type fsState : AbstractFileState to fsState : AbstractFileStateHandle in method public testTriggerSavepointAndResume() : void in class org.apache.flink.test.checkpointing.SavepointITCase |
From |
To |
|
Change Variable Type cache : Map<Integer,Optional<String>> to cache : Map<Tuple2<Integer,Integer>,Optional<String>> in method public testCaching() : void in class org.apache.flink.contrib.streaming.state.DbStateBackendTest |
From |
To |
|
Change Variable Type first : OperatorState<Boolean> to first : ValueState<Boolean> in method public onElement(element Object, timestamp long, window W, ctx TriggerContext) : TriggerResult in class org.apache.flink.streaming.api.windowing.triggers.ContinuousEventTimeTrigger |
From |
To |
|
Change Variable Type fireState : OperatorState<Long> to fireState : ValueState<Long> in method public onElement(element Object, timestamp long, window W, ctx TriggerContext) : TriggerResult in class org.apache.flink.streaming.api.windowing.triggers.ContinuousProcessingTimeTrigger |
From |
To |
|
Change Variable Type stream5 : StateBackend.CheckpointStateOutputStream to stream5 : AbstractStateBackend.CheckpointStateOutputStream in method public testStateOutputStream() : void in class org.apache.flink.runtime.state.FileStateBackendTest |
From |
To |
|
Change Variable Type lastSeenState : OperatorState<Long> to lastSeenState : ValueState<Long> in method public onElement(element Tuple3<String,Long,Integer>, timestamp long, window GlobalWindow, ctx TriggerContext) : TriggerResult in class org.apache.flink.streaming.examples.windowing.SessionWindowing.SessionTrigger |
From |
To |
|
Change Variable Type modified : Map<Integer,Optional<String>> to modified : Map<Tuple2<Integer,Integer>,Optional<String>> in method public testCaching() : void in class org.apache.flink.contrib.streaming.state.DbStateBackendTest |
From |
To |
|
Change Variable Type stream5 : StateBackend.CheckpointStateOutputStream to stream5 : AbstractStateBackend.CheckpointStateOutputStream in method public testStateOutputStream() : void in class org.apache.flink.hdfstests.FileStateBackendTest |
From |
To |
|
Change Variable Type fireState : OperatorState<Long> to fireState : ValueState<Long> in method public onProcessingTime(time long, window W, ctx TriggerContext) : TriggerResult in class org.apache.flink.streaming.api.windowing.triggers.ContinuousProcessingTimeTrigger |
From |
To |
|
Change Variable Type stream : StateBackend.CheckpointStateOutputStream to stream : AbstractStateBackend.CheckpointStateOutputStream in method private runTest(numBytes int, bufferSize int, threshold int, expectFile boolean) : void in class org.apache.flink.runtime.state.FsCheckpointStateOutputStreamTest |
From |
To |
|
Change Return Type StateBackend<T> to AbstractStateBackend in method public createFromConfig(config Configuration) : AbstractStateBackend in class org.apache.flink.runtime.state.StateBackendFactory |
From |
To |
|
Change Return Type OperatorState<S> to ValueState<S> in method public getKeyValueState(name String, stateType Class<S>, defaultState S) : ValueState<S> in class org.apache.flink.api.common.functions.RuntimeContext |
From |
To |
|
Change Return Type StateBackend<?> to AbstractStateBackend in method public getStateBackend() : AbstractStateBackend in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Change Return Type StateBackend<?> to AbstractStateBackend in method public createStateBackend(operatorIdentifier String, keySerializer TypeSerializer<?>) : AbstractStateBackend in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Return Type OperatorState<S> to ValueState<S> in method public getKeyValueState(name String, defaultState S) : ValueState<S> in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.Context |
From |
To |
|
Change Return Type KvStateSnapshot<K,V,Backend> to KvStateSnapshot<K,N,S,SD,Backend> in method public snapshot(checkpointId long, timestamp long) : KvStateSnapshot<K,N,S,SD,Backend> in class org.apache.flink.runtime.state.KvState |
From |
To |
|
Change Return Type OperatorState<S> to ValueState<S> in method public getKeyValueState(name String, defaultState S) : ValueState<S> in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator.Context |
From |
To |
|
Change Return Type OperatorState<S> to ValueState<S> in method public getKeyValueState(name String, stateType TypeInformation<S>, defaultState S) : ValueState<S> in class org.apache.flink.streaming.api.operators.StreamingRuntimeContext |
From |
To |
|
Change Return Type OperatorState<S> to ValueState<S> in method public getKeyValueState(name String, stateType TypeInformation<S>, defaultState S) : ValueState<S> in class org.apache.flink.streaming.connectors.kafka.testutils.MockRuntimeContext |
From |
To |
|
Change Return Type StateBackend<?> to AbstractStateBackend in method public getStateBackend() : AbstractStateBackend in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Change Return Type OperatorState<S> to ValueState<S> in method public getKeyValueState(name String, stateType Class<S>, defaultState S) : ValueState<S> in class org.apache.flink.streaming.api.operators.StreamingRuntimeContext |
From |
To |
|
Change Return Type OperatorState<S> to ValueState<S> in method public getKeyValueState(name String, stateType TypeInformation<S>, defaultState S) : ValueState<S> in class org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext |
From |
To |
|
Change Return Type StateBackend<?> to AbstractStateBackend in method public getStateBackend(cl ClassLoader) : AbstractStateBackend in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Change Return Type OperatorState<S> to ValueState<S> in method public getKeyValueState(name String, stateType Class<S>, defaultState S) : ValueState<S> in class org.apache.flink.streaming.connectors.kafka.testutils.MockRuntimeContext |
From |
To |
|
Change Return Type OperatorState<S> to ValueState<S> in method public getKeyValueState(name String, defaultState S) : ValueState<S> in class org.apache.flink.streaming.api.windowing.triggers.Trigger.TriggerContext |
From |
To |
|
Change Return Type HashMap<String,KvStateSnapshot<?,?,?>> to HashMap<String,KvStateSnapshot<?,?,?,?,?>> in method public getKvStates() : HashMap<String,KvStateSnapshot<?,?,?,?,?>> in class org.apache.flink.streaming.runtime.tasks.StreamTaskState |
From |
To |
|
Change Return Type KvState<K,V,FailingStateBackend> to ListState<T> in method protected createListState(namespaceSerializer TypeSerializer<N>, stateDesc ListStateDescriptor<T>) : ListState<T> in class org.apache.flink.streaming.runtime.state.StateBackendITCase.FailingStateBackend |
From |
To |
|
Change Return Type OperatorState<S> to ValueState<S> in method public getKeyValueState(name String, stateType Class<S>, defaultState S) : ValueState<S> in class org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext |
From |
To |
|
Change Return Type MemHeapKvState<K,V> to ValueState<V> in method public createValueState(namespaceSerializer TypeSerializer<N>, stateDesc ValueStateDescriptor<V>) : ValueState<V> in class org.apache.flink.runtime.state.memory.MemoryStateBackend |
From |
To |
|
Change Return Type OperatorState<S> to ValueState<S> in method public getKeyValueState(name String, stateType TypeInformation<S>, defaultState S) : ValueState<S> in class org.apache.flink.api.common.functions.RuntimeContext |
From |
To |
|
Change Return Type StateBackend<?> to AbstractStateBackend in method public getStateBackend() : AbstractStateBackend in class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |