pyapacheatlas.readers.reader.Reader#

class pyapacheatlas.readers.reader.Reader(configuration, guid=- 1000)#

The base Reader with functionality that supports python dicts.

__init__(configuration, guid=- 1000)#

Creates the base Reader with functionality that supports python dicts.

Parameters

  • configuration (ReaderConfiguration) – A list of dicts containing at least Entity TypeName and name

  • guid (int) – A negative integer to use as the starting counter for entities created by this reader.

Methods

__init__(configuration[, guid])

Creates the base Reader with functionality that supports python dicts.

make_template()

Generate a template for the given reader.

parse_bulk_entities(json_rows[, contacts_func])

Create an AtlasEntityWithExtInfo consisting of entities and their attributes for the given json_rows.

parse_classification_defs(json_rows)

Create an AtlasTypeDef consisting of classificationDefs for the given json_rows.

parse_column_mapping(json_rows)

Take in ColumnMapping dictionaries and create the mutated Process entities to be uploaded.

parse_entity_defs(json_rows)

Create an AtlasTypeDef consisting of entityDefs for the given json_rows.

parse_finegrain_column_lineage(json_rows, …)

param json_rows

parse_table_lineage(json_rows)

Converts the “tables” information into Atlas Entities for Target, Source, and Process types.

parse_update_lineage(json_rows)

Take in UpdateLineage dictionaries and create the mutated Process entities to be uploaded.

Attributes

TEMPLATE_HEADERS