CSV文件导出 (CsvSinkStreamOp)

Java 类名：com.alibaba.alink.operator.stream.sink.CsvSinkStreamOp

Python 类名：CsvSinkStreamOp

功能介绍

将输入数据写出到CSV文件。

参数说明

名称	中文名称	描述	类型	是否必须？	取值范围	默认值
filePath	文件路径	文件路径	String	✓
fieldDelimiter	字段分隔符	字段分隔符	String			“,”
numFiles	文件数目	文件数目	Integer			1
overwriteSink	是否覆写已有数据	是否覆写已有数据	Boolean			false
quoteChar	引号字符	引号字符	Character			“"”
rowDelimiter	行分隔符	行分隔符	String			“\n”

代码示例

Python 代码

filePath = 'https://alink-test-data.oss-cn-hangzhou.aliyuncs.com/iris.csv'
schema = 'sepal_length double, sepal_width double, petal_length double, petal_width double, category string'
csvSource = CsvSourceStreamOp()\
    .setFilePath(filePath)\
    .setSchemaStr(schema)\
    .setFieldDelimiter(",")
csvSink = CsvSinkStreamOp()\
    .setFilePath('~/csv_test_s.txt')

csvSource.link(csvSink)

StreamOperator.execute()

Java 代码

import com.alibaba.alink.operator.stream.StreamOperator;
import com.alibaba.alink.operator.stream.sink.CsvSinkStreamOp;
import com.alibaba.alink.operator.stream.source.CsvSourceStreamOp;
import org.junit.Test;

public class CsvSinkStreamOpTest {
	@Test
	public void testCsvSinkStreamOp() throws Exception {
		String filePath = "https://alink-test-data.oss-cn-hangzhou.aliyuncs.com/iris.csv";
		String schema
			= "sepal_length double, sepal_width double, petal_length double, petal_width double, category string";
		CsvSourceStreamOp csvSource = new CsvSourceStreamOp()
			.setFilePath(filePath)
			.setSchemaStr(schema)
			.setFieldDelimiter(",");
		CsvSinkStreamOp csvSink = new CsvSinkStreamOp()
			.setFilePath("~/csv_test_s.txt");

		csvSource.link(csvSink);

		StreamOperator.execute();
	}
}