取消
顯示的結果
而不是尋找
你的意思是:

如何遍曆火花和scala dataframe嗎?

Pierrek20
新的因素

你好!我菜鳥引發scala中,這是我的問題:tk的提前你的幫助

我輸入dataframe看起來像這樣:

指數桶美聯社站rssi的時間

-84.0 0 1 0 1 1

1 1 0 1 3 0。-67.0

2 1 0 1 4 0。-82.0

3 1 0 1 2 -68.0

4 1 0 2 5 0。-68.0

5 2今日1 3 0。-83.0

6今日2 1 2 -82.0

7 2今日1 4 0。-80.0

今日8 2 1 1 -72.0

今日9 2 2 5 0。-72.0

10 3 00:30 1 4 0。-85.0

11日00:30 1 3 -77.0

12 3 00:30 1 2 -70.0

13 3 00:30 2 5 0。-70.0

我想寫一個算法:

為每個ap為每個站對於每個桶如果rssi(以前的水桶)< rssi(桶)打印信息

我不知道如何做到這一點在scala中……

我開始是:

主要對象coveralg {def (args:數組(String)) {val火花= SparkSession.builder () .appName (coveralg) .getOrCreate進口spark.implicits ()。_ val input_data = spark.read.format (csv) .option(“標題”、“true”) .load (args (0))}}

但我不知道如何實現遍曆dataframe並選擇值如果這樣做

謝謝你的回答

2回答2

匿名
不適用

嗨,你介意給我解釋你想的代碼做什麼,我不確定我理解。之後我將高興地提供一個建議,在火花可能會是什麼樣子:slightly_smiling_face:

夏娃
新的貢獻者三世

循環並不總是必要的,我總是使用這個foreach方法,像下麵這樣:

aps.collect ()。foreach(行= > <做>)

歡迎來到磚社區:讓學習、網絡和一起慶祝

加入我們的快速增長的數據專業人員和專家的80 k +社區成員,準備發現,幫助和合作而做出有意義的聯係。

點擊在這裏注冊今天,加入!

參與令人興奮的技術討論,加入一個組與你的同事和滿足我們的成員。

Baidu
map