| AbstractProcessTableOperator |
Base class for operators for ProcessTableFunction.
|
| PassAllCollector |
Forwards all columns of the given row.
|
| PassPartitionKeysCollector |
Forwards partition keys of the given input's row.
|
| PassThroughCollectorBase |
Base class for collectors that pass input columns.
|
| ProcessRowTableOperator |
Implementation of OneInputStreamOperator for ProcessTableFunction with at most
one table with row semantics.
|
| ProcessSetTableOperator |
Implementation of MultipleInputStreamOperator for ProcessTableFunction with at
least one table with set semantics.
|
| ProcessTableOperatorFactory |
|
| RepeatedRowData |
A row that repeats the columns of a given row by the given count.
|
| RuntimeChangelogMode |
Serializable version of ChangelogMode.
|
| RuntimeStateInfo |
Serializable representation of TypeInferenceUtil.StateInfo that will translate into state descriptors and
state access.
|
| RuntimeTableSemantics |
Serializable representation of TableSemantics that will serve ProcessTableFunction.Context.tableSemanticsFor(String) during runtime.
|