ef11e636154c343c6ba557060fb0df3ddcb3c77a
Files Diff
- Added: 1
- Removed: 1
- Renamed: 0
- Modified: 21
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move And Inline Method | 1 | ||
| Move And Inline Method public getOperatorState() : OperatorState<S> moved from class org.apache.flink.streaming.runtime.tasks.StreamingRuntimeContext to class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator & inlined to public getStateSnapshotFromFunction(checkpointId long, timestamp long) : Serializable | From | To | |
| Change Parameter Type | 2 | ||
| Change Parameter Type operator : OneInputStreamOperator<?,T> to operator : OneInputStreamOperator<Object,T> in method public OperatorCollector(operator OneInputStreamOperator<Object,T>) in class org.apache.flink.streaming.runtime.tasks.OutputHandler.OperatorCollector | From | To | |
| Change Parameter Type state : StreamOperatorState<?,?> to statePartitioner : KeySelector<?,?> in method public StreamingRuntimeContext(name String, env Environment, userCodeClassLoader ClassLoader, executionConfig ExecutionConfig, statePartitioner KeySelector<?,?>, provider StateHandleProvider<?>) in class org.apache.flink.streaming.runtime.tasks.StreamingRuntimeContext | From | To | |
| Rename Variable | 2 | ||
| Rename Variable operatorState : StreamOperatorState<?,?> to operatorStates : Map<String,StreamOperatorState> in method public getStateSnapshotFromFunction(checkpointId long, timestamp long) : Serializable in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator | From | To | |
| Rename Variable operatorState : StreamOperatorState<?,Serializable> to restoredState : StreamOperatorState in method public restoreInitialState(state Serializable) : void in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.streaming.api.state.StatefulFunctionTest renamed to org.apache.flink.streaming.api.state.StatefulOperatorTest | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute state : StreamOperatorState to statePartitioner : KeySelector<?,?> in class org.apache.flink.streaming.runtime.tasks.StreamingRuntimeContext | From | To | |
| Rename Attribute opState : OperatorState<Integer> to counter : OperatorState<Integer> in class org.apache.flink.streaming.api.state.StatefulOperatorTest.StatefulMapper | From | To | |
| Change Variable Type | 4 | ||
| Change Variable Type operatorState : StreamOperatorState<?,Serializable> to restoredState : StreamOperatorState in method public restoreInitialState(state Serializable) : void in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator | From | To | |
| Change Variable Type chainedOperator : StreamOperator to chainedOperator : StreamOperator<?> in method public setInitialState(stateHandle StateHandle<Serializable>) : void in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Change Variable Type operatorState : StreamOperatorState<?,?> to operatorStates : Map<String,StreamOperatorState> in method public getStateSnapshotFromFunction(checkpointId long, timestamp long) : Serializable in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator | From | To | |
| Change Variable Type snapshots : Map<Serializable,StateHandle<Serializable>> to snapshots : Map<String,Map<Serializable,StateHandle<Serializable>>> in method public restoreInitialState(state Serializable) : void in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type operator : OneInputStreamOperator to operator : OneInputStreamOperator<Object,T> in class org.apache.flink.streaming.runtime.tasks.OutputHandler.OperatorCollector | From | To | |
| Change Attribute Type state : StreamOperatorState to statePartitioner : KeySelector<?,?> in class org.apache.flink.streaming.runtime.tasks.StreamingRuntimeContext | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter state : StreamOperatorState<?,?> to statePartitioner : KeySelector<?,?> in method public StreamingRuntimeContext(name String, env Environment, userCodeClassLoader ClassLoader, executionConfig ExecutionConfig, statePartitioner KeySelector<?,?>, provider StateHandleProvider<?>) in class org.apache.flink.streaming.runtime.tasks.StreamingRuntimeContext | From | To |