Package org.apache.storm.starter.streams

Class Summary

Class	Description
AggregateExample	An example that illustrates the global aggregate
BranchExample	An example that demonstrates the usage of Stream.branch(Predicate[]) to split a stream into multiple branches based on predicates.
GroupByKeyAndWindowExample	An example that shows the usage of PairStream.groupByKeyAndWindow(Window) and PairStream.reduceByKeyAndWindow(Reducer, Window)
JoinExample	An example that demonstrates the usage of PairStream.join(PairStream) to join multiple streams.
StatefulWordCount	A stateful word count that uses PairStream.updateStateByKey(StateUpdater) to save the counts in a key value state.
StateQueryExample	An example that uses Stream.stateQuery(StreamState) to query the state
TypedTupleExample	An example that illustrates the usage of typed tuples (TupleN<..>) and TupleValueMappers.
WindowedWordCount	A windowed word count example
WordCountToBolt	An example that computes word counts and finally emits the results to an external bolt (sink)