storm.trident.testing
Class FixedBatchSpout
java.lang.Object
storm.trident.testing.FixedBatchSpout
- All Implemented Interfaces:
- java.io.Serializable, IBatchSpout
public class FixedBatchSpout
- extends java.lang.Object
- implements IBatchSpout
- See Also:
- Serialized Form
Constructor Summary |
FixedBatchSpout(Fields fields,
int maxBatchSize,
java.util.List<java.lang.Object>... outputs)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
FixedBatchSpout
public FixedBatchSpout(Fields fields,
int maxBatchSize,
java.util.List<java.lang.Object>... outputs)
setCycle
public void setCycle(boolean cycle)
open
public void open(java.util.Map conf,
TopologyContext context)
- Specified by:
open
in interface IBatchSpout
emitBatch
public void emitBatch(long batchId,
TridentCollector collector)
- Specified by:
emitBatch
in interface IBatchSpout
ack
public void ack(long batchId)
- Specified by:
ack
in interface IBatchSpout
close
public void close()
- Specified by:
close
in interface IBatchSpout
getComponentConfiguration
public java.util.Map getComponentConfiguration()
- Specified by:
getComponentConfiguration
in interface IBatchSpout
getOutputFields
public Fields getOutputFields()
- Specified by:
getOutputFields
in interface IBatchSpout