Simulate and Develop Streaming Processing


[Up] [Top]

Documentation for package ‘RStorm’ version 1.0

Help Pages

RStorm-package Simulate a Streaming Process in [R]
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
Emit Function to emit a 'Tuple' along the stream. The emitted data 'x' should be a single row of a 'data.frame'.
GetHash Function to retrieve objects stored locally during the running of the stream.
GetHashList Function to retrieve a list of locally stored object resulting from the stream.
GetHashNames Function to retrieve the names of locally stored objects in the stream.
GetTrack Function to retrieve objects stored using the 'SetTrack' functionality during a stream.
GetTrackNames Function to retrieve the names of all tracked objects using 'SetTrack'
is.Bolt Function to create a 'Bolt' object to add to a stream
is.RStorm Main function to run a stream.
is.Topology Function to create a topology
is.Tuple Function to create an object of type 'Tuple' to emit down a stream.
plot.RStorm Main function to run a stream.
plot.Topology Function to create a topology
print.RStorm Main function to run a stream.
print.Topology Function to create a topology
RStorm Main function to run a stream.
RStorm.env Environment used by RStorm for internal storage of objects.
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.
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 time.
Tuple Function to create an object of type 'Tuple' to emit down a stream.