public class EncRowCalcBolt
extends org.apache.storm.topology.base.BaseRichBolt
Receives a <hash(selector), dataPartitions>
tuple as input.
Encrypts the row data and emits a (column index, encrypted row-value) tuple for each encrypted block.
Every FLUSH_FREQUENCY seconds, it sends a signal to EncColMultBolt to flush its output and resets all counters. At that point, all outgoing (column index, encrypted row-value) tuples are buffered until a SESSION_END signal is received back from each EncColMultBolt.
Constructor and Description |
---|
EncRowCalcBolt() |
Modifier and Type | Method and Description |
---|---|
void |
declareOutputFields(org.apache.storm.topology.OutputFieldsDeclarer outputFieldsDeclarer) |
void |
execute(org.apache.storm.tuple.Tuple tuple) |
void |
prepare(java.util.Map map,
org.apache.storm.task.TopologyContext topologyContext,
org.apache.storm.task.OutputCollector coll) |
public void prepare(java.util.Map map, org.apache.storm.task.TopologyContext topologyContext, org.apache.storm.task.OutputCollector coll)
public void execute(org.apache.storm.tuple.Tuple tuple)
public void declareOutputFields(org.apache.storm.topology.OutputFieldsDeclarer outputFieldsDeclarer)