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 and 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 Detail

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()