Interface StreamTableSinkFactory<T>
-
- Type Parameters:
T
- type of records that the factory consumes
- All Superinterfaces:
TableFactory
,TableSinkFactory<T>
- All Known Implementing Classes:
CsvAppendTableSinkFactory
,CsvBatchTableSinkFactory
@Deprecated @Internal public interface StreamTableSinkFactory<T> extends TableSinkFactory<T>
Deprecated.This interface has been replaced byDynamicTableSinkFactory
. The new interface creates instances ofDynamicTableSink
. See FLIP-95 for more information.A factory to create configured table sink instances in a streaming environment based on string-based properties. See alsoTableSinkFactory
for more information.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.flink.table.legacy.factories.TableSinkFactory
TableSinkFactory.Context
-
-
Method Summary
All Methods Instance Methods Default Methods Deprecated Methods Modifier and Type Method Description default StreamTableSink<T>
createStreamTableSink(Map<String,String> properties)
Deprecated.TableSinkFactory.Context
contains more information, and already contains table schema too.default TableSink<T>
createTableSink(Map<String,String> properties)
Deprecated.Only create stream table sink.-
Methods inherited from interface org.apache.flink.table.legacy.factories.TableFactory
requiredContext, supportedProperties
-
Methods inherited from interface org.apache.flink.table.legacy.factories.TableSinkFactory
createTableSink, createTableSink
-
-
-
-
Method Detail
-
createStreamTableSink
@Deprecated default StreamTableSink<T> createStreamTableSink(Map<String,String> properties)
Deprecated.TableSinkFactory.Context
contains more information, and already contains table schema too. Please useTableSinkFactory.createTableSink(Context)
instead.Creates and configures aStreamTableSink
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 interfaceTableSinkFactory<T>
- Parameters:
properties
- normalized properties describing a table sink.- Returns:
- the configured table sink.
-
-