功能介绍

数据结构转换，将多列数据（可以是向量列也可以是数值列）转化为一列向量数据。

参数说明

名称 中文名称 描述 类型 是否必须？ 默认值
handleInvalid 如何处理无效值 可以选择skip：跳过，error：报错抛异常，keep：保留。 String “error”
selectedCols 选择的列名 计算列对应的列名列表 String[] ✓
outputCol 输出结果列列名 输出结果列列名，必选 String ✓
reservedCols 算法保留列名 算法保留列 String[] null

脚本示例

脚本代码

  1. data = np.array([["0", "$6$1:2.0 2:3.0 5:4.3", "3.0 2.0 3.0"],\
  2. ["1", "$8$1:2.0 2:3.0 7:4.3", "3.0 2.0 3.0"],\
  3. ["2", "$8$1:2.0 2:3.0 7:4.3", "2.0 3.0"]])
  4. df = pd.DataFrame({"id" : data[:,0], "c0" : data[:,1], "c1" : data[:,2]})
  5. data = dataframeToOperator(df, schemaStr="id string, c0 string, c1 string",op_type="stream")
  7. res = VectorAssemblerStreamOp()\
  8.             .setSelectedCols(["c0", "c1"])\
  9.             .setOutputCol("table2vec")
  10. res.linkFrom(data).print()
  11. StreamOperator.execute()

脚本运行结果

VectorAssembler(stream) - 图1