in bundle_adb_360/src/c_Incremental/11_IncDataGeneration.py [0:0]
def createRestaurants(noofrows=2, minaddress=1, maxaddress=addressesNoOfRows) -> DataFrame:
fs = Fieldset(locale=Locale.EN, i=noofrows)
df = pd.DataFrame.from_dict({
"restaurantId": fs("increment"),
"restaurantName" : fs("person.name"),
"noOfTables" : fs("numeric.integer_number", start=5, end=50),
"staffCount" : fs("numeric.integer_number", start=2, end=30),
"phone": fs("telephone", mask="+1 (###) #5#-7#9#"),
"email": fs("email"),
"fkaddress" : fs("numeric.integer_number", start=minaddress, end=maxaddress)
})
return spark.createDataFrame(df)