磚

當我使用SQL代碼,像“create table myTable (column1字符串,column2字符串)使用csv選項(“分隔符”= ',','標題' = '真的')位置pathToCsv”從一個csv文件中創建一個表存儲在一個文件夾內Azure數據包含湖……

主筆記本是調用一個孩子筆記本使用dbutils.notebook.run (“PathToChildnotebook”)。孩子筆記本定義一個用戶定義函數(UDF)和使用spark.udf.register注冊它。然而,當孩子筆記本完成運行……

如果我有兩個dataframes df_target df_source,我能做df_target.as (t) .merge (df_source.as (“s”),“s.id = t.id”) .whenMatched () .updateAll () .whenNotMatched.insertAll.execute ()。當我試著上麵的代碼中,我得到了錯誤“合並不是的一員……

如果我創建一個表使用下麵的代碼:創建表如果不存在jdbcTableusing org.apache.spark.sql。jdbcoptions (url“sql_server_url”數據表“sqlserverTable”,用戶的“用戶名”,密碼“密碼”)jdbcTable總是會自動同步……