Package org.apache.flink.table.runtime.operators

Class AsyncStateTableStreamOperator<OUT>

java.lang.Object

org.apache.flink.streaming.api.operators.AbstractStreamOperator<OUT>

org.apache.flink.runtime.asyncprocessing.operators.AbstractAsyncKeyOrderedStreamOperator<OUT>

org.apache.flink.runtime.asyncprocessing.operators.AbstractAsyncStateStreamOperator<OUT>

org.apache.flink.table.runtime.operators.AsyncStateTableStreamOperator<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.StreamOperator<OUT>, org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.CheckpointedStreamOperator, org.apache.flink.streaming.api.operators.YieldingOperator<OUT>, org.apache.flink.streaming.runtime.operators.asyncprocessing.AsyncKeyOrderedProcessing, org.apache.flink.streaming.runtime.operators.asyncprocessing.AsyncKeyOrderedProcessingOperator

Direct Known Subclasses:

AsyncStateWindowAggOperator, AsyncStateWindowJoinOperator

public abstract class AsyncStateTableStreamOperator<OUT>
extends org.apache.flink.runtime.asyncprocessing.operators.AbstractAsyncStateStreamOperator<OUT>

Table operator to invoke close always. This is a base class for both batch and stream operators without key.

This class is nearly identical with TableStreamOperator, but extending from AbstractAsyncStateStreamOperator to integrate with asynchronous state access.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	AsyncStateTableStreamOperator.ContextImpl	Information available in an invocation of processElement.

Field Summary

Fields

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

Fields inherited from class org.apache.flink.runtime.asyncprocessing.operators.AbstractAsyncKeyOrderedStreamOperator

asyncExecutionController, currentProcessingContext, declarationManager, environment

Fields inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperator

combinedWatermark, config, lastRecordAttributes1, lastRecordAttributes2, latencyStats, metrics, output, processingTimeService, stateHandler, stateKeySelector1, stateKeySelector2, timeServiceManager

Constructor Summary

Constructors

Constructor	Description
AsyncStateTableStreamOperator()

Method Summary

Modifier and Type	Method	Description
long	computeMemorySize()	Compute memory size from memory faction.
void	open()
org.apache.flink.streaming.api.watermark.Watermark	preProcessWatermark(org.apache.flink.streaming.api.watermark.Watermark mark)
boolean	useSplittableTimers()

Methods inherited from class org.apache.flink.runtime.asyncprocessing.operators.AbstractAsyncStateStreamOperator

createAsyncExecutionController, getKeySelectorForAsyncKeyedContext

Methods inherited from class org.apache.flink.runtime.asyncprocessing.operators.AbstractAsyncKeyOrderedStreamOperator

asyncProcessWithKey, beforeInitializeStateHandler, close, drainStateRequests, finish, getAsyncKeyedStateBackend, getCurrentKey, getDeclarationManager, getElementOrder, getInternalTimerService, getOrCreateKeyedState, getRecordProcessor, handleAsyncException, isAsyncKeyOrderedProcessingEnabled, newKeySelected, postProcessElement, postProcessWatermark, prepareSnapshotPreBarrier, preserveRecordOrderAndProcess, processNonRecord, processRecordAttributes, processRecordAttributes1, processRecordAttributes2, processWatermark, processWatermark, processWatermark1, processWatermark1Internal, processWatermark2, processWatermark2Internal, processWatermarkInternal, processWatermarkStatus, processWatermarkStatus, reportOrForwardLatencyMarker, setAsyncKeyedContextElement, setKeyContextElement1, setKeyContextElement2

Methods inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperator

getContainingTask, getExecutionConfig, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getStateKeySelector1, getStateKeySelector2, getTimeServiceManager, getUserCodeClassloader, hasKeyContext1, hasKeyContext2, initializeState, initializeState, isUsingCustomRawKeyedState, notifyCheckpointAborted, notifyCheckpointComplete, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processWatermark1, processWatermark2, processWatermarkStatus1, processWatermarkStatus2, setCurrentKey, setMailboxExecutor, 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.runtime.operators.asyncprocessing.AsyncKeyOrderedProcessing

getRecordProcessor, isAsyncKeyOrderedProcessingEnabled

Methods inherited from interface org.apache.flink.streaming.runtime.operators.asyncprocessing.AsyncKeyOrderedProcessingOperator

asyncProcessWithKey, getDeclarationManager, getElementOrder, postProcessElement, preserveRecordOrderAndProcess, setAsyncKeyedContextElement

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

hasKeyContext

Methods inherited from interface org.apache.flink.streaming.api.operators.StreamOperator

getOperatorAttributes

Field Detail

currentWatermark

protected long currentWatermark

We listen to this ourselves because we don't have an InternalTimerService.

ctx

protected transient AsyncStateTableStreamOperator.ContextImpl ctx

Constructor Detail

AsyncStateTableStreamOperator

public AsyncStateTableStreamOperator()

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

useSplittableTimers

public boolean useSplittableTimers()

Overrides:

useSplittableTimers in class org.apache.flink.streaming.api.operators.AbstractStreamOperator<OUT>

computeMemorySize

public long computeMemorySize()

Compute memory size from memory faction.

preProcessWatermark

public org.apache.flink.streaming.api.watermark.Watermark preProcessWatermark(org.apache.flink.streaming.api.watermark.Watermark mark)
                                                                       throws Exception

Overrides:

preProcessWatermark in class org.apache.flink.runtime.asyncprocessing.operators.AbstractAsyncKeyOrderedStreamOperator<OUT>

Throws:

Exception