org.openimaj.storm.tool

Class StormToolOptions

java.lang.Object

org.openimaj.tools.InOutToolOptions

org.openimaj.storm.tool.StormToolOptions

public abstract class StormToolOptions
extends InOutToolOptions

Author:

Jon Hare (jsh2@ecs.soton.ac.uk), Sina Samangooei (ss@ecs.soton.ac.uk)

Field Summary

Fields

Modifier and Type	Field and Description
List<String>	kestrelHosts the ketrel queues for input and output
List<KestrelServerSpec>	kestrelSpecList parsed kestrel server specs
int	numberOfWorkers number of topology workers selected
TopologyModeOption	tm The topology
TopologyMode	tmOp

Fields inherited from class org.openimaj.tools.InOutToolOptions

output

Constructor Summary

Constructors

Constructor and Description
StormToolOptions(String[] args)

Method Summary

Modifier and Type	Method and Description
abstract backtype.storm.generated.StormTopology	constructTopology()
abstract String	getExtractUsageInfo()
void	prepare() Parse arguments and validate
abstract backtype.storm.Config	prepareConfig()
abstract void	topologyCleanup() called when the TopologyModeOption believes it is done
abstract String	topologyName()
abstract void	validate(org.kohsuke.args4j.CmdLineParser parser)

Methods inherited from class org.openimaj.tools.InOutToolOptions

getAllInputs, getInput, getInputFile, getOutput, isContinue, isForce, overwriteOutput, prepareMultivaluedArgument, setInput, setInputFile, setOutput

Methods inherited from class java.lang.Object

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

Field Detail

tm

public TopologyModeOption tm

The topology

tmOp

public TopologyMode tmOp

kestrelHosts

public List<String> kestrelHosts

the ketrel queues for input and output

numberOfWorkers

public int numberOfWorkers

number of topology workers selected

kestrelSpecList

public List<KestrelServerSpec> kestrelSpecList

parsed kestrel server specs

Constructor Detail

StormToolOptions

public StormToolOptions(String[] args)

Parameters:

args -

Method Detail

prepareConfig

public abstract backtype.storm.Config prepareConfig()

Returns:

provides a config based on the options

constructTopology

public abstract backtype.storm.generated.StormTopology constructTopology()

Returns:

provides a StormTopology based on the options

topologyName

public abstract String topologyName()

Returns:

the topology name

topologyCleanup

public abstract void topologyCleanup()

called when the TopologyModeOption believes it is done

prepare

public void prepare()
             throws IOException

Parse arguments and validate

Throws:

IOException

getExtractUsageInfo

public abstract String getExtractUsageInfo()

Returns:

usage of the tool

validate

public abstract void validate(org.kohsuke.args4j.CmdLineParser parser)
                       throws org.kohsuke.args4j.CmdLineException,
                              IOException

Parameters:

parser - initialise the tool

Throws:

IOException

org.kohsuke.args4j.CmdLineException - when something goes wrong