Java 类名:com.alibaba.alink.operator.batch.dataproc.format.TripleToJsonBatchOp
Python 类名:TripleToJsonBatchOp

功能介绍

将数据格式从 Triple 转成 Json
三元组转换为json,setTripleRowCol 设置数据行信息的列名,这一列值相同的数据,会被合并成一个数据
setTripleColumnCol 设置为json中key所在的列名
setTripleValueCol 设置为json中value所在的列名

参数说明

名称 中文名称 描述 类型 是否必须? 取值范围 默认值
jsonCol JSON列名 JSON列的列名 String
tripleColumnCol 三元组结构中列信息的列名 三元组结构中列信息的列名 String
tripleValueCol 三元组结构中数据信息的列名 三元组结构中数据信息的列名 String
handleInvalid 解析异常处理策略 解析异常处理策略,可选为ERROR(抛出异常)或者SKIP(输出NULL) String “ERROR”, “SKIP” “ERROR”
tripleRowCol 三元组结构中行信息的列名 三元组结构中行信息的列名 String null

代码示例

Python 代码

  1. from pyalink.alink import *
  2. import pandas as pd
  3. useLocalEnv(1)
  4. df = pd.DataFrame([
  5. [1,'f1',1.0],
  6. [1,'f2',2.0],
  7. [2,'f1',4.0],
  8. [2,'f2',8.0]])
  9. data = BatchOperator.fromDataframe(df, schemaStr="row double, col string, val double")
  10. op = TripleToJsonBatchOp()\
  11. .setTripleRowCol("row")\
  12. .setTripleColumnCol("col")\
  13. .setTripleValueCol("val")\
  14. .setJsonCol("json")\
  15. .linkFrom(data)
  16. op.print()

Java 代码

  1. import org.apache.flink.types.Row;
  2. import com.alibaba.alink.operator.batch.BatchOperator;
  3. import com.alibaba.alink.operator.batch.dataproc.format.TripleToJsonBatchOp;
  4. import com.alibaba.alink.operator.batch.source.MemSourceBatchOp;
  5. import org.junit.Test;
  6. import java.util.Arrays;
  7. import java.util.List;
  8. public class TripleToJsonBatchOpTest {
  9. @Test
  10. public void testTripleToJsonBatchOp() throws Exception {
  11. List <Row> df = Arrays.asList(
  12. Row.of(1, "f1", 1.0),
  13. Row.of(1, "f2", 2.0),
  14. Row.of(2, "f1", 4.0),
  15. Row.of(2, "f2", 8.0)
  16. );
  17. BatchOperator <?> data = new MemSourceBatchOp(df, "row int, col string, val double");
  18. BatchOperator <?> op = new TripleToJsonBatchOp()
  19. .setTripleRowCol("row")
  20. .setTripleColumnCol("col")
  21. .setTripleValueCol("val")
  22. .setJsonCol("json")
  23. .linkFrom(data);
  24. op.print();
  25. }
  26. }

运行结果

| row | json | | —- | —- |

| 1 | {“f1”:”1.0”,”f2”:”2.0”} |

| 2 | {“f1”:”4.0”,”f2”:”8.0”} |