stream_find: Find Stream

Description Usage Arguments Examples

View source: R/stream_operations.R

Description

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

Usage

1
stream_find(sc, id)

Arguments

sc

The associated Spark connection.

id

The stream identifier to find.

Examples

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
## 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)

## End(Not run)

sparklyr documentation built on June 17, 2021, 5:06 p.m.