Modifier and Type | Class and Description |
---|---|
class |
HBaseDynamicTableFactory
HBase connector factory.
|
Modifier and Type | Method and Description |
---|---|
Optional<Factory> |
AbstractJdbcCatalog.getFactory() |
Modifier and Type | Class and Description |
---|---|
class |
JdbcDynamicTableFactory
Factory for creating configured instances of
JdbcDynamicTableSource and JdbcDynamicTableSink . |
Modifier and Type | Class and Description |
---|---|
class |
HiveDynamicTableFactory
A dynamic table factory implementation for Hive catalog.
|
Modifier and Type | Class and Description |
---|---|
class |
AvroFileSystemFormatFactory
Avro format factory for file system.
|
class |
AvroFormatFactory
Table format factory for providing configured instances of Avro to RowData
SerializationSchema and DeserializationSchema . |
Modifier and Type | Class and Description |
---|---|
class |
CsvFileSystemFormatFactory
CSV format factory for file system.
|
class |
CsvFormatFactory
Format factory for providing configured instances of CSV to RowData
SerializationSchema
and DeserializationSchema . |
Modifier and Type | Class and Description |
---|---|
class |
JsonFileSystemFormatFactory
Factory to build reader/writer to read/write json format file.
|
class |
JsonFormatFactory
Table format factory for providing configured instances of JSON to RowData
SerializationSchema and DeserializationSchema . |
Modifier and Type | Class and Description |
---|---|
class |
CanalJsonFormatFactory
Format factory for providing configured instances of Canal JSON to RowData
DeserializationSchema . |
Modifier and Type | Class and Description |
---|---|
class |
DebeziumJsonFormatFactory
Format factory for providing configured instances of Debezium JSON to RowData
DeserializationSchema . |
Modifier and Type | Class and Description |
---|---|
class |
ParquetFileSystemFormatFactory
Parquet
FileSystemFormatFactory for file system. |
Modifier and Type | Class and Description |
---|---|
class |
OrcFileSystemFormatFactory
Orc
FileSystemFormatFactory for file system. |
Modifier and Type | Class and Description |
---|---|
class |
Elasticsearch6DynamicSinkFactory
A
DynamicTableSinkFactory for discovering Elasticsearch6DynamicSink . |
class |
Elasticsearch7DynamicSinkFactory
A
DynamicTableSinkFactory for discovering Elasticsearch7DynamicSink . |
Modifier and Type | Class and Description |
---|---|
class |
Kafka010DynamicTableFactory
Factory for creating configured instances of
Kafka010DynamicSource . |
class |
Kafka011DynamicTableFactory
Factory for creating configured instances of
Kafka011DynamicSource . |
class |
KafkaDynamicTableFactory
Factory for creating configured instances of
KafkaDynamicSource . |
class |
KafkaDynamicTableFactoryBase
Factory for creating configured instances of
KafkaDynamicSourceBase and KafkaDynamicSinkBase . |
Modifier and Type | Method and Description |
---|---|
default Optional<Factory> |
Catalog.getFactory()
Returns a factory for creating instances from catalog objects.
|
Modifier and Type | Method and Description |
---|---|
Optional<Factory> |
HiveCatalog.getFactory() |
Modifier and Type | Class and Description |
---|---|
class |
ChangelogCsvFormatFactory
The
ChangelogCsvFormatFactory translates format-specific options to a format. |
class |
SocketDynamicTableFactory
The
SocketDynamicTableFactory translates the catalog table to a table source. |
Modifier and Type | Interface and Description |
---|---|
interface |
DecodingFormatFactory<I>
|
interface |
DeserializationFormatFactory
Factory for creating a
DecodingFormat for DeserializationSchema . |
interface |
DynamicTableFactory
Base interface for configuring a dynamic table connector for an external storage system from
catalog and session information.
|
interface |
DynamicTableSinkFactory
Creates a
DynamicTableSink instance from a CatalogTable and additional context
information. |
interface |
DynamicTableSourceFactory
Creates a
DynamicTableSource instance from a CatalogTable and additional context
information. |
interface |
EncodingFormatFactory<I>
Base interface for configuring an
EncodingFormat for a DynamicTableSink . |
interface |
FileSystemFormatFactory
File system format factory for creating configured instances of reader and writer.
|
interface |
SerializationFormatFactory
Factory for creating a
EncodingFormat for SerializationSchema . |
Modifier and Type | Class and Description |
---|---|
class |
BlackHoleTableSinkFactory
Black hole table sink factory swallowing all input records.
|
class |
DataGenTableSourceFactory
Factory for creating configured instances of
DataGenTableSource in a stream environment. |
class |
PrintTableSinkFactory
Print table sink factory writing every row to the standard output or standard error stream.
|
Modifier and Type | Method and Description |
---|---|
static <T extends Factory> |
FactoryUtil.discoverFactory(ClassLoader classLoader,
Class<T> factoryClass,
String factoryIdentifier)
Discovers a factory using the given factory base class and identifier.
|
Modifier and Type | Method and Description |
---|---|
static void |
FactoryUtil.validateFactoryOptions(Factory factory,
ReadableConfig options)
Validates the required and optional
ConfigOption s of a factory. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.