View Stream

Opens a Shiny gadget to visualize the given stream.

stream_view(stream, ...)

Arguments

stream

The stream to visualize.

...

Additional optional arguments.

Examples

if (FALSE) { 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() }