org.apache.flink.table.sinks

类 CsvTableSink

java.lang.Object

org.apache.flink.table.sinks.CsvTableSink

所有已实现的接口:

AppendStreamTableSink<org.apache.flink.types.Row>, StreamTableSink<org.apache.flink.types.Row>, org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row>

已过时。

The legacy CSV connector has been replaced by FileSink. It is kept only to support tests for the legacy connector stack.

@Internal
 @Deprecated
public class CsvTableSink
extends Object
implements AppendStreamTableSink<org.apache.flink.types.Row>

A simple TableSink to emit data as CSV files.

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	CsvTableSink.CsvFormatter 已过时。 Formats a Row into a String with fields separated by the field delimiter.

构造器概要

构造器

构造器和说明
CsvTableSink(String path) 已过时。 A simple TableSink to emit data as CSV files using comma as field delimiter, with default parallelism and write mode.
CsvTableSink(String path, String fieldDelim) 已过时。 A simple TableSink to emit data as CSV files, with default parallelism and write mode.
CsvTableSink(String path, String fieldDelim, int numFiles, org.apache.flink.core.fs.FileSystem.WriteMode writeMode) 已过时。 A simple TableSink to emit data as CSV files.
CsvTableSink(String path, String fieldDelim, int numFiles, org.apache.flink.core.fs.FileSystem.WriteMode writeMode, String[] fieldNames, org.apache.flink.table.types.DataType[] fieldTypes) 已过时。 A simple TableSink to emit data as CSV files.

方法概要

限定符和类型	方法和说明
org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row>	configure(String[] fieldNames, org.apache.flink.api.common.typeinfo.TypeInformation<?>[] fieldTypes) 已过时。
org.apache.flink.streaming.api.datastream.DataStreamSink<?>	consumeDataStream(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.types.Row> dataStream) 已过时。 Consumes the DataStream and return the sink transformation DataStreamSink.
org.apache.flink.table.types.DataType	getConsumedDataType() 已过时。
org.apache.flink.table.api.TableSchema	getTableSchema() 已过时。

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 org.apache.flink.table.sinks.TableSink

getFieldNames, getFieldTypes, getOutputType

构造器详细资料

CsvTableSink

public CsvTableSink(String path,
                    String fieldDelim,
                    int numFiles,
                    org.apache.flink.core.fs.FileSystem.WriteMode writeMode,
                    String[] fieldNames,
                    org.apache.flink.table.types.DataType[] fieldTypes)

已过时。

A simple TableSink to emit data as CSV files.

参数:

path - The output path to write the Table to.

fieldDelim - The field delimiter

numFiles - The number of files to write to

writeMode - The write mode to specify whether existing files are overwritten or not.

fieldNames - The field names of the table to emit.

fieldTypes - The field types of the table to emit.

CsvTableSink

public CsvTableSink(String path,
                    String fieldDelim,
                    int numFiles,
                    org.apache.flink.core.fs.FileSystem.WriteMode writeMode)

已过时。

A simple TableSink to emit data as CSV files.

参数:

path - The output path to write the Table to.

fieldDelim - The field delimiter

numFiles - The number of files to write to

writeMode - The write mode to specify whether existing files are overwritten or not.

CsvTableSink

public CsvTableSink(String path)

已过时。

A simple TableSink to emit data as CSV files using comma as field delimiter, with default parallelism and write mode.

参数:

path - The output path to write the Table to.

CsvTableSink

public CsvTableSink(String path,
                    String fieldDelim)

已过时。

A simple TableSink to emit data as CSV files, with default parallelism and write mode.

参数:

path - The output path to write the Table to.

fieldDelim - The field delimiter

方法详细资料

consumeDataStream

public org.apache.flink.streaming.api.datastream.DataStreamSink<?> consumeDataStream(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.types.Row> dataStream)

已过时。

从接口复制的说明: StreamTableSink

Consumes the DataStream and return the sink transformation DataStreamSink. The returned DataStreamSink will be used to set resources for the sink operator.

指定者:

consumeDataStream 在接口中 StreamTableSink<org.apache.flink.types.Row>

configure

public org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row> configure(String[] fieldNames,
                                                                                    org.apache.flink.api.common.typeinfo.TypeInformation<?>[] fieldTypes)

已过时。

指定者:

configure 在接口中 org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row>

getConsumedDataType

public org.apache.flink.table.types.DataType getConsumedDataType()

已过时。

指定者:

getConsumedDataType 在接口中 org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row>

getTableSchema

public org.apache.flink.table.api.TableSchema getTableSchema()

已过时。

指定者:

getTableSchema 在接口中 org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row>