org.apache.flink.table.runtime.operators.multipleinput.input

Class InputSelectionHandler

java.lang.Object

org.apache.flink.table.runtime.operators.multipleinput.input.InputSelectionHandler

public class InputSelectionHandler
extends Object

This handler is mainly used for selecting the next available input index according to read priority in MultipleInputStreamOperatorBase.

Input read order: the input with high priority (the value of read order is lower) will be read first, the inputs with same priorities will be read fairly.

Constructor Summary

Constructors

Constructor and Description
InputSelectionHandler(List<InputSelectionSpec> inputSelectionSpecs)

Method Summary

Modifier and Type	Method and Description
void	endInput(int inputId)
static InputSelectionHandler	fromInputSpecs(List<InputSpec> inputSpecs)
InputSelection	getInputSelection()

Methods inherited from class java.lang.Object

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

Constructor Detail

InputSelectionHandler

public InputSelectionHandler(List<InputSelectionSpec> inputSelectionSpecs)

Method Detail

fromInputSpecs

public static InputSelectionHandler fromInputSpecs(List<InputSpec> inputSpecs)

getInputSelection

public InputSelection getInputSelection()

endInput

public void endInput(int inputId)