public class Record extends Object
Constructor and Description |
---|
Record(org.apache.storm.tuple.Tuple tuple,
List<Operation> ops,
List<String> documentFields)
Create a new aggregation record.
|
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) |
public Record(org.apache.storm.tuple.Tuple tuple, List<Operation> ops, List<String> documentFields)
tuple
- the input Storm tupleops
- the list of operationsdocumentFields
- the output fieldsCopyright © 2023. All rights reserved.