@Internal public class InputProcessorUtil extends Object
CheckpointedInputGate
based on checkpoint mode for StreamOneInputProcessor
and StreamTwoInputProcessor
.Constructor and Description |
---|
InputProcessorUtil() |
Modifier and Type | Method and Description |
---|---|
static CheckpointedInputGate |
createCheckpointedInputGate(AbstractInvokable toNotifyOnCheckpoint,
StreamConfig config,
SubtaskCheckpointCoordinator checkpointCoordinator,
IndexedInputGate[] inputGates,
TaskIOMetricGroup taskIOMetricGroup,
String taskName) |
static CheckpointedInputGate[] |
createCheckpointedMultipleInputGate(AbstractInvokable toNotifyOnCheckpoint,
StreamConfig config,
SubtaskCheckpointCoordinator checkpointCoordinator,
TaskIOMetricGroup taskIOMetricGroup,
String taskName,
List<IndexedInputGate>... inputGates) |
public static CheckpointedInputGate createCheckpointedInputGate(AbstractInvokable toNotifyOnCheckpoint, StreamConfig config, SubtaskCheckpointCoordinator checkpointCoordinator, IndexedInputGate[] inputGates, TaskIOMetricGroup taskIOMetricGroup, String taskName)
public static CheckpointedInputGate[] createCheckpointedMultipleInputGate(AbstractInvokable toNotifyOnCheckpoint, StreamConfig config, SubtaskCheckpointCoordinator checkpointCoordinator, TaskIOMetricGroup taskIOMetricGroup, String taskName, List<IndexedInputGate>... inputGates)
CheckpointedInputGate
created for two corresponding InputGate
s supplied as parameters.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.