# NOT RUN {
sc <- spark_connect(master = "local")
dir.create("iris-in")
write.csv(iris, "iris-in/iris.csv", row.names = FALSE)
stream <- stream_read_csv(sc, "iris-in") %>% stream_write_memory()
stop_stream(stream)
# }
# NOT RUN {
# }
Run the code above in your browser using DataCamp Workspace