Package org.apache.storm.trident.topology

Interface ITridentBatchBolt

All Superinterfaces:

IComponent, Serializable

All Known Implementing Classes:

SubtopologyBolt, TridentSpoutExecutor

public interface ITridentBatchBolt
extends IComponent

Method Summary

Modifier and Type	Method	Description
void	cleanup()
void	execute(BatchInfo batchInfo, Tuple tuple)
void	finishBatch(BatchInfo batchInfo)
Object	initBatchState(String batchGroup, Object batchId)
void	prepare(Map<String,Object> conf, TopologyContext context, BatchOutputCollector collector)

Methods inherited from interface org.apache.storm.topology.IComponent

declareOutputFields, getComponentConfiguration

Method Details

prepare

void prepare(Map<String,Object> conf,
 TopologyContext context,
 BatchOutputCollector collector)

execute

void execute(BatchInfo batchInfo,
 Tuple tuple)

finishBatch

void finishBatch(BatchInfo batchInfo)

initBatchState

Object initBatchState(String batchGroup,
 Object batchId)

cleanup

void cleanup()