backtype.storm.spout

Class UnreliableKestrelThriftSpout

java.lang.Object

backtype.storm.topology.base.BaseComponent

backtype.storm.topology.base.BaseRichSpout

backtype.storm.spout.UnreliableKestrelThriftSpout

All Implemented Interfaces:

backtype.storm.spout.ISpout, backtype.storm.topology.IComponent, backtype.storm.topology.IRichSpout, Serializable

public class UnreliableKestrelThriftSpout
extends backtype.storm.topology.base.BaseRichSpout

A version of the KestrelThriftSpout that is purposefully unreliable and cuts other corners in an effort for improved speeds

Author:

Sina Samangooei (ss@ecs.soton.ac.uk)

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
UnreliableKestrelThriftSpout(List<KestrelServerSpec> serverSpecs, backtype.storm.spout.Scheme scheme, String inputQueue)

Method Summary

Modifier and Type	Method and Description
void	ack(Object msgId)
void	close()
void	declareOutputFields(backtype.storm.topology.OutputFieldsDeclarer declarer)
void	fail(Object msgId)
void	nextTuple()
void	open(Map conf, backtype.storm.task.TopologyContext context, backtype.storm.spout.SpoutOutputCollector collector)
void	setAckQueue(String ackQueue) The ackQueue holds statistics about acknowledgement time useful for measuring topology throughput

Methods inherited from class backtype.storm.topology.base.BaseRichSpout

activate, deactivate

Methods inherited from class backtype.storm.topology.base.BaseComponent

getComponentConfiguration

Methods inherited from class java.lang.Object

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

Methods inherited from interface backtype.storm.topology.IComponent

getComponentConfiguration

Constructor Detail

UnreliableKestrelThriftSpout

public UnreliableKestrelThriftSpout(List<KestrelServerSpec> serverSpecs,
                                    backtype.storm.spout.Scheme scheme,
                                    String inputQueue)

Parameters:

serverSpecs - servers to connect to in a round robin fasion

scheme - how items should be read

inputQueue - queue from which to read

Method Detail

setAckQueue

public void setAckQueue(String ackQueue)

The ackQueue holds statistics about acknowledgement time useful for measuring topology throughput

Parameters:

ackQueue -

open

public void open(Map conf,
                 backtype.storm.task.TopologyContext context,
                 backtype.storm.spout.SpoutOutputCollector collector)

close

public void close()

Specified by:

close in interface backtype.storm.spout.ISpout

Overrides:

close in class backtype.storm.topology.base.BaseRichSpout

nextTuple

public void nextTuple()

declareOutputFields

public void declareOutputFields(backtype.storm.topology.OutputFieldsDeclarer declarer)

ack

public void ack(Object msgId)

Specified by:

ack in interface backtype.storm.spout.ISpout

Overrides:

ack in class backtype.storm.topology.base.BaseRichSpout

fail

public void fail(Object msgId)

Specified by:

fail in interface backtype.storm.spout.ISpout

Overrides:

fail in class backtype.storm.topology.base.BaseRichSpout