public class QueryExecutorOperator extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<InternalRow> implements org.apache.flink.streaming.api.operators.OneInputStreamOperator<InternalRow,InternalRow>
Constructor and Description |
---|
QueryExecutorOperator(Table table) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
initializeState(org.apache.flink.runtime.state.StateInitializationContext context) |
static RowType |
outputType() |
void |
processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<InternalRow> streamRecord) |
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, isUsingCustomRawKeyedState, notifyCheckpointAborted, notifyCheckpointComplete, open, prepareSnapshotPreBarrier, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processRecordAttributes, processRecordAttributes1, processRecordAttributes2, processWatermark, processWatermark1, processWatermark2, processWatermarkStatus, processWatermarkStatus1, processWatermarkStatus2, reportOrForwardLatencyMarker, setChainingStrategy, setCurrentKey, setKeyContextElement1, setKeyContextElement2, setMailboxExecutor, setProcessingTimeService, setup, snapshotState, snapshotState, useSplittableTimers
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
setKeyContextElement
finish, getMetricGroup, getOperatorAttributes, getOperatorID, initializeState, open, prepareSnapshotPreBarrier, setKeyContextElement1, setKeyContextElement2, snapshotState
notifyCheckpointAborted, notifyCheckpointComplete
getCurrentKey, setCurrentKey
public QueryExecutorOperator(Table table)
public static RowType outputType()
public void initializeState(org.apache.flink.runtime.state.StateInitializationContext context) throws Exception
initializeState
in interface org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.CheckpointedStreamOperator
initializeState
in class org.apache.flink.streaming.api.operators.AbstractStreamOperator<InternalRow>
Exception
public void processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<InternalRow> streamRecord) throws Exception
processElement
in interface org.apache.flink.streaming.api.operators.Input<InternalRow>
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
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.