Collibra DQ User Guide


We've moved! To improve customer experience, the Collibra Data Quality User Guide has moved to the Collibra Documentation Center as part of the Collibra Data Quality 2022.11 release. To ensure a seamless transition, will remain accessible, but the DQ User Guide is now maintained exclusively in the Documentation Center.


Run against a file using -json. Additionally, options are available for -flatten and -multiline. This is helpful for nested and various formats.
-ds json_file_example \
-f s3a://bucket_name/file.json \
-h \
-master spark:// \
-json \
-flatten \
Automatic flattening will infer schema and explode all structs, arrays, and map types.

Using Spark SQL

-ds public.json_sample \
-lib "/opt/owl/drivers/postgres/" \
-h \
-master spark://
-q "select * from public.jason"
-rd "2021-01-17"
-driver "org.postgresql.Driver"
-cxn postgres-gcp
-fq "select \
get_json_object(col_3, '$.data._customer_name') AS `data_customer_name` , \
get_json_object(col_3, '$.data._active_customer') AS `data_active_customer` , \
from dataset "
Pass in the path to Owls' -fq parameter. This is great for mixed data types within a database. For example, if you store JSON data as a string or a blob among other data.
// Flatten
val colArr = new JsonReader().flattenSchema(df.schema)
colArr.foreach(x => println(x))
This Owl utility will traverse the entire schema and print the proper get JSON object spark sql strings. You can use this instead of typing each query statement into the command line -fq parameter as seen above.

Using Owl Libraries

import com.owl.common.options._
import com.owl.core.util.OwlUtils
import com.owl.core.activity2.JsonReader
val connProps = Map (
"driver" -> "org.postgresql.Driver",
"user" -> "user",
"password" -> "password",
"url" -> "jdbc:postgresql://",
"dbtable" -> ""
// Spark
var rdd ="jdbc").options(connProps)$"col_name").map(x=>x.toString()).rdd
var df =
// Flatten
val colArr = new JsonReader().flattenSchema(df.schema)
val flatJson = _*)
// Opts
val dataset = "json_example"
val runId = s"2021-01-14"
val opt = new OwlOptions()
opt.dataset = dataset
opt.runId = runId
opt.datasetSafeOff = true
// Owlcheck
OwlUtils.resetDataSource("","5432/postgres","user","pass", spark)
val owl = OwlUtils.OwlContext(flatJson, opt)


This uses Owl's JsonReader to do the heavy lifting.