@PublicEvolving public class CsvBatchTableSinkFactory extends CsvTableSinkFactoryBase implements BatchTableSinkFactory<Row>
CsvTableSink
in a batch environment.Constructor and Description |
---|
CsvBatchTableSinkFactory() |
Modifier and Type | Method and Description |
---|---|
BatchTableSink<Row> |
createBatchTableSink(Map<String,String> properties)
Creates and configures a
BatchTableSink using the given properties. |
createTableSink, requiredContext, supportedProperties
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createTableSink
createTableSink
requiredContext, supportedProperties
public BatchTableSink<Row> createBatchTableSink(Map<String,String> properties)
BatchTableSinkFactory
BatchTableSink
using the given properties.createBatchTableSink
in interface BatchTableSinkFactory<Row>
properties
- normalized properties describing a table sink.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.