public class CsvTableSink extends Object implements BatchTableSink<Row>, StreamTableSink<Row>
TableSink
to emit data as CSV files.
Constructor and Description |
---|
CsvTableSink(String path,
String fieldDelim) |
Modifier and Type | Method and Description |
---|---|
protected TableSink<Row> |
copy()
Return a deep copy of the
TableSink . |
void |
emitDataSet(DataSet<Row> dataSet)
Emits the DataSet.
|
void |
emitDataStream(DataStream<Row> dataStream)
Emits the DataStream.
|
TypeInformation<Row> |
getOutputType()
Return the type expected by this
TableSink . |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
configure, fieldNames, fieldTypes, getFieldNames, getFieldTypes
public void emitDataSet(DataSet<Row> dataSet)
BatchTableSink
emitDataSet
in interface BatchTableSink<Row>
public void emitDataStream(DataStream<Row> dataStream)
StreamTableSink
emitDataStream
in interface StreamTableSink<Row>
protected TableSink<Row> copy()
TableSink
TableSink
.public TypeInformation<Row> getOutputType()
TableSink
TableSink
.
This type should depend on the types returned by getFieldNames
.
getOutputType
in interface TableSink<Row>
TableSink
.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.