Package org.apache.storm.elasticsearch.bolt

Class EsIndexTopology

java.lang.Object

org.apache.storm.elasticsearch.bolt.EsIndexTopology

public final class EsIndexTopology
extends Object

Demonstrates an ElasticSearch Storm topology.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	EsIndexTopology.UserDataSpout	The user data spout.

Method Summary

Modifier and Type	Method	Description
static void	main(String[] args)	The example's main method.

Methods inherited from class java.lang.Object

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

Method Details

main

public static void main(String[] args)
                 throws AlreadyAliveException,
InvalidTopologyException,
AuthorizationException

The example's main method.

Parameters:

args - the command line arguments

Throws:

AlreadyAliveException - if the topology is already started

InvalidTopologyException - if the topology is invalid

AuthorizationException - if the topology authorization fails