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 and Description
WordCountClient()

Method Summary

Modifier and Type	Method and 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 Detail

WordCountClient

public WordCountClient()

Method Detail

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