Interface TableSinkFactory<T>
-
- Type Parameters:
T
- type of records that the factory produces
- All Superinterfaces:
TableFactory
- All Known Subinterfaces:
StreamTableSinkFactory<T>
- All Known Implementing Classes:
CsvAppendTableSinkFactory
,CsvBatchTableSinkFactory
@Deprecated @Internal public interface TableSinkFactory<T> extends TableFactory
Deprecated.This interface has been replaced byDynamicTableSinkFactory
. The new interface consumes internal data structures. See FLIP-95 for more information.A factory to create configured table sink instances in a batch or stream environment based on string-based properties. See alsoTableFactory
for more information.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interface
TableSinkFactory.Context
Deprecated.Context of table sink creation.
-
Method Summary
All Methods Instance Methods Default Methods Deprecated Methods Modifier and Type Method Description default TableSink<T>
createTableSink(Map<String,String> properties)
Deprecated.TableSinkFactory.Context
contains more information, and already contains table schema too.default TableSink<T>
createTableSink(ObjectPath tablePath, CatalogTable table)
Deprecated.TableSinkFactory.Context
contains more information, and already contains table schema too.default TableSink<T>
createTableSink(TableSinkFactory.Context context)
Deprecated.Creates and configures aTableSink
based on the givenTableSinkFactory.Context
.-
Methods inherited from interface org.apache.flink.table.legacy.factories.TableFactory
requiredContext, supportedProperties
-
-
-
-
Method Detail
-
createTableSink
@Deprecated default TableSink<T> createTableSink(Map<String,String> properties)
Deprecated.TableSinkFactory.Context
contains more information, and already contains table schema too. Please usecreateTableSink(Context)
instead.Creates and configures aTableSink
using the given properties.- Parameters:
properties
- normalized properties describing a table sink.- Returns:
- the configured table sink.
-
createTableSink
@Deprecated default TableSink<T> createTableSink(ObjectPath tablePath, CatalogTable table)
Deprecated.TableSinkFactory.Context
contains more information, and already contains table schema too. Please usecreateTableSink(Context)
instead.Creates and configures aTableSink
based on the givenCatalogTable
instance.- Parameters:
tablePath
- path of the givenCatalogTable
table
-CatalogTable
instance.- Returns:
- the configured table sink.
-
createTableSink
default TableSink<T> createTableSink(TableSinkFactory.Context context)
Deprecated.Creates and configures aTableSink
based on the givenTableSinkFactory.Context
.- Parameters:
context
- context of this table sink.- Returns:
- the configured table sink.
-
-