Java streamlet examples (#2501)

* move examples from other directory

* fix build errors; add serialVersionUid to serializable classes

* rename to original topology name

* continue adding comments to example topologies

* comments for the ImpressionsAndClicks topology

* finish adding comments

* fix build error

* add example clone topology

* add comments for streamlet clone example

* add formatted output topology

* add smart watch topology (for reduce functions)

* improve logging for impressions and clicks topology

* updates to pulsar topology

* add new repartition topology

* fix broken examples build

* fix indentation

* remove star import statements

* fix import order

* fix remaining java syntax issues

* more comments

* add private constructor for StreamletUtils

* more syntax fixes

* fix final formatting issues

* remove some unnecessary logging statements

* re-add windowed word count topology

* add newline at end of file

* change time windows to stay within max pending value

* Removed KVStreamlet

* Fix build

* Fixed checkstyle

* Fix bug in JoinTest

* Fixed jointest

* modifications to ads/impressions topology

* rework impressions/clicks topology for API changes

* fix smart watch topology

* fix windowed word count topology

* fix unused imports

* add comments to repartition topology

* remove repartition from integer topology

* change description in join operation
14 files changed
tree: a4c72b2d0aa457c662c97ebf9bb061aaa1c1e879
  1. config/
  2. deploy/
  3. docker/
  4. examples/
  5. heron/
  6. heronpy/
  7. integration_test/
  8. release/
  9. scripts/
  10. storm-compatibility/
  11. storm-compatibility-examples/
  12. third_party/
  13. tools/
  14. vagrant/
  15. website/
  16. .gitignore
  17. .gitmodules
  18. .travis.yml
  19. ADOPTERS.md
  20. bazel_configure.py
  21. LICENSE
  22. NOTICE
  23. README.md
  24. WORKSPACE
README.md

Build Status

Heron

Heron is realtime analytics platform developed by Twitter. It is the direct successor of Apache Storm, built to be backwards compatible with Storm's topology API but with a wide array of architectural improvements.

For more information:

Update

We recently merged updates to run Heron natively using Mesos in AWS, Mesos/Aurora in AWS, and locally on a laptop.

We also added beta testing for Apache YARN support using Apache REEF, in addition to the Simple Linux Utility for Resource Management (SLURM).

We are working to add support for Mesosphere DC/OS and Kubernetes. We will continue to post updates as we progress.

Documentation

The official documentation for Heron is located at heronstreaming.io. To contribute to documentation, build and run the documentation locally. More information can be found in the documentation README.