@Internal public class InputProcessorUtil extends Object
CheckpointBarrierHandler
based on checkpoint mode
for StreamInputProcessor
and StreamTwoInputProcessor
.Constructor and Description |
---|
InputProcessorUtil() |
Modifier and Type | Method and Description |
---|---|
static CheckpointBarrierHandler |
createCheckpointBarrierHandler(StreamTask<?,?> checkpointedTask,
CheckpointingMode checkpointMode,
IOManager ioManager,
InputGate inputGate,
Configuration taskManagerConfig) |
public static CheckpointBarrierHandler createCheckpointBarrierHandler(StreamTask<?,?> checkpointedTask, CheckpointingMode checkpointMode, IOManager ioManager, InputGate inputGate, Configuration taskManagerConfig) throws IOException
IOException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.