# 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).

Copyright © 2021 The Apache Software Foundation. All rights reserved.