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!