Description

Transform data type from Triple to Kv.

Parameters

Name Description Type Required? Default Value
handleInvalid Strategy to handle unseen token String “ERROR”
tripleColumnCol Name of the triple column col String
tripleValueCol Name of the triple value column String
reservedCols Names of the columns to be retained in the output table String[] null
kvCol Name of the KV column String
kvColDelimiter Delimiter used between key-value pairs when data in the input table is in sparse format String “,”
kvValDelimiter Delimiter used between keys and values when data in the input table is in sparse format String “:”
tripleRowCol Name of the triple row column String

Script Example

Code

  1. import numpy as np
  2. import pandas as pd
  3. data = np.array([[1,'f1',1.0],[1,'f2',2.0],[2,'f1',4.0],[2,'f2',8.0]])
  4. df = pd.DataFrame({"row":data[:,0], "col":data[:,1], "val":data[:,2]})
  5. data = dataframeToOperator(df, schemaStr="row double, col string, val double",op_type="batch")
  6. op = TripleToKvBatchOp()\
  7. .setTripleRowCol("row").setTripleColCol("col").setTripleValCol("val")\
  8. .setReservedCols(["row"]).setKvCol("kv")\
  9. .linkFrom(data)
  10. op.print()

Results

  1. |row|kv|
  2. |--|--------------|
  3. |1|f0:1.0,f1:2.0|
  4. |2|f0:4.0,f1:8.0|