pyapacheatlas.readers.reader.Reader.parse_column_mapping#

Reader.parse_column_mapping(json_rows)#

Take in ColumnMapping dictionaries and create the mutated Process entities to be uploaded. All referenced entities should already exist and be identified by their type and qualifiedName.

Creates process entities with only the columnMapping field filled in.

Parameters

json_rows (list(dict(str,str))) – A list of dicts that contain the converted rows of your update lineage spreadsheet.

Returns

An AtlasTypeDef with entityDefs for the provided rows.

Return type

dict(str, list(dict))