|
Move And Inline Method public open(conf Configuration) : void moved from class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.StringPrefixCountRichMapFunction to class org.apache.flink.streaming.api.operators.StreamGroupedFold & inlined to public open() : void |
From |
To |
|
Move And Inline Method public open(conf Configuration) : void moved from class org.apache.flink.streaming.api.functions.source.StatefulSequenceSource to class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator & inlined to public open() : void |
From |
To |
|
Move And Inline Method public open(conf Configuration) : void moved from class org.apache.flink.streaming.api.functions.source.StatefulSequenceSource to class org.apache.flink.storm.wrappers.BoltWrapper & inlined to public open() : void |
From |
To |
|
Move And Inline Method public open(conf Configuration) : void moved from class org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase.StatefulCounterFunction to class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator & inlined to public open() : void |
From |
To |
|
Move And Inline Method public open(conf Configuration) : void moved from class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.StringPrefixCountRichMapFunction to class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator & inlined to public open() : void |
From |
To |
|
Move And Inline Method public open(conf Configuration) : void moved from class org.apache.flink.test.recovery.ProcessFailureStreamingRecoveryITCase.SleepyDurableGenerateSequence to class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator & inlined to public open() : void |
From |
To |
|
Move And Inline Method public open(parameters Configuration) : void moved from class org.apache.flink.streaming.runtime.operators.BucketStreamSortOperator to class org.apache.flink.streaming.runtime.operators.ExtractTimestampsOperator & inlined to public open() : void |
From |
To |
|
Move And Inline Method public open(parameters Configuration) : void moved from class org.apache.flink.test.checkpointing.UdfStreamOperatorCheckpointingITCase.StatefulMultipleSequence to class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator & inlined to public open() : void |
From |
To |
|
Move And Inline Method public open(conf Configuration) : void moved from class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.StringPrefixCountRichMapFunction to class org.apache.flink.streaming.api.operators.StreamGroupedReduce & inlined to public open() : void |
From |
To |
|
Move And Inline Method public open(conf Configuration) : void moved from class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.StringPrefixCountRichMapFunction to class org.apache.flink.streaming.runtime.operators.ExtractTimestampsOperator & inlined to public open() : void |
From |
To |
|
Move And Inline Method public createProvider(checkpointDir String) : StateHandleProvider<Serializable> moved from class org.apache.flink.runtime.state.FileStateHandle to class org.apache.flink.test.recovery.ProcessFailureStreamingRecoveryITCase & inlined to public testProgram(jobManagerPort int, coordinateDir File) : void |
From |
To |
|
Move And Inline Method public open(conf Configuration) : void moved from class org.apache.flink.test.checkpointing.StateCheckpoinedITCase.StatefulCounterFunction to class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator & inlined to public open() : void |
From |
To |
|
Change Parameter Type strategy : StreamOperator.ChainingStrategy to strategy : ChainingStrategy in method public setChainingStrategy(strategy ChainingStrategy) : void in class org.apache.flink.streaming.api.transformations.TwoInputTransformation |
From |
To |
|
Change Parameter Type output : Collector<StreamRecord<?>> to output : Collector<StreamRecord<OUT>> in method public addCollector(output Collector<StreamRecord<OUT>>, edge StreamEdge) : void in class org.apache.flink.streaming.api.collector.selector.OutputSelectorWrapper |
From |
To |
|
Change Parameter Type strategy : StreamOperator.ChainingStrategy to strategy : ChainingStrategy in method public setChainingStrategy(strategy ChainingStrategy) : void in class org.apache.flink.streaming.api.transformations.FeedbackTransformation |
From |
To |
|
Change Parameter Type state : Integer to state : Long in method public restoreState(state Long) : void in class org.apache.flink.streaming.api.functions.source.StatefulSequenceSource |
From |
To |
|
Change Parameter Type provider : StateHandleProvider<?> to backend : StateBackend<?> in method public setStateBackend(backend StateBackend<?>) : void in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Change Parameter Type strategy : StreamOperator.ChainingStrategy to strategy : ChainingStrategy in method public setChainingStrategy(strategy ChainingStrategy) : void in class org.apache.flink.streaming.api.transformations.CoFeedbackTransformation |
From |
To |
|
Change Parameter Type output : Collector<StreamRecord<?>> to output : Collector<StreamRecord<OUT>> in method public addCollector(output Collector<StreamRecord<OUT>>, edge StreamEdge) : void in class org.apache.flink.streaming.api.collector.selector.BroadcastOutputSelectorWrapper |
From |
To |
|
Change Parameter Type output : Collector<StreamRecord<?>> to output : Collector<StreamRecord<OUT>> in method public addCollector(output Collector<StreamRecord<OUT>>, edge StreamEdge) : void in class org.apache.flink.streaming.api.collector.selector.DirectedOutputSelectorWrapper |
From |
To |
|
Change Parameter Type strategy : StreamOperator.ChainingStrategy to strategy : ChainingStrategy in method public setChainingStrategy(strategy ChainingStrategy) : void in class org.apache.flink.streaming.api.transformations.SelectTransformation |
From |
To |
|
Change Parameter Type provider : StateHandleProvider<?> to backend : StateBackend<?> in method public setStateBackend(backend StateBackend<?>) : StreamExecutionEnvironment in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Change Parameter Type strategy : StreamOperator.ChainingStrategy to strategy : ChainingStrategy in method public abstract setChainingStrategy(strategy ChainingStrategy) : void in class org.apache.flink.streaming.api.transformations.StreamTransformation |
From |
To |
|
Change Parameter Type strategy : StreamOperator.ChainingStrategy to strategy : ChainingStrategy in method public setChainingStrategy(strategy ChainingStrategy) : void in class org.apache.flink.streaming.api.transformations.PartitionTransformation |
From |
To |
|
Change Parameter Type strategy : StreamOperator.ChainingStrategy to strategy : ChainingStrategy in method public setChainingStrategy(strategy ChainingStrategy) : void in class org.apache.flink.streaming.api.transformations.SinkTransformation |
From |
To |
|
Change Parameter Type strategy : StreamOperator.ChainingStrategy to strategy : ChainingStrategy in method public setChainingStrategy(strategy ChainingStrategy) : void in class org.apache.flink.streaming.api.transformations.UnionTransformation |
From |
To |
|
Change Parameter Type serializer : TypeSerializer<StreamRecord<T>> to serializer : TypeSerializer<T> in method public CopyingChainingOutput(operator OneInputStreamOperator<T,?>, serializer TypeSerializer<T>) in class org.apache.flink.streaming.runtime.tasks.OperatorChain.CopyingChainingOutput |
From |
To |
|
Change Parameter Type strategy : StreamOperator.ChainingStrategy to strategy : ChainingStrategy in method public setChainingStrategy(strategy ChainingStrategy) : void in class org.apache.flink.streaming.api.transformations.SplitTransformation |
From |
To |
|
Change Parameter Type strategy : StreamOperator.ChainingStrategy to strategy : ChainingStrategy in method public setChainingStrategy(strategy ChainingStrategy) : void in class org.apache.flink.streaming.api.transformations.SourceTransformation |
From |
To |
|
Change Parameter Type output : Output<StreamRecord<?>> to output : Output<StreamRecord<OUT>> in method public addCollector(output Output<StreamRecord<OUT>>, edge StreamEdge) : void in class org.apache.flink.streaming.runtime.io.CollectorWrapper |
From |
To |
|
Change Parameter Type strategy : StreamOperator.ChainingStrategy to strategy : ChainingStrategy in method public setChainingStrategy(strategy ChainingStrategy) : void in class org.apache.flink.streaming.api.transformations.OneInputTransformation |
From |
To |
|
Change Parameter Type provider : StateHandleProvider<?> to backend : StateBackend<?> in method public setStateBackend(backend StateBackend<?>) : void in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Change Variable Type mockContext : StreamingRuntimeContext to mockTask : StreamTask<?,?> in method private createMockTaskWithTimer(timerService ScheduledExecutorService, lock Object) : StreamTask<?,?> in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Variable Type mockContext : StreamingRuntimeContext to mockTask : StreamTask<?,?> in method private createMockTaskWithTimer(timerService ScheduledExecutorService, lock Object) : StreamTask<?,?> in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Variable Type parallelNotifications : List[] to parallelNotifications : List<Long>[] in method public postSubmit() : void in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase |
From |
To |
|
Change Variable Type operator : StreamGroupedFold<Integer,String> to operator : StreamGroupedFold<Integer,String,Integer> in method public testOpenClose() : void in class org.apache.flink.streaming.api.operators.StreamGroupedFoldTest |
From |
To |
|
Change Variable Type context : StreamingRuntimeContext to context : RuntimeContext in method public open(parameters Configuration) : void in class org.apache.flink.streaming.api.functions.sink.FileSinkFunction |
From |
To |
|
Change Variable Type output : Output<OUT> to output : Output<?> in method public emitWatermark(mark Watermark) : void in class org.apache.flink.streaming.runtime.io.CollectorWrapper |
From |
To |
|
Change Variable Type operator : StreamGroupedFold<Integer,String> to operator : StreamGroupedFold<Integer,String,String> in method public testGroupedFold() : void in class org.apache.flink.streaming.api.operators.StreamGroupedFoldTest |
From |
To |
|
Change Variable Type checkList : List[][] to checkList : List<Long>[][] in method public postSubmit() : void in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase |
From |
To |
|
Change Variable Type stateHandle : WrapperStateHandle to allStates : StreamTaskStateList in method public triggerCheckpoint(checkpointId long, timestamp long) : void in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Rename Method public getStateHandleProvider() : StateHandleProvider<?> renamed to public getStateBackend() : StateBackend<?> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Rename Method public getStateHandleProvider(cl ClassLoader) : StateHandleProvider<R> renamed to public getStateBackend(cl ClassLoader) : StateBackend<?> in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Rename Method public getOperatorState(name String, defaultState S, partitioned boolean, checkpointer StateCheckpointer<S,C>) : OperatorState<S> renamed to public getKeyValueState(stateType Class<S>, defaultState S) : OperatorState<S> in class org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext |
From |
To |
|
Rename Method public setTypeSerializerOut1(serializer TypeSerializer<?>) : void renamed to public setTypeSerializerOut(serializer TypeSerializer<?>) : void in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Rename Method public getOperatorState(name String, defaultState S, partitioned boolean) : OperatorState<S> renamed to public getKeyValueState(stateType TypeInformation<S>, defaultState S) : OperatorState<S> in class org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext |
From |
To |
|
Rename Method public getOperatorState(name String, defaultState S, partitioned boolean, checkpointer StateCheckpointer<S,C>) : OperatorState<S> renamed to public getKeyValueState(stateType Class<S>, defaultState S) : OperatorState<S> in class org.apache.flink.api.common.functions.RuntimeContext |
From |
To |
|
Rename Method public setStateHandleProvider(provider StateHandleProvider<?>) : StreamExecutionEnvironment renamed to public setStateBackend(backend StateBackend<?>) : StreamExecutionEnvironment in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Rename Method public setStateHandleProvider(provider StateHandleProvider<?>) : void renamed to public setStateBackend(backend StateBackend<?>) : void in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Rename Method public setStateHandleProvider(provider StateHandleProvider<?>) : void renamed to public setStateBackend(backend StateBackend<?>) : void in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Rename Method public getOperatorState(name String, defaultState S, partitioned boolean) : OperatorState<S> renamed to public getKeyValueState(stateType TypeInformation<S>, defaultState S) : OperatorState<S> in class org.apache.flink.api.common.functions.RuntimeContext |
From |
To |
|
Rename Method public getStateHandleProvider() : StateHandleProvider<?> renamed to public getStateBackend() : StateBackend<?> in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Rename Method public getTypeSerializerOut1(cl ClassLoader) : TypeSerializer<T> renamed to public getTypeSerializerOut(cl ClassLoader) : TypeSerializer<T> in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Rename Variable taskConfig : ExecutionConfig to execConfig : ExecutionConfig in method public testOpen() : void in class org.apache.flink.storm.wrappers.BoltWrapperTest |
From |
To |
|
Rename Variable flinkConfig : Configuration to cfg : Configuration in method public testOpen() : void in class org.apache.flink.storm.wrappers.BoltWrapperTest |
From |
To |
|
Rename Variable mockContext : StreamingRuntimeContext to mockTask : StreamTask<?,?> in method private createMockTaskWithTimer(timerService ScheduledExecutorService, lock Object) : StreamTask<?,?> in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Rename Variable stateHandle : WrapperStateHandle to allStates : StreamTaskStateList in method public triggerCheckpoint(checkpointId long, timestamp long) : void in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Rename Variable mockContext : StreamingRuntimeContext to mockTask : StreamTask<?,?> in method private createMockTaskWithTimer(timerService ScheduledExecutorService, lock Object) : StreamTask<?,?> in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest |
From |
To |
|
Change Return Type StateHandleProvider<R> to StateBackend<?> in method public getStateBackend(cl ClassLoader) : StateBackend<?> in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Change Return Type StateHandleProvider<?> to StateBackend<?> in method public getStateBackend() : StateBackend<?> in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Change Return Type StateHandleProvider<?> to StateBackend<?> in method public getStateBackend() : StateBackend<?> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Change Return Type Object to T in method public readObjectFromConfig(config Configuration, key String, cl ClassLoader) : T in class org.apache.flink.util.InstantiationUtil |
From |
To |
|
Change Return Type Object to T in method public deserializeObject(bytes byte[], cl ClassLoader) : T in class org.apache.flink.util.InstantiationUtil |
From |
To |
|
Change Return Type Integer to Long in method public snapshotState(checkpointId long, checkpointTimestamp long) : Long in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.StringPrefixCountRichMapFunction |
From |
To |
|
Rename Attribute streamOperator : O to headOperator : Operator in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Rename Attribute stateHandleProvider : StateHandleProvider<?> to defaultStateBackend : StateBackend<?> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Rename Attribute headContext : StreamingRuntimeContext to stateBackend : StateBackend<?> in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Rename Attribute STATEHANDLE_PROVIDER : String to STATE_BACKEND : String in class org.apache.flink.streaming.api.graph.StreamConfig |
From |
To |
|
Rename Attribute outputHandler : OutputHandler<OUT> to operatorChain : OperatorChain<OUT> in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Rename Attribute executionConfig : ExecutionConfig to config : StreamConfig in class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Rename Attribute stateHandleProvider : StateHandleProvider<?> to stateBackend : StateBackend<?> in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Change Attribute Type count : OperatorState<Long> to count : long in class org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase.StatefulCounterFunction |
From |
To |
|
Change Attribute Type count : OperatorState<Long> to count : long in class org.apache.flink.test.checkpointing.UdfStreamOperatorCheckpointingITCase.OnceFailingIdentityMapFunction |
From |
To |
|
Change Attribute Type index : OperatorState<Integer> to index : int in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.GeneratingSourceFunction |
From |
To |
|
Change Attribute Type index : OperatorState<Integer> to index : int in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.StringGeneratingSourceFunction |
From |
To |
|
Change Attribute Type serializer : TypeSerializer<StreamRecord<T>> to serializer : TypeSerializer<T> in class org.apache.flink.streaming.runtime.tasks.OperatorChain.CopyingChainingOutput |
From |
To |
|
Change Attribute Type executionConfig : ExecutionConfig to config : StreamConfig in class org.apache.flink.streaming.api.operators.AbstractStreamOperator |
From |
To |
|
Change Attribute Type stateHandleProvider : StateHandleProvider<?> to stateBackend : StateBackend<?> in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Change Attribute Type index : OperatorState<Integer> to index : int in class org.apache.flink.test.checkpointing.CoStreamCheckpointingITCase.StringGeneratingSourceFunction |
From |
To |
|
Change Attribute Type outputMap : Map<String,List<Collector<StreamRecord<OUT>>>> to outputMap : HashMap<String,ArrayList<Collector<StreamRecord<OUT>>>> in class org.apache.flink.streaming.api.collector.selector.DirectedOutputSelectorWrapper |
From |
To |
|
Change Attribute Type values : OperatorState<HashMap<Object,OUT>> to values : OperatorState<OUT> in class org.apache.flink.streaming.api.operators.StreamGroupedFold |
From |
To |
|
Change Attribute Type count : OperatorState<Long> to count : long in class org.apache.flink.test.checkpointing.UdfStreamOperatorCheckpointingITCase.StatefulMultipleSequence |
From |
To |
|
Change Attribute Type completedCheckpoints : List[] to completedCheckpoints : List<Long>[] in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.LeftIdentityCoRichFlatMapFunction |
From |
To |
|
Change Attribute Type completedCheckpoints : List[] to completedCheckpoints : List<Long>[] in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.IdentityMapFunction |
From |
To |
|
Change Attribute Type count : OperatorState<Long> to count : long in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.StringPrefixCountRichMapFunction |
From |
To |
|
Change Attribute Type index : OperatorState<Integer> to index : int in class org.apache.flink.test.checkpointing.PartitionedStateCheckpointingITCase.IntGeneratingSourceFunction |
From |
To |
|
Change Attribute Type outputs : List<Collector<StreamRecord<OUT>>> to outputs : ArrayList<Collector<StreamRecord<OUT>>> in class org.apache.flink.streaming.api.collector.selector.BroadcastOutputSelectorWrapper |
From |
To |
|
Change Attribute Type count : Long to count : long in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.StringRichFilterFunction |
From |
To |
|
Change Attribute Type count : OperatorState<Long> to count : long in class org.apache.flink.test.checkpointing.StateCheckpoinedITCase.StatefulCounterFunction |
From |
To |
|
Change Attribute Type collected : OperatorState<Long> to collected : long in class org.apache.flink.test.recovery.ProcessFailureStreamingRecoveryITCase.SleepyDurableGenerateSequence |
From |
To |
|
Change Attribute Type stateHandleProvider : StateHandleProvider<?> to defaultStateBackend : StateBackend<?> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Change Attribute Type inputCount : OperatorState<Long> to inputCount : long in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.OnceFailingPrefixCounter |
From |
To |
|
Change Attribute Type headContext : StreamingRuntimeContext to stateBackend : StateBackend<?> in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Attribute Type completedCheckpoints : List[] to completedCheckpoints : List<Long>[] in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.LongRichFilterFunction |
From |
To |
|
Change Attribute Type allOutputs : List<Output<OUT>> to allOutputs : ArrayList<Output<StreamRecord<OUT>>> in class org.apache.flink.streaming.runtime.io.CollectorWrapper |
From |
To |
|
Change Attribute Type collected : OperatorState<Long> to collected : long in class org.apache.flink.streaming.api.functions.source.StatefulSequenceSource |
From |
To |
|
Change Attribute Type completedCheckpoints : List[] to completedCheckpoints : List<Long>[] in class org.apache.flink.test.checkpointing.StreamCheckpointNotifierITCase.GeneratingSourceFunction |
From |
To |
|
Change Attribute Type values : OperatorState<HashMap<Object,IN>> to values : OperatorState<IN> in class org.apache.flink.streaming.api.operators.StreamGroupedReduce |
From |
To |
|
Change Attribute Type selectAllOutputs : Set<Collector<StreamRecord<OUT>>> to selectAllOutputs : HashSet<Collector<StreamRecord<OUT>>> in class org.apache.flink.streaming.api.collector.selector.DirectedOutputSelectorWrapper |
From |
To |
|
Change Attribute Type outputHandler : OutputHandler<OUT> to operatorChain : OperatorChain<OUT> in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |
|
Change Attribute Type streamOperator : O to headOperator : Operator in class org.apache.flink.streaming.runtime.tasks.StreamTask |
From |
To |