GetTrackNames: Function to retrieve the names of all tracked objects using...
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. The current GetTrackNames function allows to inspect all the tracked objects of a stream by passing the RStorm result object.

1	GetTrackNames(x)

`x`	a RStorm result object.

A list of names of the tracked objects during the stream.

Maurits Kaptein

See Also: TrackRow, SetHash, GetHash, GetTrack

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

	# Add a bolt to the topology
	computeSum <- function(x, ...){
		sum <- GetHash("sum")
		if(is.data.frame(sum)){
			x <- sum + (x[1])
		}
		SetHash("sum", x)
		# Track the current state during the stream:
		TrackRow("sum", data.frame(x=x))
	}
	topology <- AddBolt(topology, Bolt(computeSum))

	# Run the stream
	result <- RStorm(topology)

	# Inspect the sums during the stream
	GetTrackNames(result)