SparkR Structured Streaming - výpis do konzoly nefunguje

Programovacie jazyky, rady, poradňa...
alvar
Amateur
Amateur
Príspevky: 34
Registrovaný: 25 sep 2014, 20:02

SparkR Structured Streaming - výpis do konzoly nefunguje

Príspevok od používateľa alvar »

Čaute, mám problém s výpisom do konzoly (funkcia write.stream). Nižšie je môj kód:

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)
premenná "query" by mi mala vypísať počet mien, no na výstupe dostanem len toto:

Kód: Vybrať všetko

StreamingQuery
>
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!
Napísať odpoveď