org.apache.storm.trident.spout

Interface IBatchSpout

All Superinterfaces:

ITridentDataSource, Serializable

All Known Implementing Classes:

FixedBatchSpout, FixedBatchSpout, MetricGenBatchSpout, RandomNumberGeneratorSpout, TridentEsTopology.FixedBatchSpout, TridentHiveTopology.FixedBatchSpout

public interface IBatchSpout
extends ITridentDataSource

Method Summary

Modifier and Type	Method and Description
void	ack(long batchId)
void	close()
void	emitBatch(long batchId, TridentCollector collector)
Map<String,Object>	getComponentConfiguration()
Fields	getOutputFields()
void	open(Map<String,Object> conf, TopologyContext context)

Method Detail

open

void open(Map<String,Object> conf,
          TopologyContext context)

emitBatch

void emitBatch(long batchId,
               TridentCollector collector)

ack

void ack(long batchId)

close

void close()

getComponentConfiguration

Map<String,Object> getComponentConfiguration()

getOutputFields

Fields getOutputFields()