SparkR Structured Streaming - výpis do konzoly nefunguje

C,C++,C#

Moderátori: psichac, Moderátori

alvar
Nový člen
Nový člen
Príspevky: 58
Dátum registrácie: 16 Sep 2014, 17:25

SparkR Structured Streaming - výpis do konzoly nefunguje

Príspevok od používateľa alvar » 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:

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!
0

  • Podobné témy
    Odpovedí
    Zobrazení
    Posledný príspevok