org.apache.paimon.flink.sorter

Class HilbertSorter

java.lang.Object

org.apache.paimon.flink.sorter.TableSorter

org.apache.paimon.flink.sorter.HilbertSorter

public class HilbertSorter
extends TableSorter

This is a table sorter which will sort the records by the hilbert curve of specified columns. It works on stream api. It computes the hilbert index by HilbertIndexer. After add the column of hilbert, it does the range shuffle and sort. Finally, SortCompactAction will remove the "hilbert" column and insert sorted record to overwrite the origin table.

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
HilbertSorter(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

HilbertSorter

public HilbertSorter(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