MCPcopy Index your code
hub / github.com/OpenTSDB/opentsdb / process

Method process

src/core/MultiGetQuery.java:404–426  ·  view source on GitHub ↗

Handles processing of row of data into the proper list @param key The row key, possibly mutated @param row The row of KVs to process @return True if processing should continue, false if an exception occurred or the scanner was already closed (possibly due to another scanner error)

(final byte[] key, final ArrayList<KeyValue> row)

Source from the content-addressed store, hash-verified

402 * or the scanner was already closed (possibly due to another scanner error)
403 */
404 boolean process(final byte[] key, final ArrayList<KeyValue> row) {
405 ++mul_get_rows_post_filter;
406 num_post_filter_data_points.addAndGet(row.size());
407
408 List<Annotation> notes = null;
409 if (annotMap != null) {
410 notes = annotations.get(key);
411
412 if (notes == null) {
413 notes = new ArrayList<Annotation>();
414 annotations.put(key, notes);
415 }
416 }
417
418 List<HistogramDataPoint> hists = new ArrayList<HistogramDataPoint>();
419 if (RollupQuery.isValidQuery(rollup_query)) {
420 processRollupQuery(key, row, notes, hists);
421 } else {
422 processNotRollupQuery(key, row, notes, hists);
423 }
424
425 return true;
426 }
427
428 private void processNotRollupQuery(final byte[] key,
429 final ArrayList<KeyValue> row,

Callers 1

callMethod · 0.95

Calls 6

isValidQueryMethod · 0.95
processRollupQueryMethod · 0.95
processNotRollupQueryMethod · 0.95
putMethod · 0.80
sizeMethod · 0.65
getMethod · 0.45

Tested by

no test coverage detected