public static class MultiInputSortingDataInput.SelectableSortingInputs extends Object
inputs
with a InputSelectable
that should be used to choose which input to consume next from.Constructor and Description |
---|
SelectableSortingInputs(StreamTaskInput<?>[] sortedInputs,
StreamTaskInput<?>[] passThroughInputs,
InputSelectable inputSelectable) |
Modifier and Type | Method and Description |
---|---|
InputSelectable |
getInputSelectable() |
StreamTaskInput<?>[] |
getPassThroughInputs() |
StreamTaskInput<?>[] |
getSortedInputs() |
public SelectableSortingInputs(StreamTaskInput<?>[] sortedInputs, StreamTaskInput<?>[] passThroughInputs, InputSelectable inputSelectable)
public InputSelectable getInputSelectable()
public StreamTaskInput<?>[] getSortedInputs()
public StreamTaskInput<?>[] getPassThroughInputs()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.