|
Change Parameter Type checkpointHandler : EventListener<CheckpointBarrier> to task : StatefulTask in method public registerCheckpointEventHandler(task StatefulTask) : void in class org.apache.flink.streaming.runtime.io.CheckpointBarrierHandler |
From |
To |
|
Change Parameter Type checkpointHandler : EventListener<CheckpointBarrier> to toNotifyOnCheckpoint : StatefulTask in method public registerCheckpointEventHandler(toNotifyOnCheckpoint StatefulTask) : void in class org.apache.flink.streaming.runtime.io.BarrierBuffer |
From |
To |
|
Change Parameter Type checkpointListener : EventListener<CheckpointBarrier> to checkpointedTask : StatefulTask in method public StreamInputProcessor(inputGates InputGate[], inputSerializer TypeSerializer<IN>, checkpointedTask StatefulTask, checkpointMode CheckpointingMode, ioManager IOManager, enableWatermarkMultiplexing boolean) in class org.apache.flink.streaming.runtime.io.StreamInputProcessor |
From |
To |
|
Change Parameter Type checkpointHandler : EventListener<CheckpointBarrier> to toNotifyOnCheckpoint : StatefulTask in method public registerCheckpointEventHandler(toNotifyOnCheckpoint StatefulTask) : void in class org.apache.flink.streaming.runtime.io.BarrierTracker |
From |
To |
|
Change Parameter Type checkpointListener : EventListener<CheckpointBarrier> to checkpointedTask : StatefulTask in method public StreamTwoInputProcessor(inputGates1 Collection<InputGate>, inputGates2 Collection<InputGate>, inputSerializer1 TypeSerializer<IN1>, inputSerializer2 TypeSerializer<IN2>, checkpointedTask StatefulTask, checkpointMode CheckpointingMode, ioManager IOManager, enableWatermarkMultiplexing boolean) in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor |
From |
To |
|
Rename Parameter checkpointHandler : EventListener<CheckpointBarrier> to task : StatefulTask in method public registerCheckpointEventHandler(task StatefulTask) : void in class org.apache.flink.streaming.runtime.io.CheckpointBarrierHandler |
From |
To |
|
Rename Parameter checkpointHandler : EventListener<CheckpointBarrier> to toNotifyOnCheckpoint : StatefulTask in method public registerCheckpointEventHandler(toNotifyOnCheckpoint StatefulTask) : void in class org.apache.flink.streaming.runtime.io.BarrierBuffer |
From |
To |
|
Rename Parameter checkpointListener : EventListener<CheckpointBarrier> to checkpointedTask : StatefulTask in method public StreamInputProcessor(inputGates InputGate[], inputSerializer TypeSerializer<IN>, checkpointedTask StatefulTask, checkpointMode CheckpointingMode, ioManager IOManager, enableWatermarkMultiplexing boolean) in class org.apache.flink.streaming.runtime.io.StreamInputProcessor |
From |
To |
|
Rename Parameter checkpointListener : EventListener<CheckpointBarrier> to checkpointedTask : StatefulTask in method public StreamTwoInputProcessor(inputGates1 Collection<InputGate>, inputGates2 Collection<InputGate>, inputSerializer1 TypeSerializer<IN1>, inputSerializer2 TypeSerializer<IN2>, checkpointedTask StatefulTask, checkpointMode CheckpointingMode, ioManager IOManager, enableWatermarkMultiplexing boolean) in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor |
From |
To |
|
Rename Parameter checkpointHandler : EventListener<CheckpointBarrier> to toNotifyOnCheckpoint : StatefulTask in method public registerCheckpointEventHandler(toNotifyOnCheckpoint StatefulTask) : void in class org.apache.flink.streaming.runtime.io.BarrierTracker |
From |
To |