@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,
CheckpointingMode checkpointMode,
IOManager ioManager,
InputGate inputGate,
Configuration taskManagerConfig,
String taskName) |
static CheckpointedInputGate[] |
createCheckpointedInputGatePair(AbstractInvokable toNotifyOnCheckpoint,
CheckpointingMode checkpointMode,
IOManager ioManager,
InputGate inputGate1,
InputGate inputGate2,
Configuration taskManagerConfig,
TaskIOMetricGroup taskIOMetricGroup,
String taskName) |
public static CheckpointedInputGate createCheckpointedInputGate(AbstractInvokable toNotifyOnCheckpoint, CheckpointingMode checkpointMode, IOManager ioManager, InputGate inputGate, Configuration taskManagerConfig, String taskName) throws IOException
IOException
public static CheckpointedInputGate[] createCheckpointedInputGatePair(AbstractInvokable toNotifyOnCheckpoint, CheckpointingMode checkpointMode, IOManager ioManager, InputGate inputGate1, InputGate inputGate2, Configuration taskManagerConfig, TaskIOMetricGroup taskIOMetricGroup, String taskName) throws IOException
CheckpointedInputGate
created for two corresponding
InputGate
s supplied as parameters.IOException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.