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 demonstrates the usage of
PairStream.join(PairStream)to join multiple streams.A stateful word count that uses
PairStream.updateStateByKey(StateUpdater)to save the counts in a key value state.An example that uses
Stream.stateQuery(StreamState)to query the stateAn example that illustrates the usage of typed tuples (TupleN<..>) and
TupleValueMappers.A windowed word count example.An example that computes word counts and finally emits the results to an external bolt (sink).