def METHOD_NAME(dataGraph="http://rack001/data"):
    '''
    Creating the CDR is done in two phases the first CDR only has the identifiers so that it will create all the objects
    the second phase has all the data, by splitting this into two phase ths allows the lookups to succeed regardless of load order
    '''
    global __EvidenceDir__, __Evidence__, __ingestionIdentifier__
    Add.PROV_S.ACTIVITY(identifier=__ingestionIdentifier__,endedAtTime=str(datetime.now()).split(".")[0])
    __Evidence__.write(__EvidenceDir__, 
               pretty_print=True,
               xml_declaration=True,
               encoding='UTF-8')
    cdrFiles = list()
    xsdSpec = getXsd()
    outputDir = __EvidenceDir__.replace(".xml","")
    if not os.path.exists(outputDir):
        os.makedirs(outputDir)
    for thing in xsdSpec:
        headers = xsdSpec[thing]
        usedHeaders = list(["identifier", "dataInsertedBy_identifier"]) # all CDRs will have at least these columns
        data = etree.parse(__EvidenceDir__)
        root = data.getroot()
        if root.find(thing)!=None:
            cdrFiles.append(thing)
            with open(os.path.join(outputDir,thing+"1.csv"), 'w', newline='', encoding="utf-8") as outFile:
                outwriter = csv.writer(outFile, delimiter=',', quotechar='"', quoting=csv.QUOTE_MINIMAL)
                outwriter.writerow(["identifier"])
                loaded = list()
                for c in root.iter(thing):
                    if c.find("identifier") is not None:
                        if c.find("identifier").text not in loaded:
                            outwriter.writerow([c.find("identifier").text])
                            loaded.append(c.find("identifier").text)
                    # Check to see if the header item 
                    for k in headers:
                        if c.find(k) is not None:
                            if k not in usedHeaders:
                                usedHeaders.append(k)
                    else:
                        log("Identifier not found.")
            print("Found the following data for "+thing+":", str(usedHeaders))
            with open(os.path.join(outputDir,thing+"2.csv"), 'w', newline='', encoding="utf-8") as outFile:
                outwriter = csv.writer(outFile, delimiter=',', quotechar='"', quoting=csv.QUOTE_MINIMAL)
                outwriter.writerow(usedHeaders)
                for c in root.iter(thing):
                    rowData = list()
                    thingData = {}
                    for k in usedHeaders:
                        thingData[k] = c.find(k)
                    dataString = ""        
                    for k in usedHeaders:
                        if thingData[k] is not None:
                            rowData.append(thingData[k].text)
                        elif k == "dataInsertedBy_identifier":
                            rowData.append(__ingestionIdentifier__)
                        else:
                            rowData.append("")
                    outwriter.writerow(rowData)
    with open(os.path.join(outputDir,"import.yaml"), 'w', encoding="utf-8") as outFile:
        outFile.write('''data-graph: "{}"