Class and Description |
---|
DynamicTableFactory
Base interface for configuring a dynamic table connector for an external storage system from
catalog and session information.
|
DynamicTableFactory.Context
Provides catalog and session information describing the dynamic table to be accessed.
|
DynamicTableSinkFactory
Creates a
DynamicTableSink instance from a CatalogTable and additional context
information. |
DynamicTableSourceFactory
Creates a
DynamicTableSource instance from a CatalogTable and additional context
information. |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
StreamTableSinkFactory
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. |
StreamTableSourceFactory
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. |
TableFactory
A factory to create different table-related instances from string-based properties.
|
TableSinkFactory
A factory to create configured table sink instances in a batch or stream environment based on
string-based properties.
|
TableSourceFactory
A factory to create configured table source instances in a batch or stream environment based on
string-based properties.
|
Class and Description |
---|
DynamicTableFactory
Base interface for configuring a dynamic table connector for an external storage system from
catalog and session information.
|
DynamicTableFactory.Context
Provides catalog and session information describing the dynamic table to be accessed.
|
DynamicTableSinkFactory
Creates a
DynamicTableSink instance from a CatalogTable and additional context
information. |
DynamicTableSourceFactory
Creates a
DynamicTableSource instance from a CatalogTable and additional context
information. |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
StreamTableSinkFactory
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. |
StreamTableSourceFactory
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. |
TableFactory
A factory to create different table-related instances from string-based properties.
|
TableSinkFactory
A factory to create configured table sink instances in a batch or stream environment based on
string-based properties.
|
TableSourceFactory
A factory to create configured table source instances in a batch or stream environment based on
string-based properties.
|
Class and Description |
---|
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
Class and Description |
---|
CatalogFactory
A factory to create configured catalog instances based on string-based properties.
|
TableFactory
A factory to create different table-related instances from string-based properties.
|
Class and Description |
---|
DynamicTableFactory
Base interface for configuring a dynamic table connector for an external storage system from
catalog and session information.
|
DynamicTableFactory.Context
Provides catalog and session information describing the dynamic table to be accessed.
|
DynamicTableSinkFactory
Creates a
DynamicTableSink instance from a CatalogTable and additional context
information. |
DynamicTableSourceFactory
Creates a
DynamicTableSource instance from a CatalogTable and additional context
information. |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
StreamTableSinkFactory
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. |
StreamTableSourceFactory
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. |
TableFactory
A factory to create different table-related instances from string-based properties.
|
TableSinkFactory
A factory to create configured table sink instances in a batch or stream environment based on
string-based properties.
|
TableSourceFactory
A factory to create configured table source instances in a batch or stream environment based on
string-based properties.
|
Class and Description |
---|
DynamicTableFactory
Base interface for configuring a dynamic table connector for an external storage system from
catalog and session information.
|
DynamicTableFactory.Context
Provides catalog and session information describing the dynamic table to be accessed.
|
DynamicTableSinkFactory
Creates a
DynamicTableSink instance from a CatalogTable and additional context
information. |
DynamicTableSourceFactory
Creates a
DynamicTableSource instance from a CatalogTable and additional context
information. |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
TableFactory
A factory to create different table-related instances from string-based properties.
|
TableSinkFactory
A factory to create configured table sink instances in a batch or stream environment based on
string-based properties.
|
TableSinkFactory.Context
Context of table sink creation.
|
TableSourceFactory
A factory to create configured table source instances in a batch or stream environment based on
string-based properties.
|
TableSourceFactory.Context
Context of table source creation.
|
Class and Description |
---|
BulkWriterFormatFactory
Base interface for configuring a
BulkWriter.Factory for file system connector. |
DecodingFormatFactory |
DeserializationFormatFactory
Factory for creating a
DecodingFormat for DeserializationSchema . |
DeserializationSchemaFactory
Factory for creating configured instances of
DeserializationSchema . |
DynamicTableFactory.Context
Provides catalog and session information describing the dynamic table to be accessed.
|
EncodingFormatFactory
Base interface for configuring an
EncodingFormat for a DynamicTableSink . |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
FileSystemFormatFactory
Deprecated.
This interface has been replaced by
BulkReaderFormatFactory and BulkWriterFormatFactory . |
FileSystemFormatFactory.ReaderContext
Deprecated.
|
SerializationFormatFactory
Factory for creating a
EncodingFormat for SerializationSchema . |
SerializationSchemaFactory
Factory for creating configured instances of
SerializationSchema . |
TableFactory
A factory to create different table-related instances from string-based properties.
|
TableFormatFactory
A factory to create configured table format instances based on string-based properties.
|
TableFormatFactoryBase
Base class for
TableFormatFactory s. |
Class and Description |
---|
DecodingFormatFactory |
DeserializationFormatFactory
Factory for creating a
DecodingFormat for DeserializationSchema . |
DynamicTableFactory.Context
Provides catalog and session information describing the dynamic table to be accessed.
|
EncodingFormatFactory
Base interface for configuring an
EncodingFormat for a DynamicTableSink . |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
SerializationFormatFactory
Factory for creating a
EncodingFormat for SerializationSchema . |
Class and Description |
---|
DecodingFormatFactory |
DeserializationFormatFactory
Factory for creating a
DecodingFormat for DeserializationSchema . |
DynamicTableFactory.Context
Provides catalog and session information describing the dynamic table to be accessed.
|
EncodingFormatFactory
Base interface for configuring an
EncodingFormat for a DynamicTableSink . |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
SerializationFormatFactory
Factory for creating a
EncodingFormat for SerializationSchema . |
Class and Description |
---|
DecodingFormatFactory |
DeserializationFormatFactory
Factory for creating a
DecodingFormat for DeserializationSchema . |
DeserializationSchemaFactory
Factory for creating configured instances of
DeserializationSchema . |
DynamicTableFactory.Context
Provides catalog and session information describing the dynamic table to be accessed.
|
EncodingFormatFactory
Base interface for configuring an
EncodingFormat for a DynamicTableSink . |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
FileSystemFormatFactory
Deprecated.
This interface has been replaced by
BulkReaderFormatFactory and BulkWriterFormatFactory . |
FileSystemFormatFactory.ReaderContext
Deprecated.
|
SerializationFormatFactory
Factory for creating a
EncodingFormat for SerializationSchema . |
SerializationSchemaFactory
Factory for creating configured instances of
SerializationSchema . |
TableFactory
A factory to create different table-related instances from string-based properties.
|
TableFormatFactory
A factory to create configured table format instances based on string-based properties.
|
TableFormatFactoryBase
Base class for
TableFormatFactory s. |
Class and Description |
---|
DecodingFormatFactory |
DeserializationFormatFactory
Factory for creating a
DecodingFormat for DeserializationSchema . |
DeserializationSchemaFactory
Factory for creating configured instances of
DeserializationSchema . |
DynamicTableFactory.Context
Provides catalog and session information describing the dynamic table to be accessed.
|
EncodingFormatFactory
Base interface for configuring an
EncodingFormat for a DynamicTableSink . |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
SerializationFormatFactory
Factory for creating a
EncodingFormat for SerializationSchema . |
SerializationSchemaFactory
Factory for creating configured instances of
SerializationSchema . |
TableFactory
A factory to create different table-related instances from string-based properties.
|
TableFormatFactory
A factory to create configured table format instances based on string-based properties.
|
TableFormatFactoryBase
Base class for
TableFormatFactory s. |
Class and Description |
---|
DecodingFormatFactory |
DeserializationFormatFactory
Factory for creating a
DecodingFormat for DeserializationSchema . |
DynamicTableFactory.Context
Provides catalog and session information describing the dynamic table to be accessed.
|
EncodingFormatFactory
Base interface for configuring an
EncodingFormat for a DynamicTableSink . |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
SerializationFormatFactory
Factory for creating a
EncodingFormat for SerializationSchema . |
Class and Description |
---|
DecodingFormatFactory |
DeserializationFormatFactory
Factory for creating a
DecodingFormat for DeserializationSchema . |
DynamicTableFactory.Context
Provides catalog and session information describing the dynamic table to be accessed.
|
EncodingFormatFactory
Base interface for configuring an
EncodingFormat for a DynamicTableSink . |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
SerializationFormatFactory
Factory for creating a
EncodingFormat for SerializationSchema . |
Class and Description |
---|
DecodingFormatFactory |
DeserializationFormatFactory
Factory for creating a
DecodingFormat for DeserializationSchema . |
DynamicTableFactory.Context
Provides catalog and session information describing the dynamic table to be accessed.
|
EncodingFormatFactory
Base interface for configuring an
EncodingFormat for a DynamicTableSink . |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
SerializationFormatFactory
Factory for creating a
EncodingFormat for SerializationSchema . |
Class and Description |
---|
BulkReaderFormatFactory
Base interface for configuring a
BulkFormat for file system connector. |
BulkWriterFormatFactory
Base interface for configuring a
BulkWriter.Factory for file system connector. |
DecodingFormatFactory |
DynamicTableFactory.Context
Provides catalog and session information describing the dynamic table to be accessed.
|
EncodingFormatFactory
Base interface for configuring an
EncodingFormat for a DynamicTableSink . |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
Class and Description |
---|
BulkReaderFormatFactory
Base interface for configuring a
BulkFormat for file system connector. |
BulkWriterFormatFactory
Base interface for configuring a
BulkWriter.Factory for file system connector. |
DecodingFormatFactory |
DynamicTableFactory.Context
Provides catalog and session information describing the dynamic table to be accessed.
|
EncodingFormatFactory
Base interface for configuring an
EncodingFormat for a DynamicTableSink . |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
Class and Description |
---|
StreamTableSinkFactory
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. |
TableFactory
A factory to create different table-related instances from string-based properties.
|
TableSinkFactory
A factory to create configured table sink instances in a batch or stream environment based on
string-based properties.
|
Class and Description |
---|
DynamicTableFactory
Base interface for configuring a dynamic table connector for an external storage system from
catalog and session information.
|
DynamicTableFactory.Context
Provides catalog and session information describing the dynamic table to be accessed.
|
DynamicTableSinkFactory
Creates a
DynamicTableSink instance from a CatalogTable and additional context
information. |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
Class and Description |
---|
StreamTableSinkFactory
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. |
TableFactory
A factory to create different table-related instances from string-based properties.
|
TableSinkFactory
A factory to create configured table sink instances in a batch or stream environment based on
string-based properties.
|
Class and Description |
---|
StreamTableSinkFactory
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. |
TableFactory
A factory to create different table-related instances from string-based properties.
|
TableSinkFactory
A factory to create configured table sink instances in a batch or stream environment based on
string-based properties.
|
Class and Description |
---|
StreamTableSinkFactory
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. |
StreamTableSourceFactory
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. |
TableFactory
A factory to create different table-related instances from string-based properties.
|
TableSinkFactory
A factory to create configured table sink instances in a batch or stream environment based on
string-based properties.
|
TableSourceFactory
A factory to create configured table source instances in a batch or stream environment based on
string-based properties.
|
Class and Description |
---|
DynamicTableFactory
Base interface for configuring a dynamic table connector for an external storage system from
catalog and session information.
|
DynamicTableFactory.Context
Provides catalog and session information describing the dynamic table to be accessed.
|
DynamicTableSinkFactory
Creates a
DynamicTableSink instance from a CatalogTable and additional context
information. |
DynamicTableSourceFactory
Creates a
DynamicTableSource instance from a CatalogTable and additional context
information. |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
Class and Description |
---|
DynamicTableFactory
Base interface for configuring a dynamic table connector for an external storage system from
catalog and session information.
|
DynamicTableFactory.Context
Provides catalog and session information describing the dynamic table to be accessed.
|
DynamicTableSinkFactory
Creates a
DynamicTableSink instance from a CatalogTable and additional context
information. |
DynamicTableSourceFactory
Creates a
DynamicTableSource instance from a CatalogTable and additional context
information. |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
Class and Description |
---|
TableFactory
A factory to create different table-related instances from string-based properties.
|
Class and Description |
---|
CatalogFactory
A factory to create configured catalog instances based on string-based properties.
|
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
FunctionDefinitionFactory
A factory to create
FunctionDefinition . |
TableFactory
A factory to create different table-related instances from string-based properties.
|
Class and Description |
---|
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
FunctionDefinitionFactory
A factory to create
FunctionDefinition . |
TableFactory
A factory to create different table-related instances from string-based properties.
|
Class and Description |
---|
CatalogFactory
A factory to create configured catalog instances based on string-based properties.
|
FunctionDefinitionFactory
A factory to create
FunctionDefinition . |
TableFactory
A factory to create different table-related instances from string-based properties.
|
Class and Description |
---|
ComponentFactory
A factory interface for components that enables further disambiguating in case there are multiple
matching implementations present.
|
TableFactory
A factory to create different table-related instances from string-based properties.
|
Class and Description |
---|
DecodingFormatFactory |
DeserializationFormatFactory
Factory for creating a
DecodingFormat for DeserializationSchema . |
DynamicTableFactory
Base interface for configuring a dynamic table connector for an external storage system from
catalog and session information.
|
DynamicTableFactory.Context
Provides catalog and session information describing the dynamic table to be accessed.
|
DynamicTableSourceFactory
Creates a
DynamicTableSource instance from a CatalogTable and additional context
information. |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
Class and Description |
---|
ComponentFactory
A factory interface for components that enables further disambiguating in case there are multiple
matching implementations present.
|
TableFactory
A factory to create different table-related instances from string-based properties.
|
Class and Description |
---|
ComponentFactory
A factory interface for components that enables further disambiguating in case there are multiple
matching implementations present.
|
DecodingFormatFactory |
DynamicTableFactory
Base interface for configuring a dynamic table connector for an external storage system from
catalog and session information.
|
DynamicTableFactory.Context
Provides catalog and session information describing the dynamic table to be accessed.
|
DynamicTableSinkFactory
Creates a
DynamicTableSink instance from a CatalogTable and additional context
information. |
DynamicTableSourceFactory
Creates a
DynamicTableSource instance from a CatalogTable and additional context
information. |
EncodingFormatFactory
Base interface for configuring an
EncodingFormat for a DynamicTableSink . |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
FactoryUtil.TableFactoryHelper
Helper utility for discovering formats and validating all options for a
DynamicTableFactory . |
FileSystemFormatFactory.ReaderContext
Deprecated.
|
TableFactory
A factory to create different table-related instances from string-based properties.
|
TableFormatFactory
A factory to create configured table format instances based on string-based properties.
|
TableSinkFactory
A factory to create configured table sink instances in a batch or stream environment based on
string-based properties.
|
TableSinkFactory.Context
Context of table sink creation.
|
TableSourceFactory
A factory to create configured table source instances in a batch or stream environment based on
string-based properties.
|
TableSourceFactory.Context
Context of table source creation.
|
Class and Description |
---|
DynamicTableFactory
Base interface for configuring a dynamic table connector for an external storage system from
catalog and session information.
|
DynamicTableFactory.Context
Provides catalog and session information describing the dynamic table to be accessed.
|
DynamicTableSinkFactory
Creates a
DynamicTableSink instance from a CatalogTable and additional context
information. |
DynamicTableSourceFactory
Creates a
DynamicTableSource instance from a CatalogTable and additional context
information. |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
FileSystemFormatFactory
Deprecated.
This interface has been replaced by
BulkReaderFormatFactory and BulkWriterFormatFactory . |
Class and Description |
---|
DecodingFormatFactory |
DeserializationFormatFactory
Factory for creating a
DecodingFormat for DeserializationSchema . |
DynamicTableFactory.Context
Provides catalog and session information describing the dynamic table to be accessed.
|
EncodingFormatFactory
Base interface for configuring an
EncodingFormat for a DynamicTableSink . |
Factory
Base interface for all kind of factories that create object instances from a list of key-value
pairs in Flink's Table & SQL API.
|
SerializationFormatFactory
Factory for creating a
EncodingFormat for SerializationSchema . |
Class and Description |
---|
ModuleFactory
A factory to create configured module instances based on string-based properties.
|
TableFactory
A factory to create different table-related instances from string-based properties.
|
Class and Description |
---|
ModuleFactory
A factory to create configured module instances based on string-based properties.
|
TableFactory
A factory to create different table-related instances from string-based properties.
|
Class and Description |
---|
ComponentFactory
A factory interface for components that enables further disambiguating in case there are multiple
matching implementations present.
|
TableFactory
A factory to create different table-related instances from string-based properties.
|
Class and Description |
---|
ComponentFactory
A factory interface for components that enables further disambiguating in case there are multiple
matching implementations present.
|
TableFactory
A factory to create different table-related instances from string-based properties.
|
Class and Description |
---|
BatchTableSinkFactory
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. |
StreamTableSinkFactory
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. |
TableFactory
A factory to create different table-related instances from string-based properties.
|
TableSinkFactory
A factory to create configured table sink instances in a batch or stream environment based on
string-based properties.
|
Class and Description |
---|
BatchTableSourceFactory
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. |
StreamTableSourceFactory
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. |
TableFactory
A factory to create different table-related instances from string-based properties.
|
TableSourceFactory
A factory to create configured table source instances in a batch or stream environment based on
string-based properties.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.