org.apache.flink.table.sources

Interface StreamTableSource<T>

Type Parameters:

T - Type of the DataStream created by this TableSource.

All Superinterfaces:

TableSource<T>

All Known Implementing Classes:

ArrowTableSource, BatchSQLTestProgram.GeneratorTableSource, CsvTableSource, InputFormatTableSource, StreamSQLTestProgram.GeneratorTableSource

Deprecated.

This interface has been replaced by DynamicTableSource. The new interface produces internal data structures. See FLIP-95 for more information.

@Deprecated
public interface StreamTableSource<T>
extends TableSource<T>

Defines an external stream table and provides read access to its data.

Method Summary

Modifier and Type	Method and Description
DataStream<T>	getDataStream(StreamExecutionEnvironment execEnv) Deprecated. Returns the data of the table as a DataStream.
default boolean	isBounded() Deprecated. Returns true if this is a bounded source, false if this is an unbounded source.

Methods inherited from interface org.apache.flink.table.sources.TableSource

explainSource, getProducedDataType, getReturnType, getTableSchema

Method Detail

isBounded

default boolean isBounded()

Deprecated.

Returns true if this is a bounded source, false if this is an unbounded source. Default is unbounded for compatibility.

getDataStream

DataStream<T> getDataStream(StreamExecutionEnvironment execEnv)

Deprecated.

Returns the data of the table as a DataStream.

NOTE: This method is for internal use only for defining a TableSource. Do not use it in Table API programs.