如何遍曆火花和scala dataframe嗎?

[Pierrek20]

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

我輸入dataframe看起來像這樣:

指數桶美聯社站rssi的時間

-84.0 0 1 0 1 11 1 0 1 3 0。-67.02 1 0 1 4 0。-82.03 1 0 1 2 -68.04 1 0 2 5 0。-68.05 2今日1 3 0。-83.06今日2 1 2 -82.07 2今日1 4 0。-80.0今日8 2 1 1 -72.0今日9 2 2 5 0。-72.010 3 00:30 1 4 0。-85.011日00:30 1 3 -77.012 3 00:30 1 2 -70.013 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並選擇值如果這樣做

謝謝你的回答

[匿名]

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

[夏娃]

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

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