org.apache.paimon.flink.sorter

Class OrderSorter

java.lang.Object

org.apache.paimon.flink.sorter.TableSorter

org.apache.paimon.flink.sorter.OrderSorter

public class OrderSorter
extends TableSorter

Alphabetical order sorter to sort records by the given `orderColNames`.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.paimon.flink.sorter.TableSorter

TableSorter.OrderType

Field Summary

Fields inherited from class org.apache.paimon.flink.sorter.TableSorter

batchTEnv, orderColNames, origin, table

Constructor Summary

Constructors

Constructor and Description
OrderSorter(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment batchTEnv, org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> origin, FileStoreTable table, TableSortInfo tableSortInfo)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData>	sort()

Methods inherited from class org.apache.paimon.flink.sorter.TableSorter

getSorter

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OrderSorter

public OrderSorter(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment batchTEnv,
                   org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> origin,
                   FileStoreTable table,
                   TableSortInfo tableSortInfo)

Method Detail

sort

public org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> sort()

Specified by:

sort in class TableSorter