Package org.apache.beam.sdk.extensions.sorter

Utility for performing local sort of potentially large sets of values.

See: Description

Class Summary

Class	Description
BufferedExternalSorter	Sorter that will use in memory sorting until the values can't fit into memory and will then fall back to external sorting.
BufferedExternalSorter.Options	Contains configuration for the sorter.
SortValues<PrimaryKeyT,SecondaryKeyT,ValueT>	SortValues<PrimaryKeyT, SecondaryKeyT, ValueT> takes a PCollection<KV<PrimaryKeyT, Iterable<KV<SecondaryKeyT, ValueT>>>> with elements consisting of a primary key and iterables over <secondary key, value> pairs, and returns a PCollection<KV<PrimaryKeyT, Iterable<KV<SecondaryKeyT, ValueT>>> of the same elements but with values sorted by a secondary key.

Package org.apache.beam.sdk.extensions.sorter Description

Utility for performing local sort of potentially large sets of values. Will sort in memory and spill to disk for external sorting if necessary.