Class InputFormatTableSource<T>
- java.lang.Object
-
- org.apache.flink.legacy.table.sources.InputFormatTableSource<T>
-
- Type Parameters:
T
- Type of the boundedInputFormat
created by thisTableSource
.
- All Implemented Interfaces:
StreamTableSource<T>
,TableSource<T>
@Deprecated @Internal public abstract class InputFormatTableSource<T> extends Object implements StreamTableSource<T>
Deprecated.This interface has been replaced byDynamicTableSource
. The new interface produces internal data structures. See FLIP-95 for more information.Defines an external bounded table and provides access to its data.
-
-
Constructor Summary
Constructors Constructor Description InputFormatTableSource()
Deprecated.
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Deprecated Methods Modifier and Type Method Description DataStream<T>
getDataStream(StreamExecutionEnvironment execEnv)
Deprecated.Returns the data of the table as aDataStream
.abstract InputFormat<T,?>
getInputFormat()
Deprecated.Returns anInputFormat
for reading the data of the table.boolean
isBounded()
Deprecated.Always returns true which indicates this is a bounded source.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.flink.table.legacy.sources.TableSource
explainSource, getProducedDataType, getReturnType, getTableSchema
-
-
-
-
Method Detail
-
getInputFormat
public abstract InputFormat<T,?> getInputFormat()
Deprecated.Returns anInputFormat
for reading the data of the table.
-
isBounded
public final boolean isBounded()
Deprecated.Always returns true which indicates this is a bounded source.- Specified by:
isBounded
in interfaceStreamTableSource<T>
-
getDataStream
public final DataStream<T> getDataStream(StreamExecutionEnvironment execEnv)
Deprecated.Description copied from interface:StreamTableSource
Returns the data of the table as aDataStream
.NOTE: This method is for internal use only for defining a
TableSource
. Do not use it in Table API programs.- Specified by:
getDataStream
in interfaceStreamTableSource<T>
-
-