Modifier and Type | Class and Description |
---|---|
class |
BlackHoleTableSinkFactory
Black hole table sink factory swallowing all input records.
|
Modifier and Type | Class and Description |
---|---|
class |
DataGenTableSourceFactory
Factory for creating configured instances of
DataGenTableSource in a stream environment. |
Modifier and Type | Class and Description |
---|---|
class |
HBase1DynamicTableFactory
HBase connector factory.
|
Modifier and Type | Class and Description |
---|---|
class |
HBase2DynamicTableFactory
HBase connector factory.
|
Modifier and Type | Method and Description |
---|---|
Optional<Factory> |
AbstractJdbcCatalog.getFactory() |
Modifier and Type | Class and Description |
---|---|
class |
JdbcCatalogFactory
Factory for
JdbcCatalog . |
Modifier and Type | Class and Description |
---|---|
class |
JdbcDynamicTableFactory
Factory for creating configured instances of
JdbcDynamicTableSource and JdbcDynamicTableSink . |
Modifier and Type | Class and Description |
---|---|
class |
PrintTableSinkFactory
Print table sink factory writing every row to the standard output or standard error stream.
|
Modifier and Type | Class and Description |
---|---|
class |
HiveDynamicTableFactory
A dynamic table factory implementation for Hive catalog.
|
Modifier and Type | Class and Description |
---|---|
class |
AvroFileFormatFactory
Avro format factory for file system.
|
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 |
RegistryAvroFormatFactory
Table format factory for providing configured instances of Schema Registry Avro to RowData
SerializationSchema and DeserializationSchema . |
Modifier and Type | Class and Description |
---|---|
class |
DebeziumAvroFormatFactory
Format factory for providing configured instances of Debezium Avro to RowData
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 |
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 |
MaxwellJsonFormatFactory
Format factory for providing configured instances of Maxwell JSON to RowData
DeserializationSchema . |
Modifier and Type | Class and Description |
---|---|
class |
ParquetFileFormatFactory
Parquet format factory for file system.
|
Modifier and Type | Class and Description |
---|---|
class |
RawFormatFactory
Format factory for raw format which allows to read and write raw (byte based) values as a single
column.
|
Modifier and Type | Class and Description |
---|---|
class |
OrcFileFormatFactory
Orc format factory 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 |
KafkaDynamicTableFactory
Factory for creating configured instances of
KafkaDynamicSource and KafkaDynamicSink . |
class |
UpsertKafkaDynamicTableFactory
Upsert-Kafka factory.
|
Modifier and Type | Class and Description |
---|---|
class |
KinesisDynamicTableFactory
Factory for creating
KinesisDynamicSource and KinesisDynamicSink instances. |
Modifier and Type | Class and Description |
---|---|
class |
GenericInMemoryCatalogFactory
Catalog factory for
GenericInMemoryCatalog . |
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 |
HiveCatalogFactory
Catalog factory for
HiveCatalog . |
Modifier and Type | Interface and Description |
---|---|
interface |
ExecutorFactory
Factory that creates an
Executor for submitting table programs. |
interface |
PlannerFactory
Factory that creates
Planner . |
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 |
BulkReaderFormatFactory
Base interface for configuring a
BulkFormat for file system connector. |
interface |
BulkWriterFormatFactory
Base interface for configuring a
BulkWriter.Factory for file system connector. |
interface |
CatalogFactory
A factory to create configured catalog instances based on string-based properties.
|
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
Deprecated.
This interface has been replaced by
BulkReaderFormatFactory and BulkWriterFormatFactory . |
interface |
ModuleFactory
A factory to create configured module instances based on string-based properties.
|
interface |
SerializationFormatFactory
Factory for creating a
EncodingFormat for SerializationSchema . |
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. |
Modifier and Type | Class and Description |
---|---|
class |
FileSystemTableFactory
File system
TableFactory . |
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 | Interface and Description |
---|---|
interface |
ParserFactory
Factory that creates
Parser . |
Modifier and Type | Class and Description |
---|---|
class |
DefaultExecutorFactory
Factory to create the default implementation of an
Executor for TableEnvironment . |
class |
DefaultParserFactory
A Parser factory that creates
ParserImpl . |
class |
DefaultPlannerFactory
Factory for the default
Planner . |
Modifier and Type | Class and Description |
---|---|
class |
HiveParserFactory
A Parser factory that creates
HiveParser . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.