Spark sparksql中使用自定義函式

2021-10-03 18:14:00 字數 648 閱讀 8955

**中分別用物件導向和面向函式兩種寫法自定義了兩個函式:

low2up: 小寫轉大寫

up2low: 大寫轉小寫

import org.apache.spark.sql.types.stringtype

import org.apache.spark.sql.

object sparksqlfunction

},stringtype)

//5. 另外一種更加方便的構建udf方式 (面向函式寫法)

sparksession.udf.register("up2low",(x:string)=>x.tolowercase)

//6. 呼叫sparksql測試udf函式

sparksession.sql("select value from t_udf").show()

sparksession.sql("select low2up(value) from t_udf").show()

sparksession.sql("select up2low(value) from t_udf").show()

//7. 關閉連線

sparksession.stop()

}}

程序中使用委託(程序中使用程序)

delegate void setlablevisible bool bl 隱藏控制項的委託 設定進度控制項的隱藏顯示 委託 private void setvisible bool bl else this setvisible false 隱藏狀態控制項 當在程序中需要呼叫另外乙個程序的控制項的...

在BroadcastReceiver中使用通知

broadcastreceiver通常需要向使用者傳達發生的某件事或狀態,可以使用通知欄通知提醒使用者。建立通知的過程 1 建立乙個合適的通知 2 獲得通知管理器的許可權 3 向通知管理器傳送通知 建立通知時,需要包含以下幾個部分 1 要顯示的圖示 2 顯示的提示文字 3 傳送它的時間 然後使用co...

php中使用mysql介紹 PHP中使用MySQL

mysql資料庫的擴充套件 擴充套件庫基本功能相似,用法基本相同,會增加一些新的特性 mysqli擴充套件庫 只能對mysql資料庫操作 pdo擴充套件 可以操作很多態別的資料庫 wamp下修改mysql資料庫密碼 三者在建立連線上的比較 pdo需要四個引數,除了資料庫管理員名稱 密碼 host 還...