org.apache.flink.table.factories

Interface StreamTableSinkFactory<T>

Type Parameters:

T - type of records that the factory consumes

All Superinterfaces:

TableFactory, TableSinkFactory<T>

All Known Implementing Classes:

CsvAppendTableSinkFactory, Elasticsearch6UpsertTableSinkFactory, Elasticsearch7UpsertTableSinkFactory, ElasticsearchUpsertTableSinkFactoryBase, HBase1TableFactory, HBase2TableFactory, JdbcTableSourceSinkFactory, KafkaTableSourceSinkFactory, KafkaTableSourceSinkFactoryBase

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.

@Deprecated
 @PublicEvolving
public interface StreamTableSinkFactory<T>
extends TableSinkFactory<T>

A factory to create configured table sink instances in a streaming environment based on string-based properties. See also TableSinkFactory for more information.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.factories.TableSinkFactory

TableSinkFactory.Context

Method Summary

Modifier and Type	Method and Description
default StreamTableSink<T>	createStreamTableSink(Map<String,String> properties) Deprecated. Context contains more information, and already contains table schema too. Please use TableSinkFactory.createTableSink(Context) instead.
default TableSink<T>	createTableSink(Map<String,String> properties) Deprecated. Only create stream table sink.

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

createTableSink, createTableSink

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

requiredContext, supportedProperties

Method Detail

createStreamTableSink

@Deprecated
default StreamTableSink<T> createStreamTableSink(Map<String,String> properties)

Deprecated. Context contains more information, and already contains table schema too. Please use TableSinkFactory.createTableSink(Context) instead.

Creates and configures a StreamTableSink using the given properties.

Parameters:

properties - normalized properties describing a table sink.

Returns:

the configured table sink.

createTableSink

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

Deprecated.

Only create stream table sink.

Specified by:

createTableSink in interface TableSinkFactory<T>

Parameters:

properties - normalized properties describing a table sink.

Returns:

the configured table sink.