Package org.apache.flink.table.sinks
Class CsvAppendTableSinkFactory
- java.lang.Object
-
- org.apache.flink.table.sinks.CsvTableSinkFactoryBase
-
- org.apache.flink.table.sinks.CsvAppendTableSinkFactory
-
- All Implemented Interfaces:
StreamTableSinkFactory<Row>
,TableFactory
,TableSinkFactory<Row>
@Internal @Deprecated public class CsvAppendTableSinkFactory extends CsvTableSinkFactoryBase implements StreamTableSinkFactory<Row>
Deprecated.The legacy CSV connector has been replaced byFileSink
. It is kept only to support tests for the legacy connector stack.Factory base for creating configured instances ofCsvTableSink
in a stream environment.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.flink.table.legacy.factories.TableSinkFactory
TableSinkFactory.Context
-
-
Constructor Summary
Constructors Constructor Description CsvAppendTableSinkFactory()
Deprecated.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description StreamTableSink<Row>
createStreamTableSink(Map<String,String> properties)
Deprecated.Creates and configures aStreamTableSink
using the given properties.Map<String,String>
requiredContext()
Deprecated.Specifies the context that this factory has been implemented for.-
Methods inherited from class org.apache.flink.table.sinks.CsvTableSinkFactoryBase
createTableSink, supportedProperties
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.flink.legacy.table.factories.StreamTableSinkFactory
createTableSink
-
Methods inherited from interface org.apache.flink.table.legacy.factories.TableFactory
supportedProperties
-
Methods inherited from interface org.apache.flink.table.legacy.factories.TableSinkFactory
createTableSink, createTableSink
-
-
-
-
Method Detail
-
requiredContext
public Map<String,String> requiredContext()
Deprecated.Description copied from interface:TableFactory
Specifies the context that this factory has been implemented for. The framework guarantees to only match for this factory if the specified set of properties and values are met.Typical properties might be: - connector.type - format.type
Specified property versions allow the framework to provide backwards compatible properties in case of string format changes: - connector.property-version - format.property-version
An empty context means that the factory matches for all requests.
- Specified by:
requiredContext
in interfaceTableFactory
- Overrides:
requiredContext
in classCsvTableSinkFactoryBase
-
createStreamTableSink
public StreamTableSink<Row> createStreamTableSink(Map<String,String> properties)
Deprecated.Description copied from interface:StreamTableSinkFactory
Creates and configures aStreamTableSink
using the given properties.- Specified by:
createStreamTableSink
in interfaceStreamTableSinkFactory<Row>
- Parameters:
properties
- normalized properties describing a table sink.- Returns:
- the configured table sink.
-
-