|
Rename Variable trigger : TriggerContext to context : Context in method public trigger(time long) : void in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator |
From |
To |
|
Rename Variable bufferAndTrigger : Tuple2<WindowBuffer<IN>,TriggerContext> to context : Context in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Rename Variable bufferAndTrigger : Tuple2<WindowBuffer<IN>,TriggerContext> to context : Context in method private processTriggerResult(triggerResult Trigger.TriggerResult, key K, window W) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Rename Variable bufferAndTrigger : Tuple2<WindowBuffer<IN>,TriggerContext> to context : Context in method private processTriggerResult(triggerResult Trigger.TriggerResult, window W) : void in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator |
From |
To |
|
Rename Variable bufferAndTrigger : Tuple2<WindowBuffer<IN>,TriggerContext> to context : Context in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator |
From |
To |
|
Rename Variable trigger : TriggerContext to context : Context in method public processWatermark(mark Watermark) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Rename Variable trigger : TriggerContext to context : Context in method public processWatermark(mark Watermark) : void in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator |
From |
To |
|
Rename Variable trigger : TriggerContext to context : Context in method public trigger(time long) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Move Attribute package trigger : Trigger<? super IN,? super W> from class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator.TriggerContext to private trigger : Trigger<? super IN,? super W> from class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Move Attribute package trigger : Trigger<? super IN,? super W> from class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.TriggerContext to private trigger : Trigger<? super IN,? super W> from class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator |
From |
To |
|
Move Attribute package trigger : Trigger<? super IN,? super W> from class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator.TriggerContext to private trigger : Trigger<? super IN,? super W> from class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator |
From |
To |
|
Move Attribute package trigger : Trigger<? super IN,? super W> from class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.TriggerContext to private trigger : Trigger<? super IN,? super W> from class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Change Variable Type keyWindows : Map<W,Tuple2<WindowBuffer<IN>,TriggerContext>> to keyWindows : Map<W,Context> in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Change Variable Type trigger : TriggerContext to context : Context in method public processWatermark(mark Watermark) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Change Variable Type triggers : Set<TriggerContext> to triggers : Set<Context> in method public registerWatermarkTimer(time long) : void in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator.Context |
From |
To |
|
Change Variable Type entry : Map.Entry<K,Map<W,Tuple2<WindowBuffer<IN>,TriggerContext>>> to entry : Map.Entry<K,Map<W,Context>> in method public close() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Change Variable Type trigger : TriggerContext to context : Context in method public processWatermark(mark Watermark) : void in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator |
From |
To |
|
Change Variable Type trigger : TriggerContext to context : Context in method public trigger(time long) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Change Variable Type trigger : TriggerContext to context : Context in method public trigger(time long) : void in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator |
From |
To |
|
Change Variable Type keyWindows : Map<W,Tuple2<WindowBuffer<IN>,TriggerContext>> to keyWindows : Map<W,Context> in method public close() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Change Variable Type triggers : Map.Entry<Long,Set<TriggerContext>> to triggers : Map.Entry<Long,Set<Context>> in method public trigger(time long) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Change Variable Type bufferAndTrigger : Tuple2<WindowBuffer<IN>,TriggerContext> to context : Context in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Change Variable Type triggers : Map.Entry<Long,Set<TriggerContext>> to triggers : Map.Entry<Long,Set<Context>> in method public processWatermark(mark Watermark) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Change Variable Type bufferAndTrigger : Tuple2<WindowBuffer<IN>,TriggerContext> to context : Context in method private processTriggerResult(triggerResult Trigger.TriggerResult, key K, window W) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Change Variable Type triggers : Map.Entry<Long,Set<TriggerContext>> to triggers : Map.Entry<Long,Set<Context>> in method public trigger(time long) : void in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator |
From |
To |
|
Change Variable Type bufferAndTrigger : Tuple2<WindowBuffer<IN>,TriggerContext> to context : Context in method public processElement(element StreamRecord<IN>) : void in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator |
From |
To |
|
Change Variable Type keyWindows : Map<W,Tuple2<WindowBuffer<IN>,TriggerContext>> to keyWindows : Map<W,Context> in method private processTriggerResult(triggerResult Trigger.TriggerResult, key K, window W) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Change Variable Type triggers : Map.Entry<Long,Set<TriggerContext>> to triggers : Map.Entry<Long,Set<Context>> in method public processWatermark(mark Watermark) : void in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator |
From |
To |
|
Change Variable Type window : W to window : Context in method public close() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Change Variable Type window : W to window : Context in method public close() : void in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator |
From |
To |
|
Change Variable Type triggers : Set<TriggerContext> to triggers : Set<Context> in method public registerProcessingTimeTimer(time long) : void in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator.Context |
From |
To |
|
Change Variable Type bufferAndTrigger : Tuple2<WindowBuffer<IN>,TriggerContext> to context : Context in method private processTriggerResult(triggerResult Trigger.TriggerResult, window W) : void in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator |
From |
To |
|
Change Attribute Type watermarkTimers : Map<Long,Set<TriggerContext>> to watermarkTimers : Map<Long,Set<Context>> in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Change Attribute Type windows : Map<K,Map<W,Tuple2<WindowBuffer<IN>,TriggerContext>>> to windows : Map<K,Map<W,Context>> in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Change Attribute Type processingTimeTimers : Map<Long,Set<TriggerContext>> to processingTimeTimers : Map<Long,Set<Context>> in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperator |
From |
To |
|
Change Attribute Type watermarkTimers : Map<Long,Set<TriggerContext>> to watermarkTimers : Map<Long,Set<Context>> in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator |
From |
To |
|
Change Attribute Type windows : Map<W,Tuple2<WindowBuffer<IN>,TriggerContext>> to windows : Map<W,Context> in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator |
From |
To |
|
Change Attribute Type processingTimeTimers : Map<Long,Set<TriggerContext>> to processingTimeTimers : Map<Long,Set<Context>> in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator |
From |
To |
|
Change Attribute Type trigger : Trigger<? super IN,? super W> to watermarkTimer : long in class org.apache.flink.streaming.runtime.operators.windowing.NonKeyedWindowOperator.Context |
From |
To |