flink a7e24580a2178b27ea77e7327c39ad7e75cac0a3

a7e24580a2178b27ea77e7327c39ad7e75cac0a3

Files Diff

Added: 10
Removed: 0
Renamed: 0
Modified: 28

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Move And Inline Method	1
Move And Inline Method public createProvider() : LocalStateHandleProvider moved from class org.apache.flink.runtime.state.LocalStateHandle to class org.apache.flink.streaming.runtime.tasks.StreamTask & inlined to private getStateHandleProvider() : StateHandleProvider<Serializable>	From	To
Change Parameter Type	5
Change Parameter Type runtimeContext : RuntimeContext to runtimeContext : StreamingRuntimeContext in method public setup(output Output<OUT>, runtimeContext StreamingRuntimeContext) : void in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator	From	To
Change Parameter Type runtimeContext : RuntimeContext to runtimeContext : StreamingRuntimeContext in method public setup(output Output<OUT>, runtimeContext StreamingRuntimeContext) : void in class org.apache.flink.streaming.api.operators.AbstractStreamOperator	From	To
Change Parameter Type runtimeContext : RuntimeContext to runtimeContext : StreamingRuntimeContext in method public setup(output Output<OUT>, runtimeContext StreamingRuntimeContext) : void in class org.apache.flink.streaming.api.operators.StreamOperator	From	To
Change Parameter Type state : Serializable to state : R in method public createStateHandle(state R) : LocalStateHandle<R> in class org.apache.flink.runtime.state.LocalStateHandle.LocalStateHandleProvider	From	To
Change Parameter Type state : Serializable to state : T in method public LocalStateHandle(state T) in class org.apache.flink.runtime.state.LocalStateHandle	From	To
Rename Variable	2
Rename Variable typedFunction : Checkpointed<T> to operatorState : StreamOperatorState<?,Serializable> in method public restoreInitialState(state Serializable) : void in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator	From	To
Rename Variable typedState : T to snapshots : Map<Serializable,StateHandle<Serializable>> in method public restoreInitialState(state Serializable) : void in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator	From	To
Inline Method	1
Inline Method private setStateOnFunction(state Serializable, function Function) : void inlined to public restoreInitialState(state Serializable) : void in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator	From	To
Change Return Type	3
Change Return Type Serializable to Integer in method public snapshotState(state Integer, checkpointId long, checkpointTimestamp long) : Integer in class org.apache.flink.streaming.runtime.tasks.SourceStreamTaskTest.MockSource	From	To
Change Return Type Serializable to T in method public getState() : T in class org.apache.flink.runtime.state.LocalStateHandle	From	To
Change Return Type LocalStateHandle to LocalStateHandle<R> in method public createStateHandle(state R) : LocalStateHandle<R> in class org.apache.flink.runtime.state.LocalStateHandle.LocalStateHandleProvider	From	To
Extract Variable	1
Extract Variable operatorName : String in method public createRuntimeContext(conf StreamConfig) : StreamingRuntimeContext from class org.apache.flink.streaming.runtime.tasks.StreamTask	From	To
Change Variable Type	4
Change Variable Type runtimeContext : RuntimeContext to runtimeContext : StreamingRuntimeContext in method public createAndExecute(operator TwoInputStreamOperator<IN1,IN2,OUT>, input1 List<IN1>, input2 List<IN2>) : List<OUT> in class org.apache.flink.streaming.util.MockCoContext	From	To
Change Variable Type typedState : T to snapshots : Map<Serializable,StateHandle<Serializable>> in method public restoreInitialState(state Serializable) : void in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator	From	To
Change Variable Type runtimeContext : RuntimeContext to runtimeContext : StreamingRuntimeContext in method public createAndExecute(operator OneInputStreamOperator<IN,OUT>, inputs List<IN>) : List<OUT> in class org.apache.flink.streaming.util.MockContext	From	To
Change Variable Type typedFunction : Checkpointed<T> to operatorState : StreamOperatorState<?,Serializable> in method public restoreInitialState(state Serializable) : void in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator	From	To
Change Attribute Type	8
Change Attribute Type collected : long to collected : OperatorState<Long> in class org.apache.flink.test.recovery.ProcessFailureStreamingRecoveryITCase.SleepyDurableGenerateSequence	From	To
Change Attribute Type count : long to count : OperatorState<Long> in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.StatefulCounterFunction	From	To
Change Attribute Type count : long to count : OperatorState<Long> in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.StringPrefixCountRichMapFunction	From	To
Change Attribute Type collected : long to collected : OperatorState<Long> in class org.apache.flink.test.recovery.ProcessFailureStreamingRecoveryITCase.CheckpointedSink	From	To
Change Attribute Type state : Serializable to state : T in class org.apache.flink.runtime.state.LocalStateHandle	From	To
Change Attribute Type runtimeContext : RuntimeContext to runtimeContext : StreamingRuntimeContext in class org.apache.flink.streaming.api.operators.AbstractStreamOperator	From	To
Change Attribute Type count : long to count : OperatorState<Long> in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.StringRichFilterFunction	From	To
Change Attribute Type index : long to index : OperatorState<Integer> in class org.apache.flink.test.checkpointing.StreamCheckpointingITCase.StringGeneratingSourceFunction	From	To

a7e24580a2178b27ea77e7327c39ad7e75cac0a3

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: