public abstract class TableSorter extends Object
SortCompactAction
.Modifier and Type | Class and Description |
---|---|
static class |
TableSorter.OrderType
The order type of table sort.
|
Modifier and Type | Field and Description |
---|---|
protected org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
batchTEnv |
protected List<String> |
orderColNames |
protected org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> |
origin |
protected FileStoreTable |
table |
Constructor and Description |
---|
TableSorter(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment batchTEnv,
org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> origin,
FileStoreTable table,
List<String> orderColNames) |
Modifier and Type | Method and Description |
---|---|
static TableSorter |
getSorter(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment batchTEnv,
org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> origin,
FileStoreTable fileStoreTable,
TableSortInfo sortInfo) |
abstract org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> |
sort() |
protected final org.apache.flink.streaming.api.environment.StreamExecutionEnvironment batchTEnv
protected final org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> origin
protected final FileStoreTable table
public TableSorter(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment batchTEnv, org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> origin, FileStoreTable table, List<String> orderColNames)
public abstract org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> sort()
public static TableSorter getSorter(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment batchTEnv, org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> origin, FileStoreTable fileStoreTable, TableSortInfo sortInfo)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.