Modifier and Type | Class and Description |
---|---|
class |
HBaseTableSource
Creates a TableSource to scan an HBase table.
|
Modifier and Type | Class and Description |
---|---|
class |
Kafka010AvroTableSource
Kafka
StreamTableSource for Kafka 0.10. |
class |
Kafka010JsonTableSource
Kafka
StreamTableSource for Kafka 0.10. |
class |
Kafka010TableSource
Kafka
StreamTableSource for Kafka 0.10. |
class |
Kafka08AvroTableSource
Kafka
StreamTableSource for Kafka 0.8. |
class |
Kafka08JsonTableSource
Kafka
StreamTableSource for Kafka 0.8. |
class |
Kafka08TableSource
Kafka
StreamTableSource for Kafka 0.8. |
class |
Kafka09AvroTableSource
Kafka
StreamTableSource for Kafka 0.9. |
class |
Kafka09JsonTableSource
Kafka
StreamTableSource for Kafka 0.9. |
class |
Kafka09TableSource
Kafka
StreamTableSource for Kafka 0.9. |
class |
KafkaAvroTableSource
A version-agnostic Kafka Avro
StreamTableSource . |
class |
KafkaJsonTableSource
A version-agnostic Kafka JSON
StreamTableSource . |
class |
KafkaTableSource
A version-agnostic Kafka
StreamTableSource . |
Modifier and Type | Method and Description |
---|---|
<A> int[] |
TableEnvironment$.getFieldIndices(TableSource<A> tableSource)
Returns field indices for a given
TableSource . |
static <A> int[] |
TableEnvironment.getFieldIndices(TableSource<A> tableSource)
Returns field indices for a given
TableSource . |
<A> String[] |
TableEnvironment$.getFieldNames(TableSource<A> tableSource)
Returns field names for a given
TableSource . |
static <A> String[] |
TableEnvironment.getFieldNames(TableSource<A> tableSource)
Returns field names for a given
TableSource . |
void |
BatchTableEnvironment.registerTableSource(String name,
TableSource<?> tableSource)
Registers an external
BatchTableSource in this TableEnvironment 's catalog. |
void |
StreamTableEnvironment.registerTableSource(String name,
TableSource<?> tableSource)
Registers an external
StreamTableSource in this TableEnvironment 's catalog. |
abstract void |
TableEnvironment.registerTableSource(String name,
TableSource<?> tableSource)
Registers an external
TableSource in this TableEnvironment 's catalog. |
Modifier and Type | Interface and Description |
---|---|
interface |
TableSourceConverter<T extends TableSource<?>>
Creates a
TableSource from the properties of an
ExternalCatalogTable . |
Modifier and Type | Method and Description |
---|---|
abstract PhysicalTableSourceScan |
PhysicalTableSourceScan.copy(org.apache.calcite.plan.RelTraitSet traitSet,
TableSource<?> tableSource) |
Constructor and Description |
---|
PhysicalTableSourceScan(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.plan.RelOptTable table,
TableSource<?> tableSource) |
Modifier and Type | Method and Description |
---|---|
PhysicalTableSourceScan |
BatchTableSourceScan.copy(org.apache.calcite.plan.RelTraitSet traitSet,
TableSource<?> newTableSource) |
Modifier and Type | Method and Description |
---|---|
PhysicalTableSourceScan |
StreamTableSourceScan.copy(org.apache.calcite.plan.RelTraitSet traitSet,
TableSource<?> newTableSource) |
Modifier and Type | Method and Description |
---|---|
FlinkLogicalTableSourceScan |
FlinkLogicalTableSourceScan.copy(org.apache.calcite.plan.RelTraitSet traitSet,
TableSource<?> tableSource) |
Constructor and Description |
---|
FlinkLogicalTableSourceScan(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
org.apache.calcite.plan.RelOptTable table,
TableSource<?> tableSource) |
Modifier and Type | Method and Description |
---|---|
TableSource<T> |
StreamTableSourceTable.tableSource() |
TableSource<T> |
TableSourceTable.tableSource() |
Constructor and Description |
---|
StreamTableSourceTable(TableSource<T> tableSource,
FlinkStatistic statistic) |
TableSourceTable(TableSource<T> tableSource,
FlinkStatistic statistic) |
Modifier and Type | Interface and Description |
---|---|
interface |
BatchTableSource<T>
Defines an external batch table and provides access to its data.
|
interface |
StreamTableSource<T>
Defines an external stream table and provides access to its data.
|
Modifier and Type | Class and Description |
---|---|
class |
CsvTableSource
A
BatchTableSource and StreamTableSource for simple CSV files with a
(logically) unlimited number of fields. |
Modifier and Type | Method and Description |
---|---|
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 on the specified fields. |
TableSource<T> |
NestedFieldsProjectableTableSource.projectNestedFields(int[] fields,
String[][] nestedFields)
Creates a copy of the
TableSource that projects its output on the specified nested fields. |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.