eb96d5d2205eb1e807b2dc56bf0fd1e33b13c760
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 8
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Variable | 1 | ||
| Rename Variable output : ResultPartitionWriter to streamRecordWriter : StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>> in method private performCheckpoint(checkpointMetaData CheckpointMetaData, checkpointOptions CheckpointOptions, checkpointMetrics CheckpointMetrics) : boolean in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Parameterize Variable | 2 | ||
| Parameterize Variable mockTask : StreamTask<Integer,StreamMap<Integer,Integer>> to task : StreamTask<IN,OT> in method private createOperatorChain(streamConfig StreamConfig, environment Environment, task StreamTask<IN,OT>) : OperatorChain<IN,OT> in class org.apache.flink.streaming.runtime.operators.StreamOperatorChainingTest | From | To | |
| Change Variable Type | 3 | ||
| Change Variable Type output : ResultPartitionWriter to streamRecordWriter : StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>> in method private performCheckpoint(checkpointMetaData CheckpointMetaData, checkpointOptions CheckpointOptions, checkpointMetrics CheckpointMetrics) : boolean in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Change Variable Type mockTask : StreamTask<Integer,StreamMap<Integer,Integer>> to task : StreamTask<IN,OT> in method private createOperatorChain(streamConfig StreamConfig, environment Environment, task StreamTask<IN,OT>) : OperatorChain<IN,OT> in class org.apache.flink.streaming.runtime.operators.StreamOperatorChainingTest | From | To | |
| Extract Method | 2 | ||
| Extract Method private createOperatorChain(streamConfig StreamConfig, environment Environment, task StreamTask<IN,OT>) : OperatorChain<IN,OT> extracted from private testMultiChaining(env StreamExecutionEnvironment) : void in class org.apache.flink.streaming.runtime.operators.StreamOperatorChainingTest | From | To | |
| Extract Method private createOperatorChain(streamConfig StreamConfig, environment Environment, task StreamTask<IN,OT>) : OperatorChain<IN,OT> extracted from private testMultiChainingWithSplit(env StreamExecutionEnvironment) : void in class org.apache.flink.streaming.runtime.operators.StreamOperatorChainingTest | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type toSync : ResultPartitionWriter to toSync : RecordWriter<IOReadableWritable> in class org.apache.flink.runtime.iterative.task.IterationHeadTask | From | To | |
| Extract And Move Method | 1 | ||
| Extract And Move Method public getTransitiveChainedTaskConfigsWithSelf(cl ClassLoader) : Map<Integer,StreamConfig> extracted from public OperatorChain(containingTask StreamTask<OUT,OP>) in class org.apache.flink.streaming.runtime.tasks.OperatorChain & moved to class org.apache.flink.streaming.api.graph.StreamConfig | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter env : Environment to environment : Environment in method protected StreamTask(environment Environment, timeProvider ProcessingTimeService) in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To |