if (FALSE) {
library(sparklyr)
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_csv("iris-out/")
stream_render(stream)
stream_stop(stream)
}
Run the code above in your browser using DataLab