public class SortOperator extends org.apache.flink.table.runtime.operators.TableStreamOperator<InternalRow> implements org.apache.flink.streaming.api.operators.OneInputStreamOperator<InternalRow,InternalRow>, org.apache.flink.streaming.api.operators.BoundedOneInput
Constructor and Description |
---|
SortOperator(RowType keyType,
RowType rowType,
long maxMemory,
int pageSize,
int spillSortMaxNumFiles,
CompressOptions spillCompression,
int sinkParallelism,
MemorySize maxDiskSize) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
endInput() |
void |
open() |
void |
processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<InternalRow> element) |
computeMemorySize, processWatermark, useSplittableTimers
finish, getChainingStrategy, getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getStateKeySelector1, getStateKeySelector2, getTimeServiceManager, getUserCodeClassloader, hasKeyContext1, hasKeyContext2, initializeState, initializeState, isUsingCustomRawKeyedState, notifyCheckpointAborted, notifyCheckpointComplete, prepareSnapshotPreBarrier, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processRecordAttributes, processRecordAttributes1, processRecordAttributes2, processWatermark1, processWatermark2, processWatermarkStatus, processWatermarkStatus1, processWatermarkStatus2, reportOrForwardLatencyMarker, setChainingStrategy, setCurrentKey, setKeyContextElement1, setKeyContextElement2, setMailboxExecutor, setProcessingTimeService, setup, snapshotState, snapshotState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
setKeyContextElement
finish, getMetricGroup, getOperatorAttributes, getOperatorID, initializeState, prepareSnapshotPreBarrier, setKeyContextElement1, setKeyContextElement2, snapshotState
notifyCheckpointAborted, notifyCheckpointComplete
getCurrentKey, setCurrentKey
public SortOperator(RowType keyType, RowType rowType, long maxMemory, int pageSize, int spillSortMaxNumFiles, CompressOptions spillCompression, int sinkParallelism, MemorySize maxDiskSize)
public void open() throws Exception
open
in interface org.apache.flink.streaming.api.operators.StreamOperator<InternalRow>
open
in class org.apache.flink.table.runtime.operators.TableStreamOperator<InternalRow>
Exception
public void endInput() throws Exception
endInput
in interface org.apache.flink.streaming.api.operators.BoundedOneInput
Exception
public void close() throws Exception
close
in interface org.apache.flink.streaming.api.operators.StreamOperator<InternalRow>
close
in class org.apache.flink.streaming.api.operators.AbstractStreamOperator<InternalRow>
Exception
public void processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<InternalRow> element) throws Exception
processElement
in interface org.apache.flink.streaming.api.operators.Input<InternalRow>
Exception
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.