|
Change Parameter Type testTimeProvider : TimeServiceProvider to testTimeProvider : TestTimeServiceProvider in method public KeyedOneInputStreamOperatorTestHarness(operator OneInputStreamOperator<IN,OUT>, executionConfig ExecutionConfig, testTimeProvider TestTimeServiceProvider, keySelector KeySelector<IN,K>, keyType TypeInformation<K>) in class org.apache.flink.streaming.util.KeyedOneInputStreamOperatorTestHarness |
From |
To |
|
Change Parameter Type timeProvider : TimeServiceProvider to timeProvider : TestTimeServiceProvider in method private setupSourceOperator(operator StreamSource<T,?>, timeChar TimeCharacteristic, watermarkInterval long, timeProvider TestTimeServiceProvider) : void in class org.apache.flink.streaming.runtime.operators.StreamSourceOperatorTest |
From |
To |
|
Change Parameter Type clock : TimeServiceProvider to clock : TestTimeServiceProvider in method private createTestSink(sink BucketingSink<T>, clock TestTimeServiceProvider) : OneInputStreamOperatorTestHarness<T,Object> in class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTest |
From |
To |
|
Change Parameter Type testTimeProvider : TimeServiceProvider to testTimeProvider : TestTimeServiceProvider in method public OneInputStreamOperatorTestHarness(operator OneInputStreamOperator<IN,OUT>, executionConfig ExecutionConfig, testTimeProvider TestTimeServiceProvider) in class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Change Parameter Type collector : TimestampedCollector<OT> to readerContext : SourceFunction.SourceContext<OT> in method private SplitReader(format FileInputFormat<OT>, serializer TypeSerializer<OT>, readerContext SourceFunction.SourceContext<OT>, checkpointLock Object, restoredState Tuple3<List<FileInputSplit>,FileInputSplit,S>) in class org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator.SplitReader |
From |
To |
|
Change Parameter Type clock : TimeServiceProvider to clock : TestTimeServiceProvider in method private createTestSink(dataDir File, clock TestTimeServiceProvider) : OneInputStreamOperatorTestHarness<String,Object> in class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTest |
From |
To |
|
Rename Parameter lockingObject : Object to checkpointLock : Object in method private NonTimestampContext(checkpointLock Object, output Output<StreamRecord<T>>) in class org.apache.flink.streaming.api.operators.StreamSourceContexts.NonTimestampContext |
From |
To |
|
Rename Parameter lockingObject : Object to checkpointLock : Object in method private ManualWatermarkContext(checkpointLock Object, output Output<StreamRecord<T>>) in class org.apache.flink.streaming.api.operators.StreamSourceContexts.ManualWatermarkContext |
From |
To |
|
Rename Parameter lock : Object to checkpointLock : Object in method private WatermarkEmittingTask(timeService TimeServiceProvider, checkpointLock Object, output Output<StreamRecord<T>>) in class org.apache.flink.streaming.api.operators.StreamSourceContexts.AutomaticWatermarkContext.WatermarkEmittingTask |
From |
To |
|
Rename Parameter lockingObjectParam : Object to checkpointLock : Object in method private AutomaticWatermarkContext(timeService TimeServiceProvider, checkpointLock Object, output Output<StreamRecord<T>>, watermarkInterval long) in class org.apache.flink.streaming.api.operators.StreamSourceContexts.AutomaticWatermarkContext |
From |
To |
|
Rename Parameter outputParam : Output<StreamRecord<T>> to output : Output<StreamRecord<T>> in method private AutomaticWatermarkContext(timeService TimeServiceProvider, checkpointLock Object, output Output<StreamRecord<T>>, watermarkInterval long) in class org.apache.flink.streaming.api.operators.StreamSourceContexts.AutomaticWatermarkContext |
From |
To |
|
Rename Parameter collector : TimestampedCollector<OT> to readerContext : SourceFunction.SourceContext<OT> in method private SplitReader(format FileInputFormat<OT>, serializer TypeSerializer<OT>, readerContext SourceFunction.SourceContext<OT>, checkpointLock Object, restoredState Tuple3<List<FileInputSplit>,FileInputSplit,S>) in class org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator.SplitReader |
From |
To |