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 |
HiveTableSource.applyPartitionPruning(List<Map<String,String>> remainingPartitions) |
TableSource<Row> |
HiveTableFactory.createTableSource(Map<String,String> properties) |
TableSource<Row> |
HiveTableFactory.createTableSource(ObjectPath tablePath,
CatalogTable table) |
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 |
Kafka08TableSource
Kafka
StreamTableSource for Kafka 0.8. |
class |
Kafka09TableSource
Kafka
StreamTableSource for Kafka 0.9. |
class |
KafkaTableSource
Kafka
StreamTableSource . |
class |
KafkaTableSourceBase
A version-agnostic Kafka
StreamTableSource . |
Modifier and Type | Method and Description |
---|---|
Table |
TableEnvironment.fromTableSource(TableSource<?> source)
Creates a table from a table source.
|
void |
TableEnvironment.registerTableSource(String name,
TableSource<?> tableSource)
Registers an external
TableSource in this TableEnvironment 's catalog. |
Modifier and Type | Method and Description |
---|---|
Table |
TableEnvironmentImpl.fromTableSource(TableSource<?> source) |
void |
TableEnvironmentImpl.registerTableSource(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 |
---|---|
protected void |
StreamTableEnvironmentImpl.validateTableSource(TableSource<?> tableSource) |
Modifier and Type | Method and Description |
---|---|
Optional<TableSource<T1>> |
ConnectorCatalogTable.getTableSource() |
Modifier and Type | Method and Description |
---|---|
static <T1> ConnectorCatalogTable |
ConnectorCatalogTable.source(TableSource<T1> source,
boolean isBatch) |
static <T1,T2> ConnectorCatalogTable |
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 |
---|---|
Map<String,TableSource<?>> |
ExecutionContext.getTableSources() |
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.
|
TableSource<T> |
TableSourceFactory.createTableSource(Map<String,String> properties)
Creates and configures a
TableSource using the given properties. |
default TableSource<T> |
TableSourceFactory.createTableSource(ObjectPath tablePath,
CatalogTable table)
Creates and configures a
TableSource based on the given CatalogTable instance. |
static <T> TableSource<T> |
TableFactoryUtil.findAndCreateTableSource(CatalogTable table)
Returns a table sink matching the
CatalogTable . |
static <T> TableSource<T> |
TableFactoryUtil.findAndCreateTableSource(Descriptor descriptor)
Returns a table source matching the descriptor.
|
Modifier and Type | Method and Description |
---|---|
TableSource<T> |
TableSourceQueryOperation.getTableSource() |
Constructor and Description |
---|
TableSourceQueryOperation(TableSource<T> tableSource,
boolean isBatch) |
Constructor and Description |
---|
RichTableSourceQueryOperation(TableSource<T> tableSource,
org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic) |
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 |
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.hasRowtimeAttribute(TableSource<?> tableSource)
Checks if the given
TableSource defines a rowtime attribute. |
static void |
TableSourceValidation.validateTableSource(TableSource<?> tableSource)
Validates a TableSource.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.