|
Extract And Move Method public setProcessingTime(time long) : void extracted from public setProcessingTime(timestamp long) : void in class org.apache.flink.streaming.util.WindowingTestHarness & moved to class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Extract And Move Method public setProcessingTime(time long) : void extracted from public testNonRollingStringWriter() : void in class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTest & moved to class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Extract And Move Method public setProcessingTime(time long) : void extracted from public testProcessingTimeTumblingWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest & moved to class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Extract And Move Method public setProcessingTime(time long) : void extracted from public testNonRollingAvroKeyValueWithCompressionWriter() : void in class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTest & moved to class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Extract And Move Method public setProcessingTime(time long) : void extracted from public testCustomBucketingInactiveBucketCleanup() : void in class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTest & moved to class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Extract And Move Method public setProcessingTime(time long) : void extracted from public testTimestampsAndPeriodicWatermarksOperator() : void in class org.apache.flink.streaming.runtime.operators.TimestampsAndPeriodicWatermarksOperatorTest & moved to class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Extract And Move Method public setProcessingTime(time long) : void extracted from public testCheckpointWithoutNotify() : void in class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTest & moved to class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Extract And Move Method public setProcessingTime(time long) : void extracted from public checkpointRestoreWithPendingWindowSliding() : void in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest & moved to class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Extract And Move Method public setProcessingTime(time long) : void extracted from public checkpointRestoreWithPendingWindowTumbling() : void in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest & moved to class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Extract And Move Method public setProcessingTime(time long) : void extracted from public testFileReadingOperatorWithIngestionTime() : void in class org.apache.flink.hdfstests.ContinuousFileMonitoringTest & moved to class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Extract And Move Method public setProcessingTime(time long) : void extracted from public checkpointRestoreWithPendingWindowTumbling() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest & moved to class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Extract And Move Method public setProcessingTime(time long) : void extracted from public testKeyValueStateInWindowFunction() : void in class org.apache.flink.streaming.runtime.operators.windowing.AccumulatingAlignedProcessingTimeWindowOperatorTest & moved to class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Extract And Move Method public setProcessingTime(time long) : void extracted from public testCustomBucketing() : void in class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTest & moved to class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Extract And Move Method public setProcessingTime(time long) : void extracted from public testProcessingTimeSlidingWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest & moved to class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Extract And Move Method public setProcessingTime(time long) : void extracted from public testDateTimeRollingStringWriter() : void in class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTest & moved to class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Extract And Move Method public setProcessingTime(time long) : void extracted from public checkpointRestoreWithPendingWindowSliding() : void in class org.apache.flink.streaming.runtime.operators.windowing.AggregatingAlignedProcessingTimeWindowOperatorTest & moved to class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Extract And Move Method public setProcessingTime(time long) : void extracted from public testProcessingTimeSessionWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest & moved to class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Extract And Move Method public setProcessingTime(time long) : void extracted from public testNonRollingSequenceFileWithoutCompressionWriter() : void in class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTest & moved to class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |