reactiveSpark: Reactive spark reader
In sparklyr: R Interface to Apache Spark
reactiveSpark R Documentation
Reactive spark reader
Description
Given a spark object, returns a reactive data source for the contents
of the spark object. This function is most useful to read Spark streams.
Usage
reactiveSpark(x, intervalMillis = 1000, session = NULL)
Arguments
x
An object coercable to a Spark DataFrame.
intervalMillis
Approximate number of milliseconds to wait to retrieve
updated data frame. This can be a numeric value, or a function that returns
a numeric value.
session
The user session to associate this file reader with, or NULL if
none. If non-null, the reader will automatically stop when the session ends.
sparklyr documentation built on May 29, 2024, 2:58 a.m.
R Package Documentation
Browse R Packages
We want your feedback!
Note that we can't provide technical support on individual packages. You should contact the package authors for that.
| reactiveSpark | R Documentation |
Reactive spark reader
Description
Given a spark object, returns a reactive data source for the contents of the spark object. This function is most useful to read Spark streams.
Usage
reactiveSpark(x, intervalMillis = 1000, session = NULL)
Arguments
x |
An object coercable to a Spark DataFrame. |
intervalMillis |
Approximate number of milliseconds to wait to retrieve updated data frame. This can be a numeric value, or a function that returns a numeric value. |
session |
The user session to associate this file reader with, or NULL if none. If non-null, the reader will automatically stop when the session ends. |
R Package Documentation
Browse R Packages
We want your feedback!
Note that we can't provide technical support on individual packages. You should contact the package authors for that.
Embedding an R snippet on your website
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.