Package org.apache.storm.starter.streams
package org.apache.storm.starter.streams
-
ClassDescriptionAn example that illustrates the global aggregate.An example that demonstrates the usage of
Stream.branch(Predicate[])
to split a stream into multiple branches based on predicates.An example that shows the usage ofPairStream.groupByKeyAndWindow(Window)
andPairStream.reduceByKeyAndWindow(Reducer, Window)
.An example that demonstrates the usage ofPairStream.join(PairStream)
to join multiple streams.A stateful word count that usesPairStream.updateStateByKey(StateUpdater)
to save the counts in a key value state.An example that usesStream.stateQuery(StreamState)
to query the stateAn example that illustrates the usage of typed tuples (TupleN<..>) andTupleValueMappers
.A windowed word count example.An example that computes word counts and finally emits the results to an external bolt (sink).