stream_generate_test
From sparklyr v1.0.4
by Javier Luraschi
Generate Test Stream
Generates a local test stream, useful when testing streams locally.
Usage
stream_generate_test(df = rep(1:1000), path = "source",
distribution = floor(10 + 1e+05 * stats::dbinom(1:20, 20, 0.5)),
iterations = 50, interval = 1)Arguments
- df
The data frame used as a source of rows to the stream, will be cast to data frame if needed. Defaults to a sequence of one thousand entries.
- path
Path to save stream of files to, defaults to
"source".- distribution
The distribution of rows to use over each iteration, defaults to a binomial distribution. The stream will cycle through the distribution if needed.
- iterations
Number of iterations to execute before stopping, defaults to fifty.
- interval
The inverval in seconds use to write the stream, defaults to one second.
Details
This function requires the callr package to be installed.
Community examples
Looks like there are no examples yet.