Hortonworks Docs
»
»
Also available as:
Developing Apache Storm Applications
Developing Apache Storm Applications
Core Storm Concepts
Spouts
Bolts
Stream Groupings
Topologies
Processing Reliability
Workers, Executors, and Tasks
Parallelism
Core Storm Example: RollingTopWords Topology
Trident Concepts
Introductory Example: Trident Word Count
Trident Operations
Filters
Functions
Trident Aggregations
CombinerAggregator
ReducerAggregator
Aggregator
Trident State
Trident Spouts
Achieving Exactly-Once Messaging in Trident
Further Reading about Trident
Moving Data Into and Out of a Storm Topology
Implementing Windowing Computations on Data Streams
Understanding Sliding and Tumbling Windows
Implementing Windowing in Core Storm
Understanding Tuple Timestamps and Out-of-Order Tuples
Understanding Watermarks
Understanding the "at-least-once" Guarantee
Saving the Window State
Implementing Windowing in Trident
Trident Windowing Implementation Details
Sample Trident Application with Windowing
Implementing State Management
Checkpointing
Recovery
Guarantees
Implementing Custom Actions: IStateful Bolt Hooks
Implementing Custom States
Implementing Stateful Windowing
Sample Topology with Saved State
© 2012-2019, Hortonworks, Inc.
Document licensed under the
Creative Commons Attribution ShareAlike 4.0 License
.
Hortonworks.com
|
Documentation
|
Support
|
Community
