org.apache.paimon.flink.sorter

Class ZorderSorter

java.lang.Object

org.apache.paimon.flink.sorter.TableSorter

org.apache.paimon.flink.sorter.ZorderSorter

public class ZorderSorter
extends TableSorter

This is a table sorter which will sort the records by the z-order of specified columns. It works on stream api. It computes the z-order-index by ZIndexer. After add the column of z-order, it does the range shuffle and sort. Finally, SortCompactAction will remove the "z-order" 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
ZorderSorter(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 sortInfo)

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

ZorderSorter

public ZorderSorter(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 sortInfo)

Method Detail

sort

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

Specified by:

sort in class TableSorter