def createAddressTable()

in bundle_adb_360/src/b_historical/1_createhistbronzeparquets.py [0:0]

• 11 lines of code
• 1 McCabe index (conditional complexity)

def createAddressTable(noofrows=2) -> DataFrame:
    fs = Fieldset(locale=Locale.EN, i=noofrows)

    df = pd.DataFrame.from_dict({
        "addressid": fs("increment"),
        "state" : fs("address.state"),
        "streetNo" : fs("address.street_number"),
        "street" : fs("address.street_name"),
        "city"  : fs("address.city"),
        "zip" : fs("address.zip_code")
    })

    return spark.createDataFrame(df)