public class TableStreamOperator<OUT> extends AbstractStreamOperator<OUT>
chainingStrategy, config, latencyStats, LOG, metrics, output, timeServiceManager
|Constructor and Description|
|Modifier and Type||Method and Description|
This method is called after all records have been added to the operators via the methods
This method is called at the very end of the operator's life, both in the case of a successful completion of the operation, and in the case of a failure and canceling.
getChainingStrategy, getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getUserCodeClassloader, initializeState, initializeState, notifyCheckpointComplete, numEventTimeTimers, numProcessingTimeTimers, open, prepareSnapshotPreBarrier, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processWatermark, processWatermark1, processWatermark2, reportOrForwardLatencyMarker, setChainingStrategy, setCurrentKey, setKeyContextElement1, setKeyContextElement2, setup, snapshotState, snapshotState
public void close() throws Exception
The method is expected to flush all remaining buffered data. Exceptions during this flushing of buffered should be propagated, in order to cause the operation to be recognized asa failed, because the last data items are not processed properly.
Exception- An exception in this method causes the operator to fail.
public void dispose() throws Exception
This method is expected to make a thorough effort to release all resources that the operator has acquired.
Exception- if something goes wrong during disposal.
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.