Class RollingTopWords


public class RollingTopWords extends ConfigurableTopology
This topology does a continuous computation of the top N words that the topology has seen in terms of cardinality. The top N computation is done in a completely scalable way, and a similar approach could be used to compute things like trending topics or trending images on Twitter.
  • Method Details

    • main

      public static void main(String[] args) throws Exception
    • run

      protected int run(String[] args)
      Submits (runs) the topology.

      Usage: "RollingTopWords [topology-name] [-local]"

      By default, the topology is run locally under the name "slidingWindowCounts".

      Examples: ``` # Runs in remote/cluster mode, with topology name "production-topology" $ storm jar storm-starter-jar-with-dependencies.jar org.apache.storm.starter.RollingTopWords production-topology ```

      Specified by:
      run in class ConfigurableTopology
      args - First positional argument (optional) is topology name, second positional argument (optional) defines whether to run the topology locally ("-local") or remotely, i.e. on a real cluster.