Modifier and Type | Class and Description |
---|---|
class |
AsyncDynamicTableSinkFactory
Abstract Implementation of
DynamicTableSinkFactory having AsyncSinkBase fields as
optional table options defined in AsyncSinkConnectorOptions . |
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 |
FileSystemTableFactory
File system
TableFactory . |
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. |
Modifier and Type | Class and Description |
---|---|
class |
KinesisFirehoseDynamicTableFactory
Factory for creating
KinesisFirehoseDynamicSink . |
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 |
KinesisDynamicTableSinkFactory
Factory for creating
KinesisDynamicSink . |
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 |
UpsertTestDynamicTableSinkFactory
A
DynamicTableSinkFactory for discovering UpsertTestDynamicTableSink . |
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 |
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 |
CsvFileFormatFactory
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 |
OggJsonFormatFactory
Format factory for providing configured instances of Ogg 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 |
PbFormatFactory
Table format factory for providing configured instances of Protobuf to RowData
SerializationSchema and DeserializationSchema . |
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 . |
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 . |
interface |
StreamExecutorFactory
Sub interface of
ExecutorFactory to support DataStream API. |
Modifier and Type | Class and Description |
---|---|
class |
HiveServer2EndpointFactory
Endpoint Factory to create
HiveServer2Endpoint . |
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 | Class and Description |
---|---|
static class |
FactoryUtil.FactoryHelper<F extends Factory>
Base helper utility for validating all options for a
Factory . |
Modifier and Type | Interface and Description |
---|---|
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 |
FormatFactory
Base interface for
DecodingFormatFactory and EncodingFormatFactory . |
interface |
ManagedTableFactory
Base interface for configuring a managed dynamic table connector.
|
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 | Field and Description |
---|---|
protected F |
FactoryUtil.FactoryHelper.factory |
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 | Interface and Description |
---|---|
interface |
SqlGatewayEndpointFactory
A factory for creating Endpoint from Configuration.
|
Modifier and Type | Class and Description |
---|---|
class |
SqlGatewayRestEndpointFactory
The factory for sql gateway.
|
Modifier and Type | Class and Description |
---|---|
class |
CoreModuleFactory
Factory for
CoreModule . |
Modifier and Type | Method and Description |
---|---|
<T extends Factory> |
ModuleManager.getFactory(java.util.function.Function<Module,Optional<T>> selector)
Returns the first factory found in the loaded modules given a selector.
|
Modifier and Type | Class and Description |
---|---|
class |
HiveModuleFactory
Factory for
HiveModule . |
Modifier and Type | Interface and Description |
---|---|
interface |
DialectFactory
Factory that creates
Parser and ExtendedOperationExecutor . |
Modifier and Type | Class and Description |
---|---|
class |
DefaultDialectFactory
A Parser factory that creates
ParserImpl . |
class |
DefaultExecutorFactory
Factory to create the default implementation of an
Executor for TableEnvironment . |
class |
DefaultPlannerFactory
Factory for the default
Planner . |
Modifier and Type | Class and Description |
---|---|
class |
HiveDialectFactory
A Parser factory that creates
HiveParser . |
Modifier and Type | Class and Description |
---|---|
class |
DelegateExecutorFactory
Delegate of
ExecutorFactory . |
class |
DelegatePlannerFactory
Delegate of
PlannerFactory . |
Modifier and Type | Class and Description |
---|---|
class |
PythonDynamicTableFactory
Table source factory for PythonDynamicTableSource.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.