# Package org.apache.storm.starter.streams

package org.apache.storm.starter.streams

- Related Packages
  Package
  Description
  org.apache.storm.starter
  org.apache.storm.starter.bolt
  org.apache.storm.starter.spout
  org.apache.storm.starter.tools
  org.apache.storm.starter.trident
- Classes
  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).