• 功能介绍
  • 参数说明
  • 脚本示例
    • 运行脚本

    功能介绍

    按行写出到文件

    参数说明

    名称 中文名称 描述 类型 是否必须？ 默认值
    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 = CsvSourceBatchOp().setFilePath(URL).setSchemaStr(SCHEMA_STR)
    5. sink = TextSinkBatchOp().setFilePath('/tmp/text.csv')
    6. data.select('features').link(sink)
    7. BatchOperator.execute()