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.
ExternalSorter	Does an external sort of the provided values.
ExternalSorter.Options	ExternalSorter.Options contains configuration of 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.

Enum Summary

Enum	Description
ExternalSorter.Options.SorterType	Sorter type.

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.