Package org.apache.storm.starter.streams
package org.apache.storm.starter.streams
-
ClassesClassDescriptionAn 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).