RStorm: Simulate and Develop Streaming Processing in [R]

Share:

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.

Author
Maurits Kaptein
Date of publication
2013-08-28 12:25:31
Maintainer
Maurits Kaptein <maurits@mauritskaptein.com>
License
GPL-2
Version
0.902

View on CRAN

Man pages

AddBolt
Function to add a 'Bolt' to a 'Topology' object to specify a...
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
Emit
Function to emit a 'Tuple' along the stream. The emitted data...
GetHash
Function to retrieve objects stored locally during the...
GetHashList
Function to retrieve a list of locally stored object...
GetHashNames
Function to retrieve the names of locally stored objects in...
GetTrack
Function to retrieve objects stored using the 'SetTrack'...
GetTrackNames
Function to retrieve the names of all tracked objects using...
RStorm.env
Environment used by RStorm for internal storage of objects.
RStream
Main function to run a stream.
RStream-package
Simulate a Streaming Process in [R]
sentences
Sentences of the first section of the paper by Student...
SetHash
Function to store a 'data.frame' during a stream.
ShowFinalize
Function to display the name of the finalize function.
Topology
Function to create a topology
TrackRow
Function to store the value of some object in the stream over...
Tuple
Function to create an object of type 'Tuple' to emit down a...

Files in this package

RStorm
RStorm/NAMESPACE
RStorm/data
RStorm/data/sentences.RData
RStorm/R
RStorm/R/topology.R
RStorm/R/rstorm.R
RStorm/R/bolt.R
RStorm/R/tuple.R
RStorm/R/hashmap.R
RStorm/R/tracking.R
RStorm/MD5
RStorm/DESCRIPTION
RStorm/man
RStorm/man/RStream-package.Rd
RStorm/man/ShowFinalize.Rd
RStorm/man/Emit.Rd
RStorm/man/GetHashList.Rd
RStorm/man/GetHash.Rd
RStorm/man/Tuple.Rd
RStorm/man/RStream.Rd
RStorm/man/GetTrack.Rd
RStorm/man/GetTrackNames.Rd
RStorm/man/ChangeSpout.Rd
RStorm/man/AddFinalize.Rd
RStorm/man/sentences.Rd
RStorm/man/Bolt.Rd
RStorm/man/Topology.Rd
RStorm/man/AddBolt.Rd
RStorm/man/TrackRow.Rd
RStorm/man/GetHashNames.Rd
RStorm/man/SetHash.Rd
RStorm/man/RStorm.env.Rd