public interface IBatchBolt<T> extends Serializable, IComponent
Modifier and Type | Method and Description |
---|---|
void |
execute(Tuple tuple) |
void |
finishBatch() |
void |
prepare(Map<String,Object> conf,
TopologyContext context,
BatchOutputCollector collector,
T id) |
declareOutputFields, getComponentConfiguration
void prepare(Map<String,Object> conf, TopologyContext context, BatchOutputCollector collector, T id)
void execute(Tuple tuple)
void finishBatch()
Copyright © 2022 The Apache Software Foundation. All rights reserved.