Uses of Class
org.apache.flink.table.runtime.operators.TableStreamOperator

Packages that use TableStreamOperator

Package	Description
org.apache.flink.table.runtime.operators.join
org.apache.flink.table.runtime.operators.join.window
org.apache.flink.table.runtime.operators.over
org.apache.flink.table.runtime.operators.runtimefilter
org.apache.flink.table.runtime.operators.sink
org.apache.flink.table.runtime.operators.sort
org.apache.flink.table.runtime.operators.source
org.apache.flink.table.runtime.operators.window
org.apache.flink.table.runtime.operators.window.slicing

Uses of TableStreamOperator in org.apache.flink.table.runtime.operators.join

Subclasses of TableStreamOperator in org.apache.flink.table.runtime.operators.join

Modifier and Type	Class	Description
class	HashJoinOperator	Hash join base operator.
class	SortMergeJoinOperator	An implementation that realizes the joining through a sort-merge join strategy.

Uses of TableStreamOperator in org.apache.flink.table.runtime.operators.join.window

Subclasses of TableStreamOperator in org.apache.flink.table.runtime.operators.join.window

Modifier and Type	Class	Description
class	WindowJoinOperator	Streaming window join operator.

Uses of TableStreamOperator in org.apache.flink.table.runtime.operators.over

Subclasses of TableStreamOperator in org.apache.flink.table.runtime.operators.over

Modifier and Type	Class	Description
class	BufferDataOverWindowOperator	the operator for OVER window need cache data by ResettableExternalBuffer for OverWindowFrame.
class	NonBufferOverWindowOperator	The operator for OVER window don't need cache data.

Uses of TableStreamOperator in org.apache.flink.table.runtime.operators.runtimefilter

Subclasses of TableStreamOperator in org.apache.flink.table.runtime.operators.runtimefilter

Modifier and Type	Class	Description
class	GlobalRuntimeFilterBuilderOperator	Global runtime filter builder operator.
class	LocalRuntimeFilterBuilderOperator	Local runtime filter builder operator.

Uses of TableStreamOperator in org.apache.flink.table.runtime.operators.sink

Subclasses of TableStreamOperator in org.apache.flink.table.runtime.operators.sink

Modifier and Type	Class	Description
class	ConstraintEnforcer	Processes RowData to enforce the following constraints: NOT NULL column constraint of a sink table CHAR(length)/@{code VARCHAR(length)}: trim string values to comply with the length defined in their corresponding types.
class	OutputConversionOperator	Operator that converts to external data structures and unwraps atomic records if necessary.
class	RowKindSetter	An operator that sets the row kind of the incoming records to a specific row kind.
class	SinkUpsertMaterializer	An operator that maintains incoming records in state corresponding to the upsert keys and generates an upsert view for the downstream operator.
class	StreamRecordTimestampInserter	Operator which sets the timestamp on the StreamRecord from the corresponding column of each row.

Uses of TableStreamOperator in org.apache.flink.table.runtime.operators.sort

Subclasses of TableStreamOperator in org.apache.flink.table.runtime.operators.sort

Modifier and Type	Class	Description
class	LimitOperator	Operator for batch limit.
class	RankOperator	Rank operator to compute top N.
class	SortLimitOperator	Operator for batch sort limit.
class	SortOperator	Operator for batch sort.
class	StreamSortOperator	Operator for stream sort.

Uses of TableStreamOperator in org.apache.flink.table.runtime.operators.source

Subclasses of TableStreamOperator in org.apache.flink.table.runtime.operators.source

Modifier and Type	Class	Description
class	InputConversionOperator<E>	Operator that converts to internal data structures and wraps atomic records if necessary.

Uses of TableStreamOperator in org.apache.flink.table.runtime.operators.window

Subclasses of TableStreamOperator in org.apache.flink.table.runtime.operators.window

Modifier and Type	Class	Description
class	WindowTableFunctionOperator	The operator acts as a table-valued function to assign windows for input row.

Uses of TableStreamOperator in org.apache.flink.table.runtime.operators.window.slicing

Subclasses of TableStreamOperator in org.apache.flink.table.runtime.operators.window.slicing

Modifier and Type	Class	Description
class	SlicingWindowOperator<K,W>	The SlicingWindowOperator implements an optimized processing for aligned windows which can apply the slicing optimization.