org.apache.storm.starter

Class LambdaTopology

java.lang.Object

org.apache.storm.topology.ConfigurableTopology

org.apache.storm.starter.LambdaTopology

public class LambdaTopology
extends ConfigurableTopology

Field Summary

Fields inherited from class org.apache.storm.topology.ConfigurableTopology

conf

Constructor Summary

Constructors

Constructor and Description
LambdaTopology()

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args)
protected int	run(String[] args)

Methods inherited from class org.apache.storm.topology.ConfigurableTopology

getConf, loadConf, start, submit, submit

Methods inherited from class java.lang.Object

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

Constructor Detail

LambdaTopology

public LambdaTopology()

Method Detail

main

public static void main(String[] args)

run

protected int run(String[] args)
           throws Exception

Specified by:

run in class ConfigurableTopology

Throws:

Exception