org.thales.punch.libraries.storm.bolt.aggregator.impl

Class Record

java.lang.Object

org.thales.punch.libraries.storm.bolt.aggregator.impl.Record

public class Record
extends Object

A Record keeps track of the various counter associated to the keys identifying one aggregation. It is created specifically for a known list of operations to perform. Every time a Storm tuple comes in, we call the compute method that execute every operation. The instances of this class are kept in RAM, potentially millions of thems. Hence we keep the minimum number of fields in there.

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
Record(org.apache.storm.tuple.Tuple tuple, List<Operation> ops, List<String> documentFields) Create a new aggregation record.

Method Summary

Modifier and Type	Method and Description
void	compute(org.apache.storm.tuple.Tuple tuple, List<Operation> ops) Run the sequence of operations on an incoming tuple.
List<Object>	toObjectList(List<String> documentFields, List<Operation> ops, String uniqueBatchId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Record

public Record(org.apache.storm.tuple.Tuple tuple,
              List<Operation> ops,
              List<String> documentFields)

Create a new aggregation record. Every time a storm tuple is received by the bolt, the corresponding record is updated, that is all its registered operations are fired.

Parameters:

tuple - the input Storm tuple

ops - the list of operations

documentFields - the output fields

Method Detail

compute

public void compute(org.apache.storm.tuple.Tuple tuple,
                    List<Operation> ops)

Run the sequence of operations on an incoming tuple.

Parameters:

tuple - an incoming storm tuple

ops - the list of operations to apply

toObjectList

public List<Object> toObjectList(List<String> documentFields,
                                 List<Operation> ops,
                                 String uniqueBatchId)