Class | Description |
---|---|
MultiInputSortingDataInput<IN,K> |
An input that wraps an underlying input and sorts the incoming records.
|
MultiInputSortingDataInput.SelectableSortingInputs |
A wrapper that combines sorting
inputs with a InputSelectable
that should be used to choose which input to consume next from. |
SortingDataInput<T,K> |
A
StreamTaskInput which sorts in the incoming records from a chained input. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.