Package org.apache.flink.streaming.runtime.io

Class MultipleInputSelectionHandler

java.lang.Object

org.apache.flink.streaming.runtime.io.MultipleInputSelectionHandler

@Internal
public class MultipleInputSelectionHandler
extends Object

This handler is mainly used for selecting the next available input index in StreamMultipleInputProcessor.

Field Summary

Fields

Modifier and Type	Field	Description
static int	MAX_SUPPORTED_INPUT_COUNT

Constructor Summary

Constructors

Constructor	Description
MultipleInputSelectionHandler(InputSelectable inputSelectable, int inputCount)

Method Summary

Modifier and Type	Method	Description
boolean	areAllDataInputsFinished()
boolean	areAllInputsFinished()
static void	checkSupportedInputCount(int inputCount)
boolean	isInputFinished(int inputIndex)
DataInputStatus	updateStatusAndSelection(DataInputStatus inputStatus, int inputIndex)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MAX_SUPPORTED_INPUT_COUNT

public static final int MAX_SUPPORTED_INPUT_COUNT

See Also:

Constant Field Values

Constructor Detail

MultipleInputSelectionHandler

public MultipleInputSelectionHandler(@Nullable
                                     InputSelectable inputSelectable,
                                     int inputCount)

Method Detail

checkSupportedInputCount

public static void checkSupportedInputCount(int inputCount)

updateStatusAndSelection

public DataInputStatus updateStatusAndSelection(DataInputStatus inputStatus,
                                                int inputIndex)
                                         throws IOException

Throws:

IOException

isInputFinished

public boolean isInputFinished(int inputIndex)

areAllInputsFinished

public boolean areAllInputsFinished()

areAllDataInputsFinished

public boolean areAllDataInputsFinished()