Java 类名：com.alibaba.alink.operator.stream.dataproc.AppendIdStreamOp
Python 类名：AppendIdStreamOp

功能介绍

将表附加ID列

参数说明

| 名称 | 中文名称 | 描述 | 类型 | 是否必须？ | 取值范围 | 默认值 | | —- | —- | —- | —- | —- | —- | —- |

| idCol | ID列名 | ID列名 | String | | | “append_id” |

代码示例

Python 代码

  1. from pyalink.alink import *
  3. import pandas as pd
  5. useLocalEnv(1)
  7. df_data = pd.DataFrame([
  8.     ['Ohio', 2000, 1.5],
  9.     ['Ohio', 2001, 1.7],
  10.     ['Ohio', 2002, 3.6],
  11.     ['Nevada', 2001, 2.4],
  12.     ['Nevada', 2002, 2.9],
  13.     ['Nevada', 2003,3.2]
  14. ])
  16. stream_data = StreamOperator.fromDataframe(df_data, schemaStr='f1 string, f2 bigint, f3 double')
  18. AppendIdStreamOp().linkFrom(stream_data).print()
  20. StreamOperator.execute()

运行结果

  1. ['f1', 'f2', 'f3', 'append_id']
  2. ['Ohio', 2000, 1.5, 0]
  3. ['Ohio', 2001, 1.7, 1]
  4. ['Ohio', 2002, 3.6, 2]
  5. ['Nevada', 2001, 2.4, 3]
  6. ['Nevada', 2002, 2.9, 4]
  7. ['Nevada', 2003, 3.2, 5]