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

    功能介绍

    按libsvm格式写出到文件

    参数说明

    名称 中文名称 描述 类型 是否必须？ 默认值
    filePath 文件路径 文件路径 String ✓
    overwriteSink 是否覆写已有数据 是否覆写已有数据 Boolean false
    vectorCol 向量列名 向量列对应的列名 String ✓
    labelCol 标签列名 输入表中的标签列名 String ✓

    脚本示例

    运行脚本

    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. LibSvmSinkStreamOp().setFilePath('/tmp/libsvm.csv') \
    6.     .setLabelCol("label").setVectorCol("features").setOverwriteSink(True).linkFrom(data)
    7. StreamOperator.execute()