org.apache.flink.streaming.runtime.io

Class InputProcessorUtil

java.lang.Object

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

@Internal
public class InputProcessorUtil
extends Object

Utility for creating CheckpointedInputGate based on checkpoint mode for StreamOneInputProcessor and StreamTwoInputProcessor.

Constructor Summary

Constructors

Constructor and Description
InputProcessorUtil()

Method Summary

Modifier and Type	Method and Description
static CheckpointBarrierHandler	createCheckpointBarrierHandler(AbstractInvokable toNotifyOnCheckpoint, StreamConfig config, SubtaskCheckpointCoordinator checkpointCoordinator, String taskName, List<IndexedInputGate>[] inputGates, List<StreamTaskSourceInput<?>> sourceInputs)
static CheckpointedInputGate	createCheckpointedInputGate(AbstractInvokable toNotifyOnCheckpoint, StreamConfig config, SubtaskCheckpointCoordinator checkpointCoordinator, IndexedInputGate[] inputGates, TaskIOMetricGroup taskIOMetricGroup, String taskName, MailboxExecutor mailboxExecutor)
static CheckpointedInputGate[]	createCheckpointedMultipleInputGate(AbstractInvokable toNotifyOnCheckpoint, StreamConfig config, SubtaskCheckpointCoordinator checkpointCoordinator, TaskIOMetricGroup taskIOMetricGroup, String taskName, MailboxExecutor mailboxExecutor, List<IndexedInputGate>[] inputGates, List<StreamTaskSourceInput<?>> sourceInputs)
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

createCheckpointedInputGate

public static CheckpointedInputGate createCheckpointedInputGate(AbstractInvokable toNotifyOnCheckpoint,
                                                                StreamConfig config,
                                                                SubtaskCheckpointCoordinator checkpointCoordinator,
                                                                IndexedInputGate[] inputGates,
                                                                TaskIOMetricGroup taskIOMetricGroup,
                                                                String taskName,
                                                                MailboxExecutor mailboxExecutor)

createCheckpointedMultipleInputGate

public static CheckpointedInputGate[] createCheckpointedMultipleInputGate(AbstractInvokable toNotifyOnCheckpoint,
                                                                          StreamConfig config,
                                                                          SubtaskCheckpointCoordinator checkpointCoordinator,
                                                                          TaskIOMetricGroup taskIOMetricGroup,
                                                                          String taskName,
                                                                          MailboxExecutor mailboxExecutor,
                                                                          List<IndexedInputGate>[] inputGates,
                                                                          List<StreamTaskSourceInput<?>> sourceInputs)

Returns:

an array of CheckpointedInputGate created for corresponding InputGates supplied as parameters.

createCheckpointedMultipleInputGate

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

createCheckpointBarrierHandler

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