Modifier and Type | Class and Description |
---|---|
class |
HBaseTableSource
Creates a TableSource to scan an HBase table.
|
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<org.apache.flink.table.expressions.Expression> predicates) |
TableSource<Row> |
OrcTableSource.projectFields(int[] selectedFields) |
Modifier and Type | Class and Description |
---|---|
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 |
---|---|
Map<String,TableSource<?>> |
ExecutionContext.getTableSources() |
Modifier and Type | Method and Description |
---|---|
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. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.