Modifier and Type | Class and Description |
---|---|
class |
BatchExecBoundedStreamScan
Batch
ExecNode to connect a given bounded DataStream and consume data from it. |
class |
BatchExecLegacySink<T>
|
class |
BatchExecLegacyTableSourceScan
Batch
ExecNode to read data from an external source defined by a bounded StreamTableSource . |
class |
BatchExecSink
Batch
ExecNode to to write data into an external sink defined by a DynamicTableSink . |
class |
BatchExecTableSourceScan
Batch
ExecNode to read data from an external source defined by a bounded ScanTableSource . |
Modifier and Type | Class and Description |
---|---|
class |
CommonExecLegacySink<T>
|
class |
CommonExecLegacyTableSourceScan
Base
ExecNode to read data from an external source defined by a StreamTableSource . |
class |
CommonExecSink
Base
ExecNode to write data to an external sink defined by a DynamicTableSink . |
class |
CommonExecTableSourceScan
Base
ExecNode to read data from an external source defined by a ScanTableSource . |
Modifier and Type | Class and Description |
---|---|
class |
StreamExecDataStreamScan
Stream
ExecNode to connect a given DataStream and consume data from it. |
class |
StreamExecIntervalJoin
StreamExecNode for a time interval stream join. |
class |
StreamExecLegacySink<T>
|
class |
StreamExecLegacyTableSourceScan
Stream
ExecNode to read data from an external source defined by a StreamTableSource . |
class |
StreamExecMatch
Stream
ExecNode which matches along with MATCH_RECOGNIZE. |
class |
StreamExecSink
Stream
ExecNode to to write data into an external sink defined by a DynamicTableSink . |
class |
StreamExecTableSourceScan
Stream
ExecNode to read data from an external source defined by a ScanTableSource . |
class |
StreamExecTemporalSort
StreamExecNode for time-ascending-order Sort without `limit`. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.