6642768ad8f8c5d1856742a6d148f7724c20666c
Files Diff
- Added: 0
- Removed: 63
- Renamed: 0
- Modified: 63
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type legacyOperatorState : ChainedStateHandle<StreamStateHandle> to managedOperatorState : ChainedStateHandle<OperatorStateHandle> in method public SubtaskState(managedOperatorState ChainedStateHandle<OperatorStateHandle>, rawOperatorState ChainedStateHandle<OperatorStateHandle>, managedKeyedState KeyedStateHandle, rawKeyedState KeyedStateHandle) in class org.apache.flink.runtime.checkpoint.SubtaskState | From | To | |
| Inline Method | 2 | ||
| Inline Method private reduce(reduceFunction ReduceFunction<T>, function WindowFunction<T,R,K,W>, resultType TypeInformation<R>, legacyWindowOpType LegacyWindowOperatorType) : SingleOutputStreamOperator<R> inlined to public reduce(reduceFunction ReduceFunction<T>, function WindowFunction<T,R,K,W>, resultType TypeInformation<R>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream | From | To | |
| Inline Method private reduce(reduceFunction ReduceFunction<T>, function WindowFunction<T,R,K,W>, legacyWindowOpType LegacyWindowOperatorType) : SingleOutputStreamOperator<R> inlined to public reduce(reduceFunction ReduceFunction<T>, function WindowFunction<T,R,K,W>) : SingleOutputStreamOperator<R> in class org.apache.flink.streaming.api.datastream.WindowedStream | From | To | |
| Rename Variable | 2 | ||
| Rename Variable db : RocksDB to dbRef : RocksDB in method private openDB(path String, stateColumnFamilyDescriptors List<ColumnFamilyDescriptor>, stateColumnFamilyHandles List<ColumnFamilyHandle>) : RocksDB in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend | From | To | |
| Rename Variable streamConfig : StreamConfig to cfg : StreamConfig in method private testRestoreWithInterrupt(mode int) : void in class org.apache.flink.streaming.runtime.tasks.InterruptSensitiveRestoreTest | From | To | |
| Change Return Type | 1 | ||
| Change Return Type BitSet to List<BitSet> in method public snapshotState(checkpointId long, timestamp long) : List<BitSet> in class org.apache.flink.streaming.connectors.kinesis.testutils.ExactlyOnceValidatingConsumerThread.ExactlyOnceValidatingMapper | From | To | |
| Extract Variable | 1 | ||
| Extract Variable idAlternatives : List<JobVertexID> in method public testUserProvidedHashing() : void from class org.apache.flink.streaming.graph.StreamingJobGraphGeneratorNodeHashTest | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type streamTaskState : StreamStateHandle to streamTaskState : Collection<OperatorStateHandle> in method public testTriggerSavepointAndResumeWithFileBasedCheckpoints() : void in class org.apache.flink.test.checkpointing.SavepointITCase | From | To | |
| Change Variable Type statesToDiscard : List<StateObject> to statesToDiscard : Collection<StateObject> in method package releaseResources(canceled boolean) : void in class org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend.RocksDBIncrementalSnapshotOperation | From | To | |
| Inline Variable | 1 | ||
| Inline Variable operatorID : OperatorID in method private checkpointStreamOperator(op StreamOperator<?>) : void from class org.apache.flink.streaming.runtime.tasks.StreamTask.CheckpointingOperation | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter legacyOperatorState : ChainedStateHandle<StreamStateHandle> to managedOperatorState : ChainedStateHandle<OperatorStateHandle> in method public SubtaskState(managedOperatorState ChainedStateHandle<OperatorStateHandle>, rawOperatorState ChainedStateHandle<OperatorStateHandle>, managedKeyedState KeyedStateHandle, rawKeyedState KeyedStateHandle) in class org.apache.flink.runtime.checkpoint.SubtaskState | From | To | |
| Rename Parameter checkpointTimestamp : long to timestamp : long in method public snapshotState(checkpointId long, timestamp long) : List<BitSet> in class org.apache.flink.streaming.connectors.kinesis.testutils.ExactlyOnceValidatingConsumerThread.ExactlyOnceValidatingMapper | From | To |