stream_find

0th

Percentile

Find Stream

Finds and returns a stream based on the stream's identifier.

Usage
stream_find(sc, id)
Arguments
sc

The associated Spark connection.

id

The stream identifier to find.

Aliases
  • stream_find
Examples
# NOT RUN {
sc <- spark_connect(master = "local")
sdf_len(sc, 10) %>%
  spark_write_parquet(path = "parquet-in")

stream <- stream_read_parquet(sc, "parquet-in") %>%
 stream_write_parquet("parquet-out")

stream_id <- stream_id(stream)
stream_find(sc, stream_id)
# }
# NOT RUN {
# }
Documentation reproduced from package sparklyr, version 1.0.4, License: Apache License 2.0 | file LICENSE

Community examples

Looks like there are no examples yet.