org.apache.flink.table.sources

类 InputFormatTableSource<T>

java.lang.Object

org.apache.flink.table.sources.InputFormatTableSource<T>

类型参数:

T - Type of the bounded InputFormat created by this TableSource.

所有已实现的接口:

StreamTableSource<T>, org.apache.flink.table.sources.TableSource<T>

已过时。

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

@Deprecated
 @Experimental
public abstract class InputFormatTableSource<T>
extends Object
implements StreamTableSource<T>

Defines an external bounded table and provides access to its data.

构造器概要

构造器

构造器和说明
InputFormatTableSource() 已过时。

方法概要

限定符和类型	方法和说明
org.apache.flink.streaming.api.datastream.DataStream<T>	getDataStream(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment execEnv) 已过时。 Returns the data of the table as a DataStream.
abstract org.apache.flink.api.common.io.InputFormat<T,?>	getInputFormat() 已过时。 Returns an InputFormat for reading the data of the table.
boolean	isBounded() 已过时。 Always returns true which indicates this is a bounded source.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 org.apache.flink.table.sources.TableSource

explainSource, getProducedDataType, getReturnType, getTableSchema

构造器详细资料

InputFormatTableSource

public InputFormatTableSource()

已过时。

方法详细资料

getInputFormat

public abstract org.apache.flink.api.common.io.InputFormat<T,?> getInputFormat()

已过时。

Returns an InputFormat for reading the data of the table.

isBounded

public final boolean isBounded()

已过时。

Always returns true which indicates this is a bounded source.

指定者:

isBounded 在接口中 StreamTableSource<T>

getDataStream

public final org.apache.flink.streaming.api.datastream.DataStream<T> getDataStream(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment execEnv)

已过时。

从接口复制的说明: StreamTableSource

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.

指定者:

getDataStream 在接口中 StreamTableSource<T>