26535c487753975556aafc19c2ce4f9c24cc677b
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 18
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public getOutputName(outputIndex int) : List<String> renamed to public getOutputNames(outputIndex int) : List<String> in class org.apache.flink.streaming.api.StreamConfig | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type outputs : List<RecordWriter<SerializationDelegate<StreamRecord<OUT>>>> to endCollector : StreamOutputWrapper<OUT> in method package setPartitioner(outputNumber int, endCollector StreamOutputWrapper<OUT>) : Collector<OUT> in class org.apache.flink.streaming.api.streamvertex.OutputHandler | From | To | |
| Rename Variable | 2 | ||
| Rename Variable outputName : List<String> to outputNames : List<String> in method package setPartitioner(outputNumber int, endCollector StreamOutputWrapper<OUT>) : Collector<OUT> in class org.apache.flink.streaming.api.streamvertex.OutputHandler | From | To | |
| Rename Variable vertexName : String to sourceName : String in method private buildJobGraph() : void in class org.apache.flink.streaming.api.JobGraphBuilder | From | To | |
| Change Return Type | 2 | ||
| Change Return Type StreamOutputWrapper<OUT> to Collector<OUT> in method public getCollector() : Collector<OUT> in class org.apache.flink.streaming.api.streamvertex.OutputHandler | From | To | |
| Change Return Type void to Collector<OUT> in method package setPartitioner(outputNumber int, endCollector StreamOutputWrapper<OUT>) : Collector<OUT> in class org.apache.flink.streaming.api.streamvertex.OutputHandler | From | To | |
| Extract Superclass | 1 | ||
| Extract Superclass org.apache.flink.streaming.api.invokable.ChainableInvokable from classes [org.apache.flink.streaming.api.invokable.SinkInvokable, org.apache.flink.streaming.api.invokable.operator.CounterInvokable, org.apache.flink.streaming.api.invokable.operator.FilterInvokable, org.apache.flink.streaming.api.invokable.operator.FlatMapInvokable, org.apache.flink.streaming.api.invokable.operator.MapInvokable, org.apache.flink.streaming.api.invokable.operator.StreamReduceInvokable] | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute bufferTimeout : long to numberOfChainedTasks : int in class org.apache.flink.streaming.api.streamvertex.OutputHandler | From | To | |
| Rename Attribute connectionTypes : Map<String,List<StreamPartitioner<?>>> to outPartitioning : Map<String,List<StreamPartitioner<?>>> in class org.apache.flink.streaming.api.JobGraphBuilder | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type bufferTimeout : long to numberOfChainedTasks : int in class org.apache.flink.streaming.api.streamvertex.OutputHandler | From | To | |
| Split Attribute | 1 | ||
| Split Attribute outEdgeList : Map<String,List<String>> to [sources : Set<String>, builtVertices : Set<String>] in class org.apache.flink.streaming.api.JobGraphBuilder | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter outputs : List<RecordWriter<SerializationDelegate<StreamRecord<OUT>>>> to endCollector : StreamOutputWrapper<OUT> in method package setPartitioner(outputNumber int, endCollector StreamOutputWrapper<OUT>) : Collector<OUT> in class org.apache.flink.streaming.api.streamvertex.OutputHandler | From | To |