backtype.storm.testing
Class OpaqueMemoryTransactionalSpout
java.lang.Object
backtype.storm.testing.OpaqueMemoryTransactionalSpout
- All Implemented Interfaces:
- IComponent, IOpaquePartitionedTransactionalSpout<MemoryTransactionalSpoutMeta>, java.io.Serializable
public class OpaqueMemoryTransactionalSpout
- extends java.lang.Object
- implements IOpaquePartitionedTransactionalSpout<MemoryTransactionalSpoutMeta>
This spout only works in local mode.
- See Also:
- Serialized Form
Field Summary |
static java.lang.String |
TX_FIELD
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TX_FIELD
public static java.lang.String TX_FIELD
OpaqueMemoryTransactionalSpout
public OpaqueMemoryTransactionalSpout(java.util.Map<java.lang.Integer,java.util.List<java.util.List<java.lang.Object>>> partitions,
Fields outFields,
int takeAmt)
setDisabled
public void setDisabled(java.lang.Integer partition,
boolean disabled)
isExhaustedTuples
public boolean isExhaustedTuples()
getEmitter
public IOpaquePartitionedTransactionalSpout.Emitter<MemoryTransactionalSpoutMeta> getEmitter(java.util.Map conf,
TopologyContext context)
- Specified by:
getEmitter
in interface IOpaquePartitionedTransactionalSpout<MemoryTransactionalSpoutMeta>
getCoordinator
public IOpaquePartitionedTransactionalSpout.Coordinator getCoordinator(java.util.Map conf,
TopologyContext context)
- Specified by:
getCoordinator
in interface IOpaquePartitionedTransactionalSpout<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()