412779fae5b20513997fcacee509082d3fa78f96
Files Diff
- Added: 2
- Removed: 3
- Renamed: 0
- Modified: 8
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method protected evictFirst() : void renamed to private evictFromBuffer(n int) : void in class org.apache.flink.streaming.api.invokable.operator.windowing.StreamDiscretizer | From | To | |
| Move And Inline Method | 1 | ||
| Move And Inline Method public open(parameters Configuration) : void moved from class org.apache.flink.streaming.api.invokable.operator.windowing.GroupedStreamDiscretizer to class org.apache.flink.streaming.api.invokable.operator.windowing.StreamDiscretizer & inlined to public open(parameters Configuration) : void | From | To | |
| Change Parameter Type | 4 | ||
| Change Parameter Type policyHelpers : WindowingHelper... to policyHelper : WindowingHelper in method public every(policyHelper WindowingHelper) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream | From | To | |
| Change Parameter Type triggers : List<TriggerPolicy<OUT>> to trigger : TriggerPolicy<OUT> in method public window(trigger TriggerPolicy<OUT>, evicter EvictionPolicy<OUT>) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.DataStream | From | To | |
| Change Parameter Type policyHelpers : WindowingHelper... to policyHelpers : WindowingHelper in method public window(policyHelpers WindowingHelper) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.DataStream | From | To | |
| Change Parameter Type evicters : List<EvictionPolicy<OUT>> to evicter : EvictionPolicy<OUT> in method public window(trigger TriggerPolicy<OUT>, evicter EvictionPolicy<OUT>) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.DataStream | From | To | |
| Rename Variable | 3 | ||
| Rename Variable target : Runnable to runnable : Runnable in method public open(parameters Configuration) : void in class org.apache.flink.streaming.api.invokable.operator.windowing.StreamDiscretizer | From | To | |
| Rename Variable tmp : int to numToEvict : int in method private evict(input IN, isTriggered boolean) : void in class org.apache.flink.streaming.api.invokable.operator.windowing.StreamDiscretizer | From | To | |
| Rename Variable groupInvokable : StreamDiscretizer<IN> to groupDiscretizer : StreamDiscretizer<IN> in method public invoke() : void in class org.apache.flink.streaming.api.invokable.operator.windowing.GroupedStreamDiscretizer | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.streaming.api.invokable.operator.windowing.WindowInvokableTest renamed to org.apache.flink.streaming.api.invokable.operator.windowing.StreamDiscretizerTest | From | To | |
| Replace Variable With Attribute | 1 | ||
| Replace Variable With Attribute t : Thread to activePolicyThread : Thread in method public invoke() : void in class org.apache.flink.streaming.api.invokable.operator.windowing.StreamDiscretizer | From | To | |
| Rename Attribute | 5 | ||
| Rename Attribute userTriggers : LinkedList<TriggerPolicy<OUT>> to userTrigger : TriggerPolicy<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream | From | To | |
| Rename Attribute evictionHelpers : List<WindowingHelper<OUT>> to evictionHelper : WindowingHelper<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream | From | To | |
| Rename Attribute userEvicters : LinkedList<EvictionPolicy<OUT>> to userEvicter : EvictionPolicy<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream | From | To | |
| Rename Attribute windowingGroups : Map<Object,StreamDiscretizer<IN>> to groupedDiscretizers : Map<Object,StreamDiscretizer<IN>> in class org.apache.flink.streaming.api.invokable.operator.windowing.GroupedStreamDiscretizer | From | To | |
| Rename Attribute triggerHelpers : List<WindowingHelper<OUT>> to triggerHelper : WindowingHelper<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type expected : List<Integer> to expected : List<StreamWindow<Integer>> in method public testWindowInvokableWithTimePolicy() : void in class org.apache.flink.streaming.api.invokable.operator.windowing.StreamDiscretizerTest | From | To | |
| Change Variable Type expected : List<Integer> to expected : List<StreamWindow<Integer>> in method public testWindowInvokableWithCountPolicy() : void in class org.apache.flink.streaming.api.invokable.operator.windowing.StreamDiscretizerTest | From | To | |
| Extract Method | 1 | ||
| Extract Method private evict(input IN, isTriggered boolean) : void extracted from protected processRealElement(input IN) : void in class org.apache.flink.streaming.api.invokable.operator.windowing.StreamDiscretizer | From | To | |
| Change Attribute Type | 4 | ||
| Change Attribute Type userEvicters : LinkedList<EvictionPolicy<OUT>> to userEvicter : EvictionPolicy<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream | From | To | |
| Change Attribute Type triggerHelpers : List<WindowingHelper<OUT>> to triggerHelper : WindowingHelper<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream | From | To | |
| Change Attribute Type userTriggers : LinkedList<TriggerPolicy<OUT>> to userTrigger : TriggerPolicy<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream | From | To | |
| Change Attribute Type evictionHelpers : List<WindowingHelper<OUT>> to evictionHelper : WindowingHelper<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter triggers : List<TriggerPolicy<OUT>> to trigger : TriggerPolicy<OUT> in method public window(trigger TriggerPolicy<OUT>, evicter EvictionPolicy<OUT>) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.DataStream | From | To | |
| Rename Parameter evicters : List<EvictionPolicy<OUT>> to evicter : EvictionPolicy<OUT> in method public window(trigger TriggerPolicy<OUT>, evicter EvictionPolicy<OUT>) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.DataStream | From | To | |
| Rename Parameter policyHelpers : WindowingHelper... to policyHelper : WindowingHelper in method public every(policyHelper WindowingHelper) : WindowedDataStream<OUT> in class org.apache.flink.streaming.api.datastream.WindowedDataStream | From | To |