org.apache.storm.testing

Class MemoryTransactionalSpout

java.lang.Object

org.apache.storm.testing.MemoryTransactionalSpout

All Implemented Interfaces:

Serializable, IComponent, IPartitionedTransactionalSpout<MemoryTransactionalSpoutMeta>

public class MemoryTransactionalSpout
extends Object
implements IPartitionedTransactionalSpout<MemoryTransactionalSpoutMeta>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	TX_FIELD

Constructor Summary

Constructors

Constructor and Description
MemoryTransactionalSpout(Map<Integer,List<List<Object>>> partitions, Fields outFields, int takeAmt)

Method Summary

Modifier and Type	Method and Description
void	cleanup()
void	declareOutputFields(OutputFieldsDeclarer declarer) Declare the output schema for all the streams of this topology.
Map<String,Object>	getComponentConfiguration() Declare configuration specific to this component.
IPartitionedTransactionalSpout.Coordinator	getCoordinator(Map conf, TopologyContext context)
IPartitionedTransactionalSpout.Emitter<MemoryTransactionalSpoutMeta>	getEmitter(Map conf, TopologyContext context)
boolean	isExhaustedTuples()
void	startup()

Methods inherited from class java.lang.Object

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

Field Detail

TX_FIELD

public static final String TX_FIELD

Constructor Detail

MemoryTransactionalSpout

public MemoryTransactionalSpout(Map<Integer,List<List<Object>>> partitions,
                                Fields outFields,
                                int takeAmt)

Method Detail

isExhaustedTuples

public boolean isExhaustedTuples()

getCoordinator

public IPartitionedTransactionalSpout.Coordinator getCoordinator(Map conf,
                                                                 TopologyContext context)

Specified by:

getCoordinator in interface IPartitionedTransactionalSpout<MemoryTransactionalSpoutMeta>

getEmitter

public IPartitionedTransactionalSpout.Emitter<MemoryTransactionalSpoutMeta> getEmitter(Map conf,
                                                                                       TopologyContext context)

Specified by:

getEmitter in interface IPartitionedTransactionalSpout<MemoryTransactionalSpoutMeta>

declareOutputFields

public void declareOutputFields(OutputFieldsDeclarer declarer)

Description copied from interface: IComponent

Declare the output schema for all the streams of this topology.

Specified by:

declareOutputFields in interface IComponent

Parameters:

declarer - this is used to declare output stream ids, output fields, and whether or not each output stream is a direct stream

getComponentConfiguration

public Map<String,Object> getComponentConfiguration()

Description copied from interface: IComponent

Declare configuration specific to this component. Only a subset of the “topology.*” configs can be overridden. The component configuration can be further overridden when constructing the topology using TopologyBuilder

Specified by:

getComponentConfiguration in interface IComponent

startup

public void startup()

cleanup

public void cleanup()