Package org.apache.storm.flux.examples

Class WordCountClient

java.lang.Object

org.apache.storm.flux.examples.WordCountClient

public class WordCountClient
extends Object

Connects to the 'WordCount' HBase table and prints counts for each word.

Assumes you have run (or are running) the YAML topology definition in simple_hbase.yaml

You will also need to modify `src/main/resources/hbase-site.xml` to point to your HBase instance, and then repackage with `mvn package`. This is a known issue.

Constructor Summary

Constructors

Constructor	Description
WordCountClient()

Method Summary

Modifier and Type	Method	Description
static void	main(String[] args)	Entry point for WordCountClient.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

WordCountClient

public WordCountClient()

Method Details

main

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

Entry point for WordCountClient.

Parameters:

args - command line arguments

Throws:

Exception - if an unexpected error occurs