Learn R Programming

RStorm (version 1.0)

Simulate and Develop Streaming Processing

Description

While streaming processing provides opportunities to deal with extremely large and ever growing data sets in (near) real time, the development of streaming algorithms for complex models is often cumbersome: the software packages that facilitate streaming processing in production environments do not provide statisticians with the simulation, estimation, and plotting tools they are used to. Developers of streaming algorithms would thus benefit from the flexibility of [R] to create, plot and compute data while developing streaming algorithms. Package RStorm implements a streaming architecture modeled on Storm for easy development and testing of streaming algorithms in [R]. RStorm is not intended as a production package, but rather a development tool for streaming algorithms.

Copy Link

Version

Install

install.packages('RStorm')

Monthly Downloads

30

Version

1.0

License

GPL-2

Maintainer

Maurits Kaptein

Last Published

November 29th, 2018

Functions in RStorm (1.0)

Topology

Function to create a topology
RStorm-package

Simulate a Streaming Process in [R]
GetHashNames

Function to retrieve the names of locally stored objects in the stream.
sentences

Sentences of the first section of the paper by Student Introducing the T-Test.
SetHash

Function to store a data.frame during a stream.
RStorm

Main function to run a stream.
GetTrackNames

Function to retrieve the names of all tracked objects using SetTrack
GetTrack

Function to retrieve objects stored using the SetTrack functionality during a stream.
Tuple

Function to create an object of type Tuple to emit down a stream.
TrackRow

Function to store the value of some object in the stream over time.
Emit

Function to emit a Tuple along the stream. The emitted data x should be a single row of a data.frame.
GetHashList

Function to retrieve a list of locally stored object resulting from the stream.
GetHash

Function to retrieve objects stored locally during the running of the stream.
RStorm.env

Environment used by RStorm for internal storage of objects.
AddBolt

Function to add a Bolt to a Topology object to specify a stream.
AddFinalize

Function to add a finalize function to a Topology
Bolt

Function to create a Bolt object to add to a stream
ChangeSpout

Function to change the Spout of a Topology
ShowFinalize

Function to display the name of the finalize function.