功能介绍

按行写出到文件

参数说明

名称 中文名称 描述 类型 是否必须？ 默认值
filePath 文件路径 文件路径 String ✓
overwriteSink 是否覆写已有数据 是否覆写已有数据 Boolean false
numFiles 文件数目 文件数目 Integer 1

脚本示例

运行脚本

  1. URL = "http://alink-testdata.cn-hangzhou.oss.aliyun-inc.com/csv/iris_vec.csv";
  2. SCHEMA_STR = "features string, label double"
  3. data = CsvSourceStreamOp().setFilePath(URL).setSchemaStr(SCHEMA_STR)
  5. sink = TextSinkSteamOp().setFilePath('/tmp/text.csv')
  6. data.select('features').link(sink)
  7. StreamOperator.execute()