Modifier and Type | Method and Description |
---|---|
DynamicTableSource |
HBaseDynamicTableFactory.createDynamicTableSource(DynamicTableFactory.Context context) |
Modifier and Type | Class and Description |
---|---|
class |
HBaseDynamicTableSource
HBase table source implementation.
|
Modifier and Type | Method and Description |
---|---|
DynamicTableSource |
HBaseDynamicTableSource.copy() |
Modifier and Type | Class and Description |
---|---|
class |
JdbcDynamicTableSource
A
DynamicTableSource for JDBC. |
Modifier and Type | Method and Description |
---|---|
DynamicTableSource |
JdbcDynamicTableSource.copy() |
DynamicTableSource |
JdbcDynamicTableFactory.createDynamicTableSource(DynamicTableFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSource |
HiveDynamicTableFactory.createDynamicTableSource(DynamicTableFactory.Context context) |
Modifier and Type | Class and Description |
---|---|
class |
Kafka010DynamicSource
Kafka
StreamTableSource for Kafka 0.10. |
class |
Kafka011DynamicSource
Kafka
StreamTableSource for Kafka 0.11. |
class |
KafkaDynamicSource
Kafka
DynamicTableSource . |
class |
KafkaDynamicSourceBase
A version-agnostic Kafka
ScanTableSource . |
Modifier and Type | Method and Description |
---|---|
DynamicTableSource |
KafkaDynamicSource.copy() |
DynamicTableSource |
Kafka011DynamicSource.copy() |
DynamicTableSource |
Kafka010DynamicSource.copy() |
DynamicTableSource |
KafkaDynamicTableFactoryBase.createDynamicTableSource(DynamicTableFactory.Context context) |
Modifier and Type | Interface and Description |
---|---|
interface |
LookupTableSource
A
DynamicTableSource that looks up rows of an external storage system by one or more keys
during runtime. |
interface |
ScanTableSource
A
DynamicTableSource that scans all rows from an external storage system during runtime. |
Modifier and Type | Method and Description |
---|---|
DynamicTableSource |
DynamicTableSource.copy()
Creates a copy of this instance during planning.
|
Modifier and Type | Class and Description |
---|---|
class |
SocketDynamicTableSource
The
SocketDynamicTableSource is used during planning. |
Modifier and Type | Method and Description |
---|---|
DynamicTableSource |
SocketDynamicTableSource.copy() |
DynamicTableSource |
SocketDynamicTableFactory.createDynamicTableSource(DynamicTableFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSource |
DataGenTableSourceFactory.createDynamicTableSource(DynamicTableFactory.Context context) |
DynamicTableSource |
DynamicTableSourceFactory.createDynamicTableSource(DynamicTableFactory.Context context)
Creates a
DynamicTableSource instance from a CatalogTable and additional
context information. |
static DynamicTableSource |
FactoryUtil.createTableSource(Catalog catalog,
ObjectIdentifier objectIdentifier,
CatalogTable catalogTable,
ReadableConfig configuration,
ClassLoader classLoader)
Creates a
DynamicTableSource from a CatalogTable . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.