|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testRestoreAggregatingAlignedProcessingTimeWindowsFromFlink11() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom11MigrationTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testProcessingTimeTumblingWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testTumblingWindowWithApply() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Rename Variable WINDOW_SLIDE : int to windowSlide : int in method public testCountTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Rename Variable SESSION_SIZE : int to sessionSize : int in method public testSessionWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Rename Variable SESSION_SIZE : int to sessionSize : int in method public testReduceSessionWindowsWithProcessFunction() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testRestoreReducingEventTimeWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom12MigrationTest |
From |
To |
|
Rename Variable SESSION_SIZE : int to sessionSize : int in method public testRestoreSessionWindowsWithCountTriggerInMintConditionFromFlink11() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom11MigrationTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testRestoreApplyEventTimeWindowsFromFlink11() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom11MigrationTest |
From |
To |
|
Rename Variable WINDOW_SLIDE : int to windowSlide : int in method public testCountTriggerWithApply() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Rename Variable SESSION_GAP : int to sessionGap : int in method public testWindowAssignment() : void in class org.apache.flink.streaming.runtime.operators.windowing.EventTimeSessionWindowsTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testRestoreAccumulatingAlignedProcessingTimeWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom12MigrationTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testTumblingEventTimeWindowsApply() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testCountTriggerWithApply() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testRestoreReducingProcessingTimeWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom12MigrationTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public writeApplyEventTimeWindowsSnapshot() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom12MigrationTest |
From |
To |
|
Rename Variable SESSION_GAP : int to sessionGap : int in method public testTimeUnits() : void in class org.apache.flink.streaming.runtime.operators.windowing.EventTimeSessionWindowsTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public writeReducingEventTimeWindowsSnapshot() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom12MigrationTest |
From |
To |
|
Rename Variable TRIGGER_COUNT : int to triggerCount : int in method public testTimeEvictorEvictBefore() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testTimeEvictorEvictBefore() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Rename Variable TRIGGER_COUNT : int to triggerCount : int in method public testDeltaEvictorEvictBefore() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testTumblingEventTimeWindowsReduce() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testRestoreReducingProcessingTimeWindowsFromFlink11() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom11MigrationTest |
From |
To |
|
Rename Variable SESSION_SIZE : int to sessionSize : int in method public testSessionWindowsWithProcessFunction() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Rename Variable SESSION_SIZE : int to sessionSize : int in method public testSessionWindowsWithCountTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public writeReducingProcessingTimeWindowsSnapshot() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom12MigrationTest |
From |
To |
|
Rename Variable EVICT_AFTER : boolean to evictAfter : boolean in method public testTimeEvictorEvictAfter() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testRestoreAggregatingAlignedProcessingTimeWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom12MigrationTest |
From |
To |
|
Rename Variable WINDOW_GAP : int to windowGap : int in method public testProcessingTimeSessionWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testRestoreAccumulatingAlignedProcessingTimeWindowsFromFlink11() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom11MigrationTest |
From |
To |
|
Rename Variable SESSION_SIZE : int to sessionSize : int in method public testRestoreSessionWindowsWithCountTriggerInMintCondition() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom12MigrationTest |
From |
To |
|
Rename Variable SESSION_SIZE : int to sessionSize : int in method public writeSessionWindowsWithCountTriggerSnapshot() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom12MigrationTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public writeApplyProcessingTimeWindowsSnapshot() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom12MigrationTest |
From |
To |
|
Rename Variable f0_0 : FieldAccessor<Tuple2<String,Integer>,String> to f0f0 : FieldAccessor<Tuple2<String,Integer>,String> in method public testFlatTuple() : void in class org.apache.flink.streaming.util.typeutils.FieldAccessorTest |
From |
To |
|
Rename Variable SESSION_SIZE : int to sessionSize : int in method public testRestoreSessionWindowsWithCountTriggerFromFlink11() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom11MigrationTest |
From |
To |
|
Rename Variable TRIGGER_COUNT : int to triggerCount : int in method public testCountEvictorEvictAfter() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testContinuousWatermarkTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testRestoreReducingEventTimeWindowsFromFlink11() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom11MigrationTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testRestoreApplyProcessingTimeWindowsFromFlink11() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom11MigrationTest |
From |
To |
|
Rename Variable TRIGGER_COUNT : int to triggerCount : int in method public testDeltaEvictorEvictAfter() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Rename Variable SESSION_SIZE : int to sessionSize : int in method public writeSessionWindowsWithCountTriggerInMintConditionSnapshot() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom12MigrationTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testRestoreApplyProcessingTimeWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom12MigrationTest |
From |
To |
|
Rename Variable TRIGGER_COUNT : int to triggerCount : int in method public testTimeEvictorNoTimestamp() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testRestoreApplyEventTimeWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom12MigrationTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testCountTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Rename Variable TRIGGER_COUNT : int to triggerCount : int in method public testTimeEvictorEvictAfter() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testCountTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Rename Variable SESSION_SIZE : int to sessionSize : int in method public testReduceSessionWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Rename Variable SESSION_SIZE : int to sessionSize : int in method public testSessionWindowsWithContinuousEventTimeTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Rename Variable EVICT_AFTER : boolean to evictAfter : boolean in method public testTimeEvictorNoTimestamp() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Rename Variable SESSION_SIZE : int to sessionSize : int in method public testRestoreSessionWindowsWithCountTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorFrom12MigrationTest |
From |
To |
|
Rename Variable WINDOW_SIZE : int to windowSize : int in method public testCleanupTimeOverflow() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |