Modifier and Type | Class and Description |
---|---|
class |
HBaseTableSource
Creates a TableSource to scan an HBase table.
|
Modifier and Type | Class and Description |
---|---|
class |
JdbcTableSource
TableSource for JDBC. |
Modifier and Type | Method and Description |
---|---|
TableSource<Row> |
JdbcTableSource.projectFields(int[] fields) |
Modifier and Type | Class and Description |
---|---|
class |
HiveTableSource
A TableSource implementation to read data from Hive tables.
|
Modifier and Type | Method and Description |
---|---|
TableSource<RowData> |
HiveTableSource.applyLimit(long limit) |
TableSource<RowData> |
HiveTableSource.applyPartitionPruning(List<Map<String,String>> remainingPartitions) |
TableSource<RowData> |
HiveTableFactory.createTableSource(TableSourceFactory.Context context) |
TableSource<RowData> |
HiveTableSource.projectFields(int[] fields) |
Modifier and Type | Class and Description |
---|---|
class |
ParquetTableSource
A TableSource to read Parquet files.
|
Modifier and Type | Method and Description |
---|---|
TableSource<Row> |
ParquetTableSource.applyPredicate(List<Expression> predicates) |
TableSource<Row> |
ParquetTableSource.projectFields(int[] fields) |
Modifier and Type | Class and Description |
---|---|
class |
OrcTableSource
A TableSource to read ORC files.
|
Modifier and Type | Method and Description |
---|---|
TableSource<Row> |
OrcTableSource.applyPredicate(List<Expression> predicates) |
TableSource<Row> |
OrcTableSource.projectFields(int[] selectedFields) |
Modifier and Type | Class and Description |
---|---|
static class |
BatchSQLTestProgram.GeneratorTableSource
TableSource for generated data.
|
static class |
StreamSQLTestProgram.GeneratorTableSource
TableSource for generated data.
|
Modifier and Type | Class and Description |
---|---|
class |
Kafka010TableSource
Kafka
StreamTableSource for Kafka 0.10. |
class |
Kafka011TableSource
Kafka
StreamTableSource for Kafka 0.11. |
class |
KafkaTableSource
Kafka
StreamTableSource . |
class |
KafkaTableSourceBase
A version-agnostic Kafka
StreamTableSource . |
Modifier and Type | Method and Description |
---|---|
Table |
TableEnvironment.fromTableSource(TableSource<?> source)
Deprecated.
|
void |
TableEnvironment.registerTableSource(String name,
TableSource<?> tableSource)
Deprecated.
Use
executeSql(ddl) to register a table instead. |
Modifier and Type | Method and Description |
---|---|
protected void |
StreamTableEnvironmentImpl.validateTableSource(TableSource<?> tableSource) |
Modifier and Type | Method and Description |
---|---|
Table |
TableEnvironmentImpl.fromTableSource(TableSource<?> source) |
void |
TableEnvironmentImpl.registerTableSource(String name,
TableSource<?> tableSource) |
void |
TableEnvironmentInternal.registerTableSourceInternal(String name,
TableSource<?> tableSource)
Registers an external
TableSource in this TableEnvironment 's catalog. |
void |
TableEnvironmentImpl.registerTableSourceInternal(String name,
TableSource<?> tableSource) |
protected void |
TableEnvironmentImpl.validateTableSource(TableSource<?> tableSource)
Subclasses can override this method to add additional checks.
|
Modifier and Type | Method and Description |
---|---|
Optional<TableSource<T1>> |
ConnectorCatalogTable.getTableSource() |
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) |
Constructor and Description |
---|
ConnectorCatalogTable(TableSource<T1> tableSource,
TableSink<T2> tableSink,
TableSchema tableSchema,
boolean isBatch) |
Modifier and Type | Method and Description |
---|---|
default TableSource<T> |
BatchTableSourceFactory.createTableSource(Map<String,String> properties)
Only create batch table source.
|
default TableSource<T> |
StreamTableSourceFactory.createTableSource(Map<String,String> properties)
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)
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)
Creates a
TableSource from a CatalogTable . |
static <T> TableSource<T> |
TableFactoryUtil.findAndCreateTableSource(TableSourceFactory.Context context)
Returns a table source matching the descriptor.
|
Modifier and Type | Class and Description |
---|---|
class |
FileSystemTableSource
File system table source.
|
Modifier and Type | Method and Description |
---|---|
TableSource<RowData> |
FileSystemTableFactory.createTableSource(TableSourceFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
TableSource<T> |
TableSourceQueryOperation.getTableSource() |
Constructor and Description |
---|
TableSourceQueryOperation(TableSource<T> tableSource,
boolean isBatch) |
Constructor and Description |
---|
RichTableSourceQueryOperation(ObjectIdentifier identifier,
TableSource<T> tableSource,
org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic) |
Modifier and Type | Method and Description |
---|---|
protected List<String> |
FlinkPreparingTableBase.explainSourceAsString(TableSource<?> ts)
Returns the digest of the
TableSource instance. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractArrowTableSource<T>
A
StreamTableSource for serialized arrow record batch data. |
class |
ArrowTableSource
An Arrow TableSource which takes
RowData as the type of the produced records. |
class |
RowArrowTableSource
An Arrow TableSource which takes
Row as the type of the produced records. |
Modifier and Type | Interface and Description |
---|---|
interface |
BatchTableSource<T>
Deprecated.
use
InputFormatTableSource instead. |
interface |
LookupableTableSource<T>
A
TableSource which supports for lookup accessing via key column(s). |
interface |
StreamTableSource<T>
Defines an external stream table and provides read access to its data.
|
Modifier and Type | Class and Description |
---|---|
class |
CsvTableSource
A
StreamTableSource and BatchTableSource for simple CSV files with a (logically)
unlimited number of fields. |
class |
InputFormatTableSource<T>
Defines an external bounded table and provides access to its data.
|
Modifier and Type | Method and Description |
---|---|
TableSource<T> |
LimitableTableSource.applyLimit(long limit)
Check and push down the limit to the table source.
|
TableSource |
PartitionableTableSource.applyPartitionPruning(List<Map<String,String>> remainingPartitions)
Applies the remaining partitions to the table source.
|
TableSource<T> |
FilterableTableSource.applyPredicate(List<Expression> predicates)
Check and pick all predicates this table source can support.
|
TableSource<T> |
ProjectableTableSource.projectFields(int[] fields)
Creates a copy of the
TableSource that projects its output to the given field
indexes. |
TableSource<T> |
NestedFieldsProjectableTableSource.projectNestedFields(int[] fields,
String[][] nestedFields)
Creates a copy of the
TableSource that projects its output to the given field
indexes. |
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.
|
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 . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.