Package org.apache.flink.table.sinks
Class CsvBatchTableSinkFactory
- java.lang.Object
-
- org.apache.flink.table.sinks.CsvTableSinkFactoryBase
-
- org.apache.flink.table.sinks.CsvBatchTableSinkFactory
-
- All Implemented Interfaces:
StreamTableSinkFactory<Row>
,TableFactory
,TableSinkFactory<Row>
@Internal @Deprecated public class CsvBatchTableSinkFactory 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 batch environment.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.flink.table.legacy.factories.TableSinkFactory
TableSinkFactory.Context
-
-
Constructor Summary
Constructors Constructor Description CsvBatchTableSinkFactory()
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.-
Methods inherited from class org.apache.flink.table.sinks.CsvTableSinkFactoryBase
createTableSink, requiredContext, 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
requiredContext, supportedProperties
-
Methods inherited from interface org.apache.flink.table.legacy.factories.TableSinkFactory
createTableSink, createTableSink
-
-
-
-
Method Detail
-
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.
-
-