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)
| 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, |
no test coverage detected