reactiveSpark

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.

R interface to Apache Spark, a fast and general
engine for big data processing, see <https://spark.apache.org/>. This
package supports connecting to local and remote Apache Spark clusters,
provides a 'dplyr' compatible back-end, and provides an interface to
Spark's built-in machine learning algorithms.

Edgar Ruiz

sparklyr

R Interface to Apache Spark

Javier Luraschi

Kevin Kuo

Kevin Ushey

JJ Allaire

Samuel Macedo

Hossein Falaki

Lu Wang

Andy Zhang

Yitao Li

Jozef Hajnala

Maciej Szymkiewicz

Wil Davis

 RStudio

 The Apache Software Foundation

reactiveSpark function

<dl><dt>x</dt>
<dd>An object coercable to a Spark DataFrame.</dd>
<dt>intervalMillis</dt>
<dd>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.</dd>
<dt>session</dt>
<dd>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.</dd></dl>

Arguments

Reactive spark reader — reactiveSpark

<dl>

<dt>x</dt>
<dd>An object coercable to a Spark DataFrame.</dd>


<dt>intervalMillis</dt>
<dd>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.</dd>


<dt>session</dt>
<dd>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.</dd>

</dl>

Reactive spark reader

reactiveSpark: Reactive spark reader

Description

Usage

Arguments