storm.trident.spout
Interface IBatchSpout

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

FixedBatchSpout

public interface IBatchSpout
extends java.io.Serializable

Method Summary

void	ack(long batchId)
void	close()
void	emitBatch(long batchId, TridentCollector collector)
java.util.Map	getComponentConfiguration()
Fields	getOutputFields()
void	open(java.util.Map conf, TopologyContext context)

Method Detail

open

void open(java.util.Map conf,
          TopologyContext context)

emitBatch

void emitBatch(long batchId,
               TridentCollector collector)

ack

void ack(long batchId)

close

void close()

getComponentConfiguration

java.util.Map getComponentConfiguration()

getOutputFields

Fields getOutputFields()