ef7b7cd968c13ce9df15e30e33300e0f26def303
Files Diff
- Added: 3
- Removed: 0
- Renamed: 0
- Modified: 13
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method protected getEvicter() : EvictionPolicy<OUT> renamed to protected getEviction() : EvictionPolicy<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream | From | To | |
| Move And Rename Method | 1 | ||
| Move And Rename Method private evictFromBuffer(n int) : void from class org.apache.flink.streaming.api.invokable.operator.windowing.StreamDiscretizer to public evict(n int) : void from class org.apache.flink.streaming.api.invokable.operator.windowing.BasicWindowBuffer | From | To | |
| Change Parameter Type | 2 | ||
| Change Parameter Type isMap : boolean to transformation : WindowTransformation in method private partition(transformation WindowTransformation) : DiscretizedStream<OUT> in class org.apache.flink.streaming.api.datastream.DiscretizedStream | From | To | |
| Change Parameter Type isMap : boolean to transformation : WindowTransformation in method private discretize(transformation WindowTransformation) : DiscretizedStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream | From | To | |
| Inline Method | 2 | ||
| Inline Method protected emitFinalWindow() : void inlined to public invoke() : void in class org.apache.flink.streaming.api.invokable.operator.windowing.StreamDiscretizer | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute buffer : LinkedList<IN> to bufferHandler : WindowBuffer<IN> in class org.apache.flink.streaming.api.invokable.operator.windowing.StreamDiscretizer | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type buffer : LinkedList<IN> to bufferHandler : WindowBuffer<IN> in class org.apache.flink.streaming.api.invokable.operator.windowing.StreamDiscretizer | From | To | |
| Extract Method | 2 | ||
| Extract Method private wrap(stream SingleOutputStreamOperator, transformation WindowTransformation) : DiscretizedStream<R> extracted from private wrap(stream SingleOutputStreamOperator) : DiscretizedStream<R> in class org.apache.flink.streaming.api.datastream.DiscretizedStream | From | To | |
| Extract Method private getDiscretizerParallelism() : int extracted from private discretize(isMap boolean) : DiscretizedStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter isMap : boolean to transformation : WindowTransformation in method private partition(transformation WindowTransformation) : DiscretizedStream<OUT> in class org.apache.flink.streaming.api.datastream.DiscretizedStream | From | To | |
| Rename Parameter isMap : boolean to transformation : WindowTransformation in method private discretize(transformation WindowTransformation) : DiscretizedStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream | From | To |