@PublicEvolving public interface DataStreamScanProvider extends ScanTableSource.ScanRuntimeProvider
DataStream
as a runtime implementation for ScanTableSource
.
Note: This provider is only meant for advanced connector developers. Usually, a source should
consist of a single entity expressed via InputFormatProvider
, SourceFunctionProvider
, or SourceProvider
.
Modifier and Type | Method and Description |
---|---|
DataStream<RowData> |
produceDataStream(StreamExecutionEnvironment execEnv)
Creates a scan Java
DataStream from a StreamExecutionEnvironment . |
isBounded
DataStream<RowData> produceDataStream(StreamExecutionEnvironment execEnv)
DataStream
from a StreamExecutionEnvironment
.Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.