Friday, December 30, 2016

Storm

  • controlling the rate data flows into a topology
    • builder.setSpout(...).setMaxSpoutPending(N)
    • N > the total prallelism
  • metrics-collecting API
    • use it for testing
  • configuration
    • topology.stats.sample.rate
      • set to 1 for testing and verifying
Posted by at

No comments:

Post a Comment

Note: Only a member of this blog may post a comment.

Subscribe to: Post Comments (Atom)