adp.ingest.schema

Extends schema related functionality from pyspark to support nested data structures

Functions

flatten_df(orig_df)

Flatten the StructField columns of a dataframe

Classes

StructTypeGraph()

Create a graph from a nested Dataframe schema and allows for filtering on the original dataframe.