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 and Description
static class	EsIndexTopology.UserDataSpout The user data spout.

Method Summary

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

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