|
Change Parameter Type task : TwoInputStreamTask<IN1,IN2,OUT> to taskFactory : BiFunction<Environment,TaskStateSnapshot,? extends TwoInputStreamTask<IN1,IN2,OUT>> in method public TwoInputStreamTaskTestHarness(taskFactory BiFunction<Environment,TaskStateSnapshot,? extends TwoInputStreamTask<IN1,IN2,OUT>>, numInputGates int, numInputChannelsPerGate int, inputGateAssignment int[], inputType1 TypeInformation<IN1>, inputType2 TypeInformation<IN2>, outputType TypeInformation<OUT>) in class org.apache.flink.streaming.runtime.tasks.TwoInputStreamTaskTestHarness |
From |
To |
|
Change Parameter Type checkpointedTask : StatefulTask to checkpointedTask : StreamTask<?,?> in method public StreamInputProcessor(inputGates InputGate[], inputSerializer TypeSerializer<IN>, checkpointedTask StreamTask<?,?>, checkpointMode CheckpointingMode, lock Object, ioManager IOManager, taskManagerConfig Configuration, streamStatusMaintainer StreamStatusMaintainer, streamOperator OneInputStreamOperator<IN,?>) in class org.apache.flink.streaming.runtime.io.StreamInputProcessor |
From |
To |
|
Change Parameter Type task : TwoInputStreamTask<IN1,IN2,OUT> to taskFactory : BiFunction<Environment,TaskStateSnapshot,? extends TwoInputStreamTask<IN1,IN2,OUT>> in method public TwoInputStreamTaskTestHarness(taskFactory BiFunction<Environment,TaskStateSnapshot,? extends TwoInputStreamTask<IN1,IN2,OUT>>, inputType1 TypeInformation<IN1>, inputType2 TypeInformation<IN2>, outputType TypeInformation<OUT>) in class org.apache.flink.streaming.runtime.tasks.TwoInputStreamTaskTestHarness |
From |
To |
|
Change Parameter Type task : OneInputStreamTask<IN,OUT> to taskFactory : BiFunction<Environment,TaskStateSnapshot,? extends OneInputStreamTask<IN,OUT>> in method public OneInputStreamTaskTestHarness(taskFactory BiFunction<Environment,TaskStateSnapshot,? extends OneInputStreamTask<IN,OUT>>, inputType TypeInformation<IN>, outputType TypeInformation<OUT>) in class org.apache.flink.streaming.runtime.tasks.OneInputStreamTaskTestHarness |
From |
To |
|
Change Parameter Type task : OneInputStreamTask<IN,OUT> to taskFactory : BiFunction<Environment,TaskStateSnapshot,? extends OneInputStreamTask<IN,OUT>> in method public OneInputStreamTaskTestHarness(taskFactory BiFunction<Environment,TaskStateSnapshot,? extends OneInputStreamTask<IN,OUT>>, numInputGates int, numInputChannelsPerGate int, inputType TypeInformation<IN>, outputType TypeInformation<OUT>) in class org.apache.flink.streaming.runtime.tasks.OneInputStreamTaskTestHarness |
From |
To |
|
Change Parameter Type task : AbstractInvokable to taskFactory : BiFunction<Environment,TaskStateSnapshot,? extends StreamTask<OUT,?>> in method public StreamTaskTestHarness(taskFactory BiFunction<Environment,TaskStateSnapshot,? extends StreamTask<OUT,?>>, outputType TypeInformation<OUT>) in class org.apache.flink.streaming.runtime.tasks.StreamTaskTestHarness |
From |
To |
|
Change Parameter Type task : StatefulTask to task : AbstractInvokable in method public registerCheckpointEventHandler(task AbstractInvokable) : void in class org.apache.flink.streaming.runtime.io.CheckpointBarrierHandler |
From |
To |
|
Change Parameter Type toNotifyOnCheckpoint : StatefulTask to toNotifyOnCheckpoint : AbstractInvokable in method public registerCheckpointEventHandler(toNotifyOnCheckpoint AbstractInvokable) : void in class org.apache.flink.streaming.runtime.io.BarrierTracker |
From |
To |
|
Change Parameter Type toNotifyOnCheckpoint : StatefulTask to toNotifyOnCheckpoint : AbstractInvokable in method public registerCheckpointEventHandler(toNotifyOnCheckpoint AbstractInvokable) : void in class org.apache.flink.streaming.runtime.io.BarrierBuffer |
From |
To |
|
Change Parameter Type checkpointedTask : StatefulTask to checkpointedTask : TwoInputStreamTask<IN1,IN2,?> in method public StreamTwoInputProcessor(inputGates1 Collection<InputGate>, inputGates2 Collection<InputGate>, inputSerializer1 TypeSerializer<IN1>, inputSerializer2 TypeSerializer<IN2>, checkpointedTask TwoInputStreamTask<IN1,IN2,?>, checkpointMode CheckpointingMode, lock Object, ioManager IOManager, taskManagerConfig Configuration, streamStatusMaintainer StreamStatusMaintainer, streamOperator TwoInputStreamOperator<IN1,IN2,?>) in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor |
From |
To |
|
Change Variable Type toNotify : StatefulTask to toNotify : AbstractInvokable in method public testAlignmentLimitWithQueuedAlignments() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferAlignmentLimitTest |
From |
To |
|
Change Variable Type toNotify : StatefulTask to toNotify : AbstractInvokable in method public testAbortWhileHavingQueuedBarriers() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTest |
From |
To |
|
Change Variable Type toNotify : StatefulTask to toNotify : AbstractInvokable in method public testBreakCheckpointAtAlignmentLimit() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferAlignmentLimitTest |
From |
To |
|
Change Variable Type toNotify : StatefulTask to toNotify : AbstractInvokable in method public testMultiChannelAbortCheckpoint() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTest |
From |
To |
|
Change Variable Type toNotify : StatefulTask to toNotify : AbstractInvokable in method public testSingleChannelAbortCheckpoint() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTest |
From |
To |
|
Change Variable Type toNotify : StatefulTask to toNotify : AbstractInvokable in method public testAbortViaQueuedBarriers() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTest |
From |
To |
|
Change Variable Type toNotify : StatefulTask to toNotify : AbstractInvokable in method public testMultiChannelSkippingCheckpoints() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTest |
From |
To |
|
Change Variable Type toNotify : StatefulTask to toNotify : AbstractInvokable in method public testIgnoreCancelBarrierIfCheckpointSubsumed() : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTest |
From |
To |
|
Change Variable Type statefulTask : StatefulTask to statefulTask : AbstractInvokable in method public testInterleavedCancellationBarriers() : void in class org.apache.flink.streaming.runtime.io.BarrierTrackerTest |
From |
To |
|
Rename Parameter task : TwoInputStreamTask<IN1,IN2,OUT> to taskFactory : BiFunction<Environment,TaskStateSnapshot,? extends TwoInputStreamTask<IN1,IN2,OUT>> in method public TwoInputStreamTaskTestHarness(taskFactory BiFunction<Environment,TaskStateSnapshot,? extends TwoInputStreamTask<IN1,IN2,OUT>>, numInputGates int, numInputChannelsPerGate int, inputGateAssignment int[], inputType1 TypeInformation<IN1>, inputType2 TypeInformation<IN2>, outputType TypeInformation<OUT>) in class org.apache.flink.streaming.runtime.tasks.TwoInputStreamTaskTestHarness |
From |
To |
|
Rename Parameter task : TwoInputStreamTask<IN1,IN2,OUT> to taskFactory : BiFunction<Environment,TaskStateSnapshot,? extends TwoInputStreamTask<IN1,IN2,OUT>> in method public TwoInputStreamTaskTestHarness(taskFactory BiFunction<Environment,TaskStateSnapshot,? extends TwoInputStreamTask<IN1,IN2,OUT>>, inputType1 TypeInformation<IN1>, inputType2 TypeInformation<IN2>, outputType TypeInformation<OUT>) in class org.apache.flink.streaming.runtime.tasks.TwoInputStreamTaskTestHarness |
From |
To |
|
Rename Parameter task : OneInputStreamTask<IN,OUT> to taskFactory : BiFunction<Environment,TaskStateSnapshot,? extends OneInputStreamTask<IN,OUT>> in method public OneInputStreamTaskTestHarness(taskFactory BiFunction<Environment,TaskStateSnapshot,? extends OneInputStreamTask<IN,OUT>>, inputType TypeInformation<IN>, outputType TypeInformation<OUT>) in class org.apache.flink.streaming.runtime.tasks.OneInputStreamTaskTestHarness |
From |
To |
|
Rename Parameter task : AbstractInvokable to taskFactory : BiFunction<Environment,TaskStateSnapshot,? extends StreamTask<OUT,?>> in method public StreamTaskTestHarness(taskFactory BiFunction<Environment,TaskStateSnapshot,? extends StreamTask<OUT,?>>, outputType TypeInformation<OUT>) in class org.apache.flink.streaming.runtime.tasks.StreamTaskTestHarness |
From |
To |
|
Rename Parameter task : OneInputStreamTask<IN,OUT> to taskFactory : BiFunction<Environment,TaskStateSnapshot,? extends OneInputStreamTask<IN,OUT>> in method public OneInputStreamTaskTestHarness(taskFactory BiFunction<Environment,TaskStateSnapshot,? extends OneInputStreamTask<IN,OUT>>, numInputGates int, numInputChannelsPerGate int, inputType TypeInformation<IN>, outputType TypeInformation<OUT>) in class org.apache.flink.streaming.runtime.tasks.OneInputStreamTaskTestHarness |
From |
To |