SparkR Structured Streaming - výpis do konzoly nefunguje
Napísané: 06 Jan 2020, 19:53
Čaute, mám problém s výpisom do konzoly (funkcia write.stream). Nižšie je môj kód:
premenná "query" by mi mala vypísať počet mien, no na výstupe dostanem len toto:
V priečinku mám vytvorené súbory vo formáte csv, oddelené čiarkami a v nich nahodené nejaké mená a čísla.
V čom by mohla byť chyba? Vďaka za pomoc!
Kód: Vybrať všetko
library(SparkR)
sparkR.session(appName = "File Test Streaming")
schema <- structType(structField("name", "string"), structField("age", "integer"))
csvDF <- read.stream("csv", path = "C:/Users/42194/Desktop/spark", schema = schema, sep = ",")
sucetMien <- count(groupBy(csvDF, "name"))
sucetMien
query <- write.stream(sucetMien, "console", outputMode = "complete")
query
csvDF
awaitTermination(query)
Kód: Vybrať všetko
StreamingQuery
>
V čom by mohla byť chyba? Vďaka za pomoc!