org.apache.flink.table.factories

Interface TableSinkFactory<T>

Type Parameters:

T - type of records that the factory produces

All Superinterfaces:

TableFactory

All Known Subinterfaces:

BatchTableSinkFactory<T>, StreamTableSinkFactory<T>

All Known Implementing Classes:

CsvAppendTableSinkFactory, CsvBatchTableSinkFactory, Elasticsearch6UpsertTableSinkFactory, Elasticsearch7UpsertTableSinkFactory, ElasticsearchUpsertTableSinkFactoryBase, HBaseTableFactory, HiveTableFactory, JDBCTableSourceSinkFactory, Kafka010TableSourceSinkFactory, Kafka011TableSourceSinkFactory, Kafka08TableSourceSinkFactory, Kafka09TableSourceSinkFactory, KafkaTableSourceSinkFactory, KafkaTableSourceSinkFactoryBase

@PublicEvolving
public interface TableSinkFactory<T>
extends TableFactory

A factory to create configured table sink instances in a batch or stream environment based on string-based properties. See also TableFactory for more information.

Method Summary

Modifier and Type	Method and Description
TableSink<T>	createTableSink(Map<String,String> properties) Creates and configures a TableSink using the given properties.
default TableSink<T>	createTableSink(ObjectPath tablePath, CatalogTable table) Creates and configures a TableSink based on the given CatalogTable instance.

Methods inherited from interface org.apache.flink.table.factories.TableFactory

requiredContext, supportedProperties

Method Detail

createTableSink

TableSink<T> createTableSink(Map<String,String> properties)

Creates and configures a TableSink using the given properties.

Parameters:

properties - normalized properties describing a table sink.

Returns:

the configured table sink.

createTableSink

default TableSink<T> createTableSink(ObjectPath tablePath,
                                     CatalogTable table)

Creates and configures a TableSink based on the given CatalogTable instance.

Parameters:

tablePath - path of the given CatalogTable

table - CatalogTable instance.

Returns:

the configured table sink.