org.apache.flink.streaming.runtime.io.checkpointing

Class InputProcessorUtil

java.lang.Object

org.apache.flink.streaming.runtime.io.checkpointing.InputProcessorUtil

@Internal
public class InputProcessorUtil
extends Object

Utility for creating CheckpointedInputGate based on checkpoint mode for StreamOneInputProcessor.

Constructor Summary

Constructors

Constructor and Description
InputProcessorUtil()

Method Summary

Modifier and Type	Method and Description
static CheckpointBarrierHandler	createCheckpointBarrierHandler(CheckpointableTask toNotifyOnCheckpoint, StreamConfig config, SubtaskCheckpointCoordinator checkpointCoordinator, String taskName, List<IndexedInputGate>[] inputGates, List<StreamTaskSourceInput<?>> sourceInputs, MailboxExecutor mailboxExecutor, TimerService timerService)
static CheckpointedInputGate[]	createCheckpointedMultipleInputGate(MailboxExecutor mailboxExecutor, List<IndexedInputGate>[] inputGates, TaskIOMetricGroup taskIOMetricGroup, CheckpointBarrierHandler barrierHandler, StreamConfig config)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InputProcessorUtil

public InputProcessorUtil()

Method Detail

createCheckpointedMultipleInputGate

public static CheckpointedInputGate[] createCheckpointedMultipleInputGate(MailboxExecutor mailboxExecutor,
                                                                          List<IndexedInputGate>[] inputGates,
                                                                          TaskIOMetricGroup taskIOMetricGroup,
                                                                          CheckpointBarrierHandler barrierHandler,
                                                                          StreamConfig config)

createCheckpointBarrierHandler

public static CheckpointBarrierHandler createCheckpointBarrierHandler(CheckpointableTask toNotifyOnCheckpoint,
                                                                      StreamConfig config,
                                                                      SubtaskCheckpointCoordinator checkpointCoordinator,
                                                                      String taskName,
                                                                      List<IndexedInputGate>[] inputGates,
                                                                      List<StreamTaskSourceInput<?>> sourceInputs,
                                                                      MailboxExecutor mailboxExecutor,
                                                                      TimerService timerService)