Package org.apache.flink.table.sources

Interface Summary

Interface	Description
BatchTableSource<T>	Deprecated use InputFormatTableSource instead.
DefinedFieldMapping	The DefinedFieldMapping interface provides a mapping for the fields of the table schema (TableSource.getTableSchema() to fields of the physical produced data type TableSource.getProducedDataType() of a TableSource.
DefinedProctimeAttribute	Extends a TableSource to specify a processing time attribute.
DefinedRowtimeAttributes	Extends a TableSource to specify rowtime attributes via a RowtimeAttributeDescriptor.
FieldComputer<T>	The FieldComputer interface returns an expression to compute the field of the table schema of a TableSource from one or more fields of the TableSource's return type.
FilterableTableSource<T>	Adds support for filtering push-down to a TableSource.
LimitableTableSource<T>	Adds support for limiting push-down to a TableSource.
LookupableTableSource<T>	A TableSource which supports for lookup accessing via key column(s).
NestedFieldsProjectableTableSource<T>	Adds support for projection push-down to a TableSource with nested fields.
PartitionableTableSource	An interface for partitionable TableSource.
ProjectableTableSource<T>	Adds support for projection push-down to a TableSource.
StreamTableSource<T>	Defines an external stream table and provides read access to its data.
TableSource<T>	Defines an external table with the schema that is provided by TableSource.getTableSchema().

Class Summary

Class	Description
CsvAppendTableSourceFactory	Factory for creating configured instances of CsvTableSource in a stream environment.
CsvBatchTableSourceFactory	Factory for creating configured instances of CsvTableSource in a batch environment.
CsvTableSource	A StreamTableSource and BatchTableSource for simple CSV files with a (logically) unlimited number of fields.
CsvTableSource.Builder	A builder for creating CsvTableSource instances.
CsvTableSource.CsvLookupFunction	LookupFunction to support lookup in CsvTableSource.
CsvTableSourceFactoryBase	Factory base for creating configured instances of CsvTableSource.
InputFormatTableSource<T>	Defines an external bounded table and provides access to its data.
RowtimeAttributeDescriptor	Describes a rowtime attribute of a TableSource.
TableSourceValidation	Logic to validate TableSource types.