TrackRow: Function to store the value of some object in the stream over...
In RStorm: Simulate and Develop Streaming Processing

Description Usage Arguments Value Author(s) See Also Examples

Within bolts in a RStorm stream the TrackRow function can be used to store the state of variables at that point during the stream. The TrackRow function will store values incrementally during the stream. Thus, TrackRow enables one to store a set of parameter at each event in a Bolt.

1	TrackRow(name, row)

`name`	a string with the name of the object that is stored.
`row`	a single row data.frame containing the parameters that are supposed to be tracked over time. See example.

TRUE if the row is correctly stored.

Maurits Kaptein

Topology, GetTrack, GetTrackNames

# Create a topology with a simple spout
topology <- Topology(data.frame(x=c(1:10)))

# Define the bolt and add it 
computeSum <- function(x, ...){
	sum <- GetHash("sum")
	if(is.data.frame(sum)){
		x <- sum + (x[1])
	}
	SetHash("sum", x)
	TrackRow("sum", data.frame(x=x))
}
topology <- AddBolt(topology, Bolt(computeSum))

# Run the stream
result <- RStorm(topology)

# Insepct the result over the timepoints in the stream
GetTrack("sum", result)