standardize.py contains the udf function "create_address_json_for_request_udf"
def create_address_json_for_request(
line1_address , line2_address , city , state , postcode , country , tracking_idc , environment ,
source_system_name
):
ship_to_address = {
"line1Address": line1_address ,
"line2Address": line2_address ,
"city": city ,
"state": state ,
"zip": postcode ,
"country": country ,
}
customer_address_element = {
"trackingIdc": tracking_idc ,
"environment": environment ,
"sourceSystemName": source_system_name ,
"shipToAddress": ship_to_address ,
}
return str (customer_address_element)
create_address_json_for_request_udf = udf (create_address_json_for_request , StringType ())
when i am importing above udf from a different file,i am getting error
ImportError: cannot import name 'create_address_json_for_request_udf'
from standardize import create_address_json_for_request_udf
spark.sparkContext.addFile("standardize.py")
