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 CheckpointBarrierHandler based on checkpoint mode for StreamInputProcessor and StreamTwoInputProcessor.

Constructor Summary

Constructors

Constructor and Description
InputProcessorUtil()

Method Summary

Modifier and Type	Method and Description
static CheckpointBarrierHandler	createCheckpointBarrierHandler(StreamTask<?,?> checkpointedTask, CheckpointingMode checkpointMode, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, org.apache.flink.runtime.io.network.partition.consumer.InputGate inputGate, org.apache.flink.configuration.Configuration taskManagerConfig)

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

createCheckpointBarrierHandler

public static CheckpointBarrierHandler createCheckpointBarrierHandler(StreamTask<?,?> checkpointedTask,
                                                                      CheckpointingMode checkpointMode,
                                                                      org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager,
                                                                      org.apache.flink.runtime.io.network.partition.consumer.InputGate inputGate,
                                                                      org.apache.flink.configuration.Configuration taskManagerConfig)
                                                               throws IOException

Throws:

IOException