...
Code Block | ||
---|---|---|
| ||
public enum Order { /** Indicates an ascending order. */ ASCENDING, /** Indicates a descending order. */ DESCENDING } |
Next, we will propose the operator implementation for the sortPartition API we will propose the operator implementation for the sortPartition
API.
The TaskMainThread will add records to the ExternalSorter, which is a multi-way merge sorter for sorting large amounts of data that cannot totally fit into memory. The ExternalSorter will sort the records according to the Order
and send the sorted records to output at the end of inputs. The following diagram illustrates the interaction between the TaskMainThread and the ExternalSorter:
...