你好!我菜鳥引發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並選擇值如果這樣做
謝謝你的回答