library(sparklyr)
sc <- spark_connect(master = "local")
dir.create("iris-in")
write.csv(iris, "iris-in/iris.csv", row.names = FALSE)
stream_read_csv(sc, "iris-in/") %>%
stream_write_csv("iris-out/") %>%
stream_view() %>%
stream_stop() View Stream
R/stream_view.R
stream_view
Description
Opens a Shiny gadget to visualize the given stream.
Usage
stream_view(stream, ...) Arguments
| Arguments | Description |
|---|---|
| stream | The stream to visualize. |
| … | Additional optional arguments. |