@Internal public abstract class AbstractOneInputPythonFunctionOperator<IN,OUT> extends AbstractPythonFunctionOperator<OUT> implements OneInputStreamOperator<IN,OUT>, BoundedOneInput
elementCount, maxBundleSize, pythonFunctionRunner
chainingStrategy, latencyStats, LOG, metrics, output, processingTimeService
Constructor and Description |
---|
AbstractOneInputPythonFunctionOperator(Configuration config) |
Modifier and Type | Method and Description |
---|---|
void |
endInput()
It is notified that no more data will arrive on the input.
|
checkInvokeFinishBundleByCount, close, createPythonEnvironmentManager, createPythonFunctionRunner, dispose, emitResult, emitResults, getConfig, getFlinkMetricContainer, getPythonConfig, getPythonEnv, invokeFinishBundle, isBundleFinished, open, prepareSnapshotPreBarrier, processWatermark, setPythonConfig
getChainingStrategy, getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getTimeServiceManager, getUserCodeClassloader, initializeState, initializeState, isUsingCustomRawKeyedState, notifyCheckpointAborted, notifyCheckpointComplete, 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
setKeyContextElement
close, dispose, getMetricGroup, getOperatorID, initializeState, open, prepareSnapshotPreBarrier, setKeyContextElement1, setKeyContextElement2, snapshotState
notifyCheckpointAborted, notifyCheckpointComplete
getCurrentKey, setCurrentKey
processElement, processLatencyMarker, processWatermark
public AbstractOneInputPythonFunctionOperator(Configuration config)
public void endInput() throws Exception
BoundedOneInput
endInput
in interface BoundedOneInput
Exception
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.