Modifier and Type | Class and Description |
---|---|
class |
HBaseTableFactory
Factory for creating configured instances of
HBaseTableSource or sink. |
Modifier and Type | Class and Description |
---|---|
class |
JDBCTableSourceSinkFactory
Factory for creating configured instances of
JDBCTableSource and JDBCUpsertTableSink . |
Modifier and Type | Class and Description |
---|---|
class |
HiveTableFactory
A table factory implementation for Hive catalog.
|
Modifier and Type | Class and Description |
---|---|
class |
AvroRowFormatFactory
Table format factory for providing configured instances of Avro-to-row
SerializationSchema
and DeserializationSchema . |
Modifier and Type | Class and Description |
---|---|
class |
CsvRowFormatFactory
Table format factory for providing configured instances of CSV-to-row
SerializationSchema
and DeserializationSchema . |
Modifier and Type | Class and Description |
---|---|
class |
JsonRowFormatFactory
Table format factory for providing configured instances of JSON-to-row
SerializationSchema
and DeserializationSchema . |
Modifier and Type | Class and Description |
---|---|
class |
ElasticsearchUpsertTableSinkFactoryBase
Version-agnostic table factory for creating an
UpsertStreamTableSink for Elasticsearch. |
Modifier and Type | Class and Description |
---|---|
class |
Elasticsearch6UpsertTableSinkFactory
Table factory for creating an
UpsertStreamTableSink for Elasticsearch 6. |
Modifier and Type | Class and Description |
---|---|
class |
Kafka010TableSourceSinkFactory
Factory for creating configured instances of
Kafka010TableSource . |
class |
Kafka011TableSourceSinkFactory
Factory for creating configured instances of
Kafka011TableSource . |
class |
Kafka08TableSourceSinkFactory
Factory for creating configured instances of
Kafka08TableSource . |
class |
Kafka09TableSourceSinkFactory
Factory for creating configured instances of
Kafka09TableSource . |
class |
KafkaTableSourceSinkFactory
Factory for creating configured instances of
KafkaTableSource . |
class |
KafkaTableSourceSinkFactoryBase
Factory for creating configured instances of
KafkaTableSourceBase . |
Modifier and Type | Class and Description |
---|---|
class |
GenericInMemoryCatalogFactory
Catalog factory for
GenericInMemoryCatalog . |
Modifier and Type | Method and Description |
---|---|
default Optional<TableFactory> |
Catalog.getTableFactory()
Get an optional
TableFactory instance that's responsible for generating table-related
instances stored in this catalog, instances such as source/sink and function definitions. |
Modifier and Type | Method and Description |
---|---|
Optional<TableFactory> |
HiveCatalog.getTableFactory() |
Modifier and Type | Class and Description |
---|---|
class |
HiveCatalogFactory
Catalog factory for
HiveCatalog . |
Modifier and Type | Interface and Description |
---|---|
interface |
ExecutorFactory
Factory that creates
Executor . |
interface |
PlannerFactory
Factory that creates
Planner . |
Modifier and Type | Class and Description |
---|---|
class |
StreamExecutorFactory
Factory to create an implementation of
Executor to use in a
TableEnvironment . |
Modifier and Type | Interface and Description |
---|---|
interface |
BatchTableSinkFactory<T>
A factory to create configured table sink instances in a batch environment based on
string-based properties.
|
interface |
BatchTableSourceFactory<T>
A factory to create configured table source instances in a batch environment based on
string-based properties.
|
interface |
CatalogFactory
A factory to create configured catalog instances based on string-based properties.
|
interface |
ComponentFactory
A factory interface for components that enables further disambiguating in case
there are multiple matching implementations present.
|
interface |
DeserializationSchemaFactory<T>
Factory for creating configured instances of
DeserializationSchema . |
interface |
ExternalCatalogFactory
Deprecated.
use
CatalogFactory instead. |
interface |
FunctionDefinitionFactory
A factory to create
FunctionDefinition . |
interface |
SerializationSchemaFactory<T>
Factory for creating configured instances of
SerializationSchema . |
interface |
StreamTableSinkFactory<T>
A factory to create configured table sink instances in a streaming environment based on
string-based properties.
|
interface |
StreamTableSourceFactory<T>
A factory to create configured table source instances in a streaming environment based on
string-based properties.
|
interface |
TableFormatFactory<T>
A factory to create configured table format instances based on string-based properties.
|
interface |
TableSinkFactory<T>
A factory to create configured table sink instances in a batch or stream environment based on
string-based properties.
|
interface |
TableSourceFactory<T>
A factory to create configured table source instances in a batch or stream environment based on
string-based properties.
|
Modifier and Type | Class and Description |
---|---|
class |
TableFormatFactoryBase<T>
Base class for
TableFormatFactory s. |
Modifier and Type | Method and Description |
---|---|
static <T extends TableFactory> |
TableFactoryService.find(Class<T> factoryClass,
Descriptor descriptor)
Finds a table factory of the given class and descriptor.
|
static <T extends TableFactory> |
TableFactoryService.find(Class<T> factoryClass,
Descriptor descriptor,
ClassLoader classLoader)
Finds a table factory of the given class, descriptor, and classloader.
|
static <T extends TableFactory> |
TableFactoryService.find(Class<T> factoryClass,
Map<String,String> propertyMap)
Finds a table factory of the given class and property map.
|
static <T extends TableFactory> |
TableFactoryService.find(Class<T> factoryClass,
Map<String,String> propertyMap,
ClassLoader classLoader)
Finds a table factory of the given class, property map, and classloader.
|
static <T extends TableFactory> |
TableFactoryService.findAll(Class<T> factoryClass,
Map<String,String> propertyMap)
Finds all table factories of the given class and property map.
|
Modifier and Type | Class and Description |
---|---|
class |
StreamPlannerFactory
Factory to construct a
StreamPlanner . |
Modifier and Type | Class and Description |
---|---|
class |
BlinkExecutorFactory
Factory to create an implementation of
Executor to use in a
TableEnvironment . |
class |
BlinkPlannerFactory
Factory to construct a
BatchPlanner or StreamPlanner . |
Modifier and Type | Class and Description |
---|---|
class |
CsvAppendTableSinkFactory
Factory base for creating configured instances of
CsvTableSink in a stream environment. |
class |
CsvBatchTableSinkFactory
Factory base for creating configured instances of
CsvTableSink in a batch environment. |
class |
CsvTableSinkFactoryBase
Factory base for creating configured instances of
CsvTableSink . |
Modifier and Type | Class and Description |
---|---|
class |
CsvAppendTableSourceFactory
Factory for creating configured instances of
CsvTableSource in a stream environment. |
class |
CsvBatchTableSourceFactory
Factory for creating configured instances of
CsvTableSource in a batch environment. |
class |
CsvTableSourceFactoryBase
Factory base for creating configured instances of
CsvTableSource . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.