|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testCleanupTimeOverflow() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testTimeEvictorEvictAfter() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testPointSessions() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public writeReducingEventTimeWindowsSnapshot() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorMigrationTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public writeApplyProcessingTimeWindowsSnapshot() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorMigrationTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testCleanupTimerWithEmptyFoldingStateForSessionWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testCleanupTimerWithEmptyListStateForTumblingWindows2() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testSideOutputDueToLatenessTumbling() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testSideOutputDueToLatenessSliding() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testRestoreApplyEventTimeWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorMigrationTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testSideOutputDueToLatenessSessionZeroLatenessPurgingTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testRestoreSessionWindowsWithCountTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorMigrationTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testCleanupTimerWithEmptyFoldingStateForTumblingWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testCountTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testProcessingTimeTumblingWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testTimeEvictorEvictBefore() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testCleanupTimerWithEmptyReduceStateForTumblingWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testDynamicEventTimeSessionWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testTumblingEventTimeWindowsReduce() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testRestoreReducingProcessingTimeWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorMigrationTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testCountTriggerWithApply() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testTumblingEventTimeWindowsApply() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testCountTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testNotSideOutputDueToLatenessSessionWithLateness() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testCountEvictorEvictAfter() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testRestoreApplyProcessingTimeWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorMigrationTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testCleanupTimerWithEmptyListStateForTumblingWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public writeSessionWindowsWithCountTriggerInMintConditionSnapshot() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorMigrationTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testSlidingEventTimeWindowsReduce() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testProcessingTimeSessionWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testTumblingWindowWithApply() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testProcessingTimeSlidingWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testNotSideOutputDueToLatenessSessionWithHugeLateness() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testDeltaEvictorEvictAfter() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testDropDueToLatenessSessionWithLatenessPurgingTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testDynamicProcessingTimeSessionWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testSessionWindowsWithContinuousEventTimeTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testSessionWindowsWithProcessFunction() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public writeSessionWindowsWithCountTriggerSnapshot() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorMigrationTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testLateness() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testSessionWindowsWithCountTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testReduceSessionWindowsWithProcessFunction() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testTimeEvictorNoTimestamp() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testCleanupTimerWithEmptyReduceStateForSessionWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testSideOutputDueToLatenessSessionZeroLateness() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testCleanupTimerWithEmptyListStateForSessionWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testNotSideOutputDueToLatenessSessionWithHugeLatenessPurgingTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testReduceSessionWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testDeltaEvictorEvictBefore() : void in class org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testSessionWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testSlidingEventTimeWindowsApply() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testContinuousWatermarkTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public writeApplyEventTimeWindowsSnapshot() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorMigrationTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testRestoreSessionWindowsWithCountTriggerInMintCondition() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorMigrationTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public writeReducingProcessingTimeWindowsSnapshot() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorMigrationTest |
From |
To |
|
Replace Variable With Attribute inputType : TypeInformation<Tuple2<String,Integer>> to STRING_INT_TUPLE : TypeInformation<Tuple2<String,Integer>> in method public testRestoreReducingEventTimeWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorMigrationTest |
From |
To |