Modifier and Type | Class and Description |
---|---|
class |
BroadcastStateBootstrapOperator<IN>
A
StreamOperator for executing BroadcastStateBootstrapFunction 's. |
class |
KeyedStateBootstrapOperator<K,IN>
A
StreamOperator for executing KeyedStateBootstrapFunction 's. |
class |
StateBootstrapOperator<IN>
A
StreamOperator for executing StateBootstrapFunction 's. |
class |
StateBootstrapWrapperOperator<IN,OUT,OP extends AbstractStreamOperator<OUT> & OneInputStreamOperator<IN,OUT>>
Wraps an existing operator so it can be bootstrapped.
|
Modifier and Type | Class and Description |
---|---|
class |
AsyncWaitOperator<IN,OUT>
The
AsyncWaitOperator allows to asynchronously process incoming stream records. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractOneInputPythonFunctionOperator<IN,OUT>
Base class for all one input stream operators to execute Python functions.
|
class |
OneInputPythonFunctionOperator<IN,OUT,UDFIN,UDFOUT>
OneInputPythonFunctionOperator is responsible for launching beam runner which will start
a python harness to execute user defined python function. |
class |
PythonFlatMapOperator<IN,OUT>
The
PythonFlatMapOperator is responsible for executing Python functions that gets one
input and produces zero/one or more outputs. |
class |
PythonKeyedProcessOperator<OUT>
PythonKeyedProcessOperator is responsible for launching beam runner which will start a
python harness to execute user defined python function. |
class |
PythonMapOperator<IN,OUT>
The
PythonMapOperator is responsible for executing Python functions that gets one input
and produces zero/one or more outputs. |
class |
PythonPartitionCustomOperator<IN,OUT>
The
PythonPartitionCustomOperator enables us to set the number of partitions for current
operator dynamically when generating the StreamGraph
before executing the job. |
class |
PythonProcessOperator<IN,OUT>
PythonProcessOperator is responsible for launching beam runner which will start a python
harness to execute user defined python ProcessFunction. |
class |
PythonReduceOperator<OUT>
PythonReduceOperator is responsible for launching beam runner which will start a python
harness to execute user defined python ReduceFunction. |
class |
PythonTimestampsAndWatermarksOperator<IN>
A stream operator that may do one or both of the following: extract timestamps from events and
generate watermarks by user specify TimestampAssigner and WatermarkStrategy.
|
Modifier and Type | Class and Description |
---|---|
class |
StreamingGlobalCommitterOperator<CommT,GlobalCommT>
Runtime
StreamOperator for executing GlobalCommitter in the streaming execution mode. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractStreamingWriter<IN,OUT>
Operator for file system sink.
|
class |
StreamingFileWriter<IN>
Writer for emitting
PartitionCommitInfo to downstream. |
Modifier and Type | Class and Description |
---|---|
class |
CompactFileWriter<T>
Writer for emitting
CompactMessages.InputFile and CompactMessages.EndCheckpoint to downstream. |
class |
CompactOperator<T>
Receives compaction units to do compaction.
|
Modifier and Type | Class and Description |
---|---|
class |
BufferDataOverWindowOperator
the operator for OVER window need cache data by ResettableExternalBuffer for
OverWindowFrame . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractStatelessFunctionOperator<IN,OUT,UDFIN>
Base class for all stream operators to execute Python Stateless Functions.
|
Modifier and Type | Class and Description |
---|---|
class |
PythonStreamGroupAggregateOperator
The Python AggregateFunction operator for the blink planner.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractArrowPythonAggregateFunctionOperator
The Abstract class of Arrow Aggregate Operator for Pandas
AggregateFunction . |
Modifier and Type | Class and Description |
---|---|
class |
BatchArrowPythonGroupAggregateFunctionOperator
The Batch Arrow Python
AggregateFunction Operator for Group Aggregation. |
class |
BatchArrowPythonGroupWindowAggregateFunctionOperator
The Batch Arrow Python
AggregateFunction Operator for Group Window Aggregation. |
class |
BatchArrowPythonOverWindowAggregateFunctionOperator
The Batch Arrow Python
AggregateFunction Operator for Over Window Aggregation. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractStreamArrowPythonBoundedRangeOperator<K>
The Abstract class of Stream Arrow Python
AggregateFunction Operator for RANGE clause
bounded Over Window Aggregation. |
class |
AbstractStreamArrowPythonBoundedRowsOperator<K>
The Abstract class of Stream Arrow Python
AggregateFunction Operator for ROWS clause
bounded Over Window Aggregation. |
class |
AbstractStreamArrowPythonOverWindowAggregateFunctionOperator<K>
The Abstract class of Stream Arrow Python
AggregateFunction Operator for Over Window
Aggregation. |
class |
StreamArrowPythonGroupWindowAggregateFunctionOperator<K,W extends Window>
The Stream Arrow Python
AggregateFunction Operator for Group Window Aggregation. |
class |
StreamArrowPythonProcTimeBoundedRangeOperator<K>
The Stream Arrow Python
AggregateFunction Operator for ROWS clause proc-time bounded OVER
window. |
class |
StreamArrowPythonProcTimeBoundedRowsOperator<K>
The Stream Arrow Python
AggregateFunction Operator for ROWS clause proc-time bounded OVER
window. |
class |
StreamArrowPythonRowTimeBoundedRangeOperator<K>
The Stream Arrow Python
AggregateFunction Operator for RANGE clause event-time bounded
OVER window. |
class |
StreamArrowPythonRowTimeBoundedRowsOperator<K>
The Stream Arrow Python
AggregateFunction Operator for RANGE clause event-time bounded
OVER window. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractPythonScalarFunctionOperator<IN,OUT,UDFIN>
Base class for all stream operators to execute Python
ScalarFunction s. |
class |
AbstractRowDataPythonScalarFunctionOperator
The Python
ScalarFunction operator for the blink planner. |
class |
AbstractRowPythonScalarFunctionOperator
Base Python
ScalarFunction operator for the legacy planner. |
class |
PythonScalarFunctionOperator
The Python
ScalarFunction operator for the legacy planner. |
class |
RowDataPythonScalarFunctionOperator
The Python
ScalarFunction operator for the blink planner. |
Modifier and Type | Class and Description |
---|---|
class |
ArrowPythonScalarFunctionOperator
Arrow Python
ScalarFunction operator for the old planner. |
class |
RowDataArrowPythonScalarFunctionOperator
Arrow Python
ScalarFunction operator for the blink planner. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractPythonTableFunctionOperator<IN,OUT,UDTFIN> |
class |
PythonTableFunctionOperator
The Python
TableFunction operator for the legacy planner. |
class |
RowDataPythonTableFunctionOperator
The Python
TableFunction operator for the blink planner. |
Modifier and Type | Class and Description |
---|---|
class |
SortLimitOperator
Operator for batch sort limit.
|
class |
SortOperator
Operator for batch sort.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.