backtype.storm.testing
Class MemoryTransactionalSpout

java.lang.Object
  backtype.storm.testing.MemoryTransactionalSpout

All Implemented Interfaces:

IComponent, IPartitionedTransactionalSpout<MemoryTransactionalSpoutMeta>, java.io.Serializable

public class MemoryTransactionalSpout
extends java.lang.Object
implements IPartitionedTransactionalSpout<MemoryTransactionalSpoutMeta>

This spout only works in local mode.

See Also:

Serialized Form

Field Summary

static java.lang.String

TX_FIELD

Constructor Summary

MemoryTransactionalSpout(java.util.Map<java.lang.Integer,java.util.List<java.util.List<java.lang.Object>>> partitions, Fields outFields, int takeAmt)

Method Summary

void	cleanup()
void	declareOutputFields(OutputFieldsDeclarer declarer) Declare the output schema for all the streams of this topology.
java.util.Map<java.lang.String,java.lang.Object>	getComponentConfiguration() Declare configuration specific to this component.
IPartitionedTransactionalSpout.Coordinator	getCoordinator(java.util.Map conf, TopologyContext context)
IPartitionedTransactionalSpout.Emitter<MemoryTransactionalSpoutMeta>	getEmitter(java.util.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 java.lang.String TX_FIELD

Constructor Detail

MemoryTransactionalSpout

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

Method Detail

isExhaustedTuples

public boolean isExhaustedTuples()

getCoordinator

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

Specified by:

getCoordinator in interface IPartitionedTransactionalSpout<MemoryTransactionalSpoutMeta>

getEmitter

public IPartitionedTransactionalSpout.Emitter<MemoryTransactionalSpoutMeta> getEmitter(java.util.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 java.util.Map<java.lang.String,java.lang.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()