public class InputSelectionHandler extends Object
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 and Description |
---|
InputSelectionHandler(List<InputSelectionSpec> inputSelectionSpecs) |
Modifier and Type | Method and Description |
---|---|
void |
endInput(int inputId) |
static InputSelectionHandler |
fromInputSpecs(List<InputSpec> inputSpecs) |
InputSelection |
getInputSelection() |
public InputSelectionHandler(List<InputSelectionSpec> inputSelectionSpecs)
public static InputSelectionHandler fromInputSpecs(List<InputSpec> inputSpecs)
public InputSelection getInputSelection()
public void endInput(int inputId)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.