Uses of Interface
org.apache.flink.table.sources.TableSource

Packages that use TableSource

Package	Description
org.apache.flink.connectors.hive
org.apache.flink.sql.tests
org.apache.flink.table.api.bridge.java.internal
org.apache.flink.table.api.internal
org.apache.flink.table.catalog
org.apache.flink.table.factories
org.apache.flink.table.operations
org.apache.flink.table.planner.operations
org.apache.flink.table.planner.plan.nodes.exec.batch
org.apache.flink.table.planner.plan.nodes.exec.common
org.apache.flink.table.planner.plan.nodes.exec.stream
org.apache.flink.table.planner.plan.schema
org.apache.flink.table.runtime.arrow.sources
org.apache.flink.table.sources
org.apache.flink.table.utils
org.apache.flink.table.utils.python

Uses of TableSource in org.apache.flink.connectors.hive

Methods in org.apache.flink.connectors.hive that return TableSource

Modifier and Type	Method and Description
TableSource	HiveTableFactory.createTableSource(TableSourceFactory.Context context)

Uses of TableSource in org.apache.flink.sql.tests

Classes in org.apache.flink.sql.tests that implement TableSource

Modifier and Type	Class and Description
static class	BatchSQLTestProgram.GeneratorTableSource TableSource for generated data.
static class	StreamSQLTestProgram.GeneratorTableSource TableSource for generated data.

Uses of TableSource in org.apache.flink.table.api.bridge.java.internal

Methods in org.apache.flink.table.api.bridge.java.internal with parameters of type TableSource

Modifier and Type	Method and Description
protected void	StreamTableEnvironmentImpl.validateTableSource(TableSource<?> tableSource)

Uses of TableSource in org.apache.flink.table.api.internal

Methods in org.apache.flink.table.api.internal with parameters of type TableSource

Modifier and Type	Method and Description
Table	TableEnvironmentImpl.fromTableSource(TableSource<?> source)
Table	TableEnvironmentInternal.fromTableSource(TableSource<?> source) Deprecated.
void	TableEnvironmentImpl.registerTableSourceInternal(String name, TableSource<?> tableSource)
void	TableEnvironmentInternal.registerTableSourceInternal(String name, TableSource<?> tableSource) Registers an external TableSource in this TableEnvironment's catalog.
protected void	TableEnvironmentImpl.validateTableSource(TableSource<?> tableSource) Subclasses can override this method to add additional checks.

Uses of TableSource in org.apache.flink.table.catalog

Methods in org.apache.flink.table.catalog that return types with arguments of type TableSource

Modifier and Type	Method and Description
Optional<TableSource<T1>>	ConnectorCatalogTable.getTableSource()

Methods in org.apache.flink.table.catalog with parameters of type TableSource

Modifier and Type	Method and Description
static <T1> TableSchema	ConnectorCatalogTable.calculateSourceSchema(TableSource<T1> source, boolean isBatch)
static <T1> ConnectorCatalogTable<T1,?>	ConnectorCatalogTable.source(TableSource<T1> source, boolean isBatch)
static <T1,T2> ConnectorCatalogTable<T1,T2>	ConnectorCatalogTable.sourceAndSink(TableSource<T1> source, TableSink<T2> sink, boolean isBatch)

Constructors in org.apache.flink.table.catalog with parameters of type TableSource

Constructor and Description
ConnectorCatalogTable(TableSource<T1> tableSource, TableSink<T2> tableSink, TableSchema tableSchema, boolean isBatch)

Uses of TableSource in org.apache.flink.table.factories

Methods in org.apache.flink.table.factories that return TableSource

Modifier and Type	Method and Description
default TableSource<T>	StreamTableSourceFactory.createTableSource(Map<String,String> properties) Deprecated. Only create a stream table source.
default TableSource<T>	TableSourceFactory.createTableSource(Map<String,String> properties) Deprecated. TableSourceFactory.Context contains more information, and already contains table schema too. Please use TableSourceFactory.createTableSource(Context) instead.
default TableSource<T>	TableSourceFactory.createTableSource(ObjectPath tablePath, CatalogTable table) Deprecated. TableSourceFactory.Context contains more information, and already contains table schema too. Please use TableSourceFactory.createTableSource(Context) instead.
default TableSource<T>	TableSourceFactory.createTableSource(TableSourceFactory.Context context) Deprecated. Creates and configures a TableSource based on the given TableSourceFactory.Context.
static <T> TableSource<T>	TableFactoryUtil.findAndCreateTableSource(Catalog catalog, ObjectIdentifier objectIdentifier, CatalogTable catalogTable, ReadableConfig configuration, boolean isTemporary) Creates a TableSource from a CatalogTable.
static <T> TableSource<T>	TableFactoryUtil.findAndCreateTableSource(TableSourceFactory.Context context) Returns a table source matching the descriptor.

Uses of TableSource in org.apache.flink.table.operations

Methods in org.apache.flink.table.operations that return TableSource

Modifier and Type	Method and Description
TableSource<T>	TableSourceQueryOperation.getTableSource()

Constructors in org.apache.flink.table.operations with parameters of type TableSource

Constructor and Description
TableSourceQueryOperation(TableSource<T> tableSource, boolean isBatch)

Uses of TableSource in org.apache.flink.table.planner.operations

Constructors in org.apache.flink.table.planner.operations with parameters of type TableSource

Constructor and Description
RichTableSourceQueryOperation(ObjectIdentifier identifier, TableSource<T> tableSource, org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic)

Uses of TableSource in org.apache.flink.table.planner.plan.nodes.exec.batch

Constructors in org.apache.flink.table.planner.plan.nodes.exec.batch with parameters of type TableSource

Constructor and Description
BatchExecLegacyTableSourceScan(ReadableConfig tableConfig, TableSource<?> tableSource, List<String> qualifiedName, RowType outputType, String description)

Uses of TableSource in org.apache.flink.table.planner.plan.nodes.exec.common

Fields in org.apache.flink.table.planner.plan.nodes.exec.common declared as TableSource

Modifier and Type	Field and Description
protected TableSource<?>	CommonExecLegacyTableSourceScan.tableSource

Constructors in org.apache.flink.table.planner.plan.nodes.exec.common with parameters of type TableSource

Constructor and Description
CommonExecLegacyTableSourceScan(int id, ExecNodeContext context, ReadableConfig persistedConfig, TableSource<?> tableSource, List<String> qualifiedName, RowType outputType, String description)

Uses of TableSource in org.apache.flink.table.planner.plan.nodes.exec.stream

Constructors in org.apache.flink.table.planner.plan.nodes.exec.stream with parameters of type TableSource

Constructor and Description
StreamExecLegacyTableSourceScan(ReadableConfig tableConfig, TableSource<?> tableSource, List<String> qualifiedName, RowType outputType, String description)

Uses of TableSource in org.apache.flink.table.planner.plan.schema

Methods in org.apache.flink.table.planner.plan.schema with parameters of type TableSource

Modifier and Type	Method and Description
protected List<String>	FlinkPreparingTableBase.explainSourceAsString(TableSource<?> ts) Returns the digest of the TableSource instance.

Uses of TableSource in org.apache.flink.table.runtime.arrow.sources

Classes in org.apache.flink.table.runtime.arrow.sources that implement TableSource

Modifier and Type	Class and Description
class	ArrowTableSource A StreamTableSource for serialized arrow record batch data.

Uses of TableSource in org.apache.flink.table.sources

Subinterfaces of TableSource in org.apache.flink.table.sources

Modifier and Type	Interface and Description
interface	LookupableTableSource<T> Deprecated. This interface will not be supported in the new source design around DynamicTableSource. Use LookupTableSource instead. See FLIP-95 for more information.
interface	StreamTableSource<T> Deprecated. This interface has been replaced by DynamicTableSource. The new interface produces internal data structures. See FLIP-95 for more information.

Classes in org.apache.flink.table.sources that implement TableSource

Modifier and Type	Class and Description
class	CsvTableSource Deprecated. The legacy CSV connector has been replaced by FileSource. It is kept only to support tests for the legacy connector stack.
class	InputFormatTableSource<T> Deprecated. This interface has been replaced by DynamicTableSource. The new interface produces internal data structures. See FLIP-95 for more information.

Methods in org.apache.flink.table.sources that return TableSource

Modifier and Type	Method and Description
TableSource<T>	LimitableTableSource.applyLimit(long limit) Deprecated. Check and push down the limit to the table source.
TableSource	PartitionableTableSource.applyPartitionPruning(List<Map<String,String>> remainingPartitions) Deprecated. Applies the remaining partitions to the table source.
TableSource<T>	FilterableTableSource.applyPredicate(List<Expression> predicates) Deprecated. Check and pick all predicates this table source can support.
TableSource<T>	ProjectableTableSource.projectFields(int[] fields) Deprecated. Creates a copy of the TableSource that projects its output to the given field indexes.
TableSource<T>	NestedFieldsProjectableTableSource.projectNestedFields(int[] fields, String[][] nestedFields) Deprecated. Creates a copy of the TableSource that projects its output to the given field indexes.

Methods in org.apache.flink.table.sources with parameters of type TableSource

Modifier and Type	Method and Description
static boolean	TableSourceValidation.hasProctimeAttribute(TableSource<?> tableSource) Checks if the given TableSource defines a proctime attribute.
static boolean	TableSourceValidation.hasRowtimeAttribute(TableSource<?> tableSource) Checks if the given TableSource defines a rowtime attribute.
static void	TableSourceValidation.validateTableSource(TableSource<?> tableSource, TableSchema schema) Validates a TableSource.

Uses of TableSource in org.apache.flink.table.utils

Methods in org.apache.flink.table.utils with parameters of type TableSource

Modifier and Type	Method and Description
static int[]	TypeMappingUtils.computePhysicalIndicesOrTimeAttributeMarkers(TableSource<?> tableSource, List<TableColumn> logicalColumns, boolean streamMarkers, java.util.function.Function<String,String> nameRemapping) Computes indices of physical fields corresponding to the selected logical fields of a TableSchema.

Uses of TableSource in org.apache.flink.table.utils.python

Classes in org.apache.flink.table.utils.python that implement TableSource

Modifier and Type	Class and Description
class	PythonInputFormatTableSource An InputFormatTableSource created by python 'from_element' method.