<html> <div style=“font-size:xx-large; font-weight: 900;”>07.03.2024 Donnerstag</div> </html>
SparkTester.getStatsAboutMultipleIntervals()import org.apache.commons.io.IOUtils
import java.net.URL
import java.nio.charset.Charset
// Zeppelin creates and injects sc (SparkContext) and sqlContext (HiveContext or SqlContext)
// So you don't need create them manually
// load bank data
val bankText = sc.parallelize(
IOUtils.toString(
new URL("file:///z-vol/small_ablauf_228Unter_data.csv"),
Charset.forName("utf8")).split("\n"))
case class CsvEntry(time: String, value: Float)
val myMap = bankText.map(s => s.split("\\|"))
System.out.println(myMap.first()(1))
val bank = myMap.filter(s => s(0) != "time").map(
// val bank = myMap.map(
// s => CsvEntry(s(0), "s(1)")
s => CsvEntry(s(0), s(1))
).toDF()
bank.registerTempTable("bank")
//bank.orderBy(col("age").desc()).show()
//val bank2 = bank.orderBy(col("age").desc())
val bank2 = bank.orderBy(col("time").desc)
bank2.show()
SparkTester.getStatsAboutMultipleIntervals()Task properly