R/sdf_schema_tree.R

sdf_schema_tree <- function (object){
  jobj <- spark_dataframe(object)
  schema <- invoke(jobj, "schema")
  fields <- invoke(schema, "fields")
  obj <- spark_jobj(schema)
  schemaString <- invoke(obj, "treeString")
  cat(schemaString)
}
environment(sdf_schema_tree) <- asNamespace('sparklyr')
catlain/sparklyrfun documentation built on May 20, 2019, 3:29 p.m.