TableStreamOperator (Flink : Table : Runtime 1.19.2-cp2 API)

java.lang.Object
- org.apache.flink.streaming.api.operators.AbstractStreamOperator<OUT>
- - org.apache.flink.table.runtime.operators.TableStreamOperator<OUT>

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.state.CheckpointListener, org.apache.flink.streaming.api.operators.KeyContext, org.apache.flink.streaming.api.operators.KeyContextHandler, org.apache.flink.streaming.api.operators.SetupableStreamOperator<OUT>, org.apache.flink.streaming.api.operators.StreamOperator<OUT>, org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.CheckpointedStreamOperator

Direct Known Subclasses:

BufferDataOverWindowOperator, ConstraintEnforcer, GlobalRuntimeFilterBuilderOperator, HashJoinOperator, InputConversionOperator, LimitOperator, LocalRuntimeFilterBuilderOperator, NonBufferOverWindowOperator, OutputConversionOperator, RankOperator, RowKindSetter, SinkUpsertMaterializer, SortLimitOperator, SortMergeJoinOperator, SortOperator, StreamRecordTimestampInserter, StreamSortOperator, WindowAggOperator, WindowJoinOperator, WindowTableFunctionOperatorBase
```
public abstract class TableStreamOperator<OUT>
extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<OUT>
```
Table operator to invoke close always. This is a base class for both batch and stream operators without key.

See Also:

Serialized Form

Nested Class Summary

Nested Classes
Modifier and Type Class Description

protected class TableStreamOperator.ContextImpl
Information available in an invocation of processElement.

Field Summary

Fields
Modifier and Type	Field	Description
`protected TableStreamOperator.ContextImpl`	`ctx`
`protected long`	`currentWatermark`	We listen to this ourselves because we don't have an `InternalTimerService`.

Fields inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperator
chainingStrategy, config, lastRecordAttributes1, lastRecordAttributes2, latencyStats, LOG, metrics, output, processingTimeService

Constructor Summary

Constructors
Constructor Description

TableStreamOperator()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`long`	`computeMemorySize()`	Compute memory size from memory faction.
`void`	`open()`
`void`	`processWatermark(org.apache.flink.streaming.api.watermark.Watermark mark)`

Methods inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperator
close, finish, getChainingStrategy, getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, 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, setProcessingTimeService, setup, snapshotState, snapshotState

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.streaming.api.operators.KeyContextHandler
hasKeyContext

- Field Detail
  - currentWatermark
```
protected long currentWatermark
```
    We listen to this ourselves because we don't have an InternalTimerService.
  - ctx
```
protected transient TableStreamOperator.ContextImpl ctx
```
- Constructor Detail
  - TableStreamOperator
```
public TableStreamOperator()
```
- Method Detail
  - open
```
public void open()
          throws Exception
```
    Specified by:
    
    open in interface org.apache.flink.streaming.api.operators.StreamOperator<OUT>
    
    Overrides:
    
    open in class org.apache.flink.streaming.api.operators.AbstractStreamOperator<OUT>
    
    Throws:
    
    Exception
  - processWatermark
```
public void processWatermark(org.apache.flink.streaming.api.watermark.Watermark mark)
                      throws Exception
```
    Overrides:
    
    processWatermark in class org.apache.flink.streaming.api.operators.AbstractStreamOperator<OUT>
    
    Throws:
    
    Exception
  - computeMemorySize
```
public long computeMemorySize()
```
    Compute memory size from memory faction.