Modifier and Type | Class and Description |
---|---|
class |
HBase1TableFactory
Factory for creating configured instances of
HBaseTableSource or sink. |
Modifier and Type | Class and Description |
---|---|
class |
HBase2TableFactory
Factory for creating configured instances of
HBaseTableSource or sink. |
Modifier and Type | Class and Description |
---|---|
class |
JdbcCatalogFactory
Factory for
JdbcCatalog . |
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 |
Elasticsearch7UpsertTableSinkFactory
Table factory for creating an
UpsertStreamTableSink for Elasticsearch 7. |
Modifier and Type | Class and Description |
---|---|
class |
KafkaTableSourceSinkFactory
Deprecated.
|
class |
KafkaTableSourceSinkFactoryBase
Deprecated.
|
Constructor and Description |
---|
AmbiguousTableFactoryException(List<? extends TableFactory> matchingFactories,
Class<? extends TableFactory> factoryClass,
List<TableFactory> factories,
Map<String,String> properties) |
AmbiguousTableFactoryException(List<? extends TableFactory> matchingFactories,
Class<? extends TableFactory> factoryClass,
List<TableFactory> factories,
Map<String,String> properties) |
AmbiguousTableFactoryException(List<? extends TableFactory> matchingFactories,
Class<? extends TableFactory> factoryClass,
List<TableFactory> factories,
Map<String,String> properties) |
AmbiguousTableFactoryException(List<? extends TableFactory> matchingFactories,
Class<? extends TableFactory> factoryClass,
List<TableFactory> factories,
Map<String,String> properties,
Throwable cause) |
AmbiguousTableFactoryException(List<? extends TableFactory> matchingFactories,
Class<? extends TableFactory> factoryClass,
List<TableFactory> factories,
Map<String,String> properties,
Throwable cause) |
AmbiguousTableFactoryException(List<? extends TableFactory> matchingFactories,
Class<? extends TableFactory> factoryClass,
List<TableFactory> factories,
Map<String,String> properties,
Throwable cause) |
NoMatchingTableFactoryException(String message,
Class<?> factoryClass,
List<TableFactory> factories,
Map<String,String> properties) |
NoMatchingTableFactoryException(String message,
String matchCandidatesMessage,
Class<?> factoryClass,
List<TableFactory> factories,
Map<String,String> properties) |
NoMatchingTableFactoryException(String message,
String matchCandidatesMessage,
Class<?> factoryClass,
List<TableFactory> factories,
Map<String,String> properties,
Throwable cause) |
Modifier and Type | Class and Description |
---|---|
class |
GenericInMemoryCatalogFactory
Catalog factory for
GenericInMemoryCatalog . |
Modifier and Type | Method and Description |
---|---|
default Optional<TableFactory> |
Catalog.getTableFactory()
Deprecated.
Use
Catalog.getFactory() for the new factory stack. The new factory stack uses
the new table sources and sinks defined in FLIP-95 and a slightly different discovery
mechanism. |
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>
Deprecated.
This interface has been replaced by
DynamicTableSinkFactory . The new
interface creates instances of DynamicTableSink and only works with the Blink
planner. See FLIP-95 for more information. |
interface |
BatchTableSourceFactory<T>
Deprecated.
This interface has been replaced by
DynamicTableSourceFactory . The new
interface creates instances of DynamicTableSource and only works with the Blink
planner. See FLIP-95 for more information. |
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 |
ModuleFactory
A factory to create configured module instances based on string-based properties.
|
interface |
SerializationSchemaFactory<T>
Factory for creating configured instances of
SerializationSchema . |
interface |
StreamTableSinkFactory<T>
Deprecated.
This interface has been replaced by
DynamicTableSinkFactory . The new
interface creates instances of DynamicTableSink and only works with the Blink
planner. See FLIP-95 for more information. |
interface |
StreamTableSourceFactory<T>
Deprecated.
This interface has been replaced by
DynamicTableSourceFactory . The new
interface creates instances of DynamicTableSource and only works with the Blink
planner. See FLIP-95 for more information. |
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 |
CoreModuleFactory
Factory for
CoreModule . |
Modifier and Type | Class and Description |
---|---|
class |
HiveModuleFactory
Factory for
HiveModule . |
Modifier and Type | Class and Description |
---|---|
class |
StreamPlannerFactory
Factory to construct a
StreamPlanner . |
Modifier and Type | Interface and Description |
---|---|
interface |
ParserFactory
Factory that creates
Parser . |
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 . |
class |
DefaultParserFactory
A Parser factory that creates
ParserImpl . |
Modifier and Type | Class and Description |
---|---|
class |
HiveParserFactory
A Parser factory that creates
HiveParser . |
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–2022 The Apache Software Foundation. All rights reserved.