Uses of Class
org.apache.storm.trident.topology.BatchInfo
-
Packages that use BatchInfo Package Description org.apache.storm.trident.planner org.apache.storm.trident.spout org.apache.storm.trident.topology -
-
Uses of BatchInfo in org.apache.storm.trident.planner
Methods in org.apache.storm.trident.planner with parameters of type BatchInfo Modifier and Type Method Description void
SubtopologyBolt. execute(BatchInfo batchInfo, Tuple tuple)
void
SubtopologyBolt. finishBatch(BatchInfo batchInfo)
-
Uses of BatchInfo in org.apache.storm.trident.spout
Methods in org.apache.storm.trident.spout with parameters of type BatchInfo Modifier and Type Method Description void
TridentSpoutExecutor. execute(BatchInfo info, Tuple input)
void
TridentSpoutExecutor. finishBatch(BatchInfo batchInfo)
-
Uses of BatchInfo in org.apache.storm.trident.topology
Methods in org.apache.storm.trident.topology with parameters of type BatchInfo Modifier and Type Method Description void
ITridentBatchBolt. execute(BatchInfo batchInfo, Tuple tuple)
void
ITridentBatchBolt. finishBatch(BatchInfo batchInfo)
Constructors in org.apache.storm.trident.topology with parameters of type BatchInfo Constructor Description TrackedBatch(BatchInfo info, TridentBoltExecutor.CoordCondition condition, int attemptId)
-