Add another metric series to this collection, computing the tag and agg intersections and incrementing the size. @param dps The series to add
(final DataPoints dps)
| 119 | * @param dps The series to add |
| 120 | */ |
| 121 | public void add(final DataPoints dps) { |
| 122 | metric_uids.add(dps.metricUID()); |
| 123 | |
| 124 | // TODO - tags intersection |
| 125 | |
| 126 | for (final byte[] tagk : dps.getAggregatedTagUids()) { |
| 127 | aggregated_tags.add(tagk); |
| 128 | } |
| 129 | |
| 130 | tsuids.addAll(dps.getTSUIDs()); |
| 131 | // TODO - this ain't right. We need to number of dps emitted from HERE. For |
| 132 | // now we'll just take the first dps size. If it's downsampled then this |
| 133 | // will be accurate. |
| 134 | //size += dps.size(); |
| 135 | // TODO - restore when this is faster |
| 136 | //raw_size += dps.aggregatedSize(); |
| 137 | } |
| 138 | |
| 139 | /** |
| 140 | * Add another metric series to this collection, computing the tag and |
no test coverage detected