Package org.apache.flink.table.runtime.operators.sort

Class Summary

Class	Description
AbstractBinaryExternalMerger<Entry>	Spilled files Merger of BinaryExternalSorter.
BinaryExternalMerger	Record merger for sort of BinaryRow.
BinaryExternalSorter	The BinaryExternalSorter is a full fledged sorter for binary format.
BinaryIndexedSortable	abstract sortable, provide basic compare and swap.
BinaryInMemorySortBuffer	In memory sort buffer for binary row.
BinaryKVExternalMerger	Key-Value style record merger for sort.
BinaryKVInMemorySortBuffer	In memory KV sortable buffer for binary row, it already has records in memory.
BinaryMergeIterator<Entry>	Binary version of MergeIterator.
BufferedKVExternalSorter	Sorter for buffered input in the form of Key-Value Style.
ChannelReaderKVInputViewIterator<K,V>	Key-Value style channel reader input view iterator.
LimitOperator	Operator for batch limit.
ListMemorySegmentPool	MemorySegment pool of a MemorySegment list.
ProcTimeSortOperator	Sort on proc-time and additional secondary sort attributes.
RankOperator	Rank operator to compute top N.
RowTimeSortOperator	Sort based on event-time and possibly additional secondary sort attributes.
SortLimitOperator	Operator for batch sort limit.
SortOperator	Operator for batch sort.
SortUtil	Util for sort.
SpillChannelManager	Channel manager to manage the life cycle of spill channels.
StreamSortOperator	Operator for stream sort.