Description

Transform data type from Triple to Csv.

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
csvCol Name of the CSV column String ✓
schemaStr Formatted schema String ✓
csvFieldDelimiter Field delimiter String “,”
quoteChar quote char Character “\””
tripleRowCol Name of the triple row column String

Script Example

Code

  1. import numpy as np
  2. import pandas as pd
  5. data = np.array([[1,'f1',1.0],[1,'f2',2.0],[2,'f1',4.0],[2,'f2',8.0]])
  6. df = pd.DataFrame({"row":data[:,0], "col":data[:,1], "val":data[:,2]})
  7. data = dataframeToOperator(df, schemaStr="row double, col string, val double",op_type="batch")
  10. op = TripleToCsvBatchOp()\
  11.     .setTripleRowCol("row").setTripleColCol("col").setTripleValCol("val")\
  12.     .setReservedCols(["row"]).setCsvCol("csv").setSchemaStr("f1 string, f2 string")\
  13.     .linkFrom(data)
  14. op.print()

Results

row csv
1 1.0,2.0
2 4.0,8.0