IN
- Type of the input elements.OUT
- Type of the output elements.UDTFIN
- Type of the UDTF input type.@Internal public abstract class AbstractPythonTableFunctionOperator<IN,OUT,UDTFIN> extends AbstractStatelessFunctionOperator<IN,OUT,UDTFIN>
AbstractStatelessFunctionOperator.StreamRecordCRowWrappingCollector, AbstractStatelessFunctionOperator.StreamRecordRowDataWrappingCollector
Modifier and Type | Field and Description |
---|---|
protected org.apache.calcite.rel.core.JoinRelType |
joinType
The correlate join type.
|
protected PythonFunctionInfo |
tableFunction
The Python
TableFunction to be executed. |
bais, baisWrapper, forwardedInputQueue, inputType, outputType, userDefinedFunctionInputOffsets, userDefinedFunctionInputType, userDefinedFunctionOutputType, userDefinedFunctionResultQueue
chainingStrategy, latencyStats, LOG, metrics, output, processingTimeService
Constructor and Description |
---|
AbstractPythonTableFunctionOperator(Configuration config,
PythonFunctionInfo tableFunction,
RowType inputType,
RowType outputType,
int[] udtfInputOffsets,
org.apache.calcite.rel.core.JoinRelType joinType) |
Modifier and Type | Method and Description |
---|---|
PythonEnv |
getPythonEnv()
Returns the
PythonEnv used to create PythonEnvironmentManager.. |
protected boolean |
isFinishResult(byte[] rawUdtfResult)
The received udtf execution result is a finish message when it is a byte with value 0x00.
|
void |
open()
This method is called immediately before any elements are processed, it should contain the
operator's initialization logic, e.g.
|
bufferInput, createPythonFunctionRunner, createPythonFunctionRunner, getFunctionInput, processElement
close, createPythonEnvironmentManager, dispose, emitResults, endInput, getFlinkMetricContainer, getPythonConfig, prepareSnapshotPreBarrier, processWatermark
getChainingStrategy, getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getTimeServiceManager, getUserCodeClassloader, initializeState, initializeState, isUsingCustomRawKeyedState, notifyCheckpointAborted, notifyCheckpointComplete, numEventTimeTimers, numProcessingTimeTimers, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processWatermark1, processWatermark2, reportOrForwardLatencyMarker, setChainingStrategy, setCurrentKey, setKeyContextElement1, setKeyContextElement2, setProcessingTimeService, setup, snapshotState, snapshotState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
processLatencyMarker
getMetricGroup, getOperatorID, initializeState, setKeyContextElement1, setKeyContextElement2, snapshotState
notifyCheckpointAborted, notifyCheckpointComplete
getCurrentKey, setCurrentKey
protected final PythonFunctionInfo tableFunction
TableFunction
to be executed.protected final org.apache.calcite.rel.core.JoinRelType joinType
public AbstractPythonTableFunctionOperator(Configuration config, PythonFunctionInfo tableFunction, RowType inputType, RowType outputType, int[] udtfInputOffsets, org.apache.calcite.rel.core.JoinRelType joinType)
public void open() throws Exception
AbstractStreamOperator
The default implementation does nothing.
open
in interface StreamOperator<OUT>
open
in class AbstractStatelessFunctionOperator<IN,OUT,UDTFIN>
Exception
- An exception in this method causes the operator to fail.public PythonEnv getPythonEnv()
AbstractPythonFunctionOperator
PythonEnv
used to create PythonEnvironmentManager..getPythonEnv
in class AbstractPythonFunctionOperator<IN,OUT>
protected boolean isFinishResult(byte[] rawUdtfResult)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.