static CheckpointBarrierHandler |
InputProcessorUtil.createCheckpointBarrierHandler(AbstractInvokable toNotifyOnCheckpoint,
StreamConfig config,
SubtaskCheckpointCoordinator checkpointCoordinator,
String taskName,
List<IndexedInputGate>[] inputGates,
List<StreamTaskSourceInput<?>> sourceInputs,
MailboxExecutor mailboxExecutor,
TimerService timerService) |
static CheckpointedInputGate |
InputProcessorUtil.createCheckpointedInputGate(AbstractInvokable toNotifyOnCheckpoint,
StreamConfig config,
SubtaskCheckpointCoordinator checkpointCoordinator,
IndexedInputGate[] inputGates,
TaskIOMetricGroup taskIOMetricGroup,
String taskName,
MailboxExecutor mailboxExecutor,
TimerService timerService) |
static CheckpointedInputGate[] |
InputProcessorUtil.createCheckpointedMultipleInputGate(AbstractInvokable toNotifyOnCheckpoint,
StreamConfig config,
SubtaskCheckpointCoordinator checkpointCoordinator,
TaskIOMetricGroup taskIOMetricGroup,
String taskName,
MailboxExecutor mailboxExecutor,
List<IndexedInputGate>[] inputGates,
List<StreamTaskSourceInput<?>> sourceInputs,
TimerService timerService) |
static CheckpointedInputGate[] |
InputProcessorUtil.createCheckpointedMultipleInputGate(MailboxExecutor mailboxExecutor,
List<IndexedInputGate>[] inputGates,
TaskIOMetricGroup taskIOMetricGroup,
CheckpointBarrierHandler barrierHandler,
StreamConfig config) |