Package org.apache.storm.starter.trident

Class Summary

Class	Description
DebugMemoryMapState<T>
DebugMemoryMapState.Factory
TridentHBaseWindowingStoreTopology	Sample application of trident windowing which uses HBaseWindowsStoreFactory’s store for storing tuples in window.
TridentMapExample	A simple example that demonstrates the usage of Stream.map(MapFunction) and Stream.flatMap(FlatMapFunction) functions.
TridentMinMaxOfDevicesTopology	This class demonstrates different usages of * Stream.minBy(String) * Stream.maxBy(String) operations on trident Stream.
TridentMinMaxOfVehiclesTopology	This class demonstrates different usages of * Stream.minBy(String, Comparator) * Stream.min(Comparator) * Stream.maxBy(String, Comparator) * Stream.max(Comparator) operations on trident Stream.
TridentReach
TridentReach.ExpandList
TridentReach.One
TridentReach.StaticSingleKeyMapState
TridentReach.StaticSingleKeyMapState.Factory
TridentWindowingInmemoryStoreTopology	Sample application of trident windowing which uses inmemory store for storing tuples in window.
TridentWordCount
TridentWordCount.Split