/dports/databases/opentsdb/opentsdb-2.3.0/test/search/ |
H A D | TestTimeSeriesLookup.java | 85 assertNotNull(tsuids); in metricOnlyMeta() 98 assertNotNull(tsuids); in metricOnlyMetaStar() 109 assertNotNull(tsuids); in metricOnlyData() 121 assertNotNull(tsuids); in metricOnly2Meta() 133 assertNotNull(tsuids); in metricOnly2Data() 151 assertNotNull(tsuids); in metricOnlyNoValuesMeta() 162 assertNotNull(tsuids); in metricOnlyNoValuesData() 175 assertNotNull(tsuids); in tagkOnlyMeta() 191 assertNotNull(tsuids); in tagkOnlyMetaStar() 209 assertNotNull(tsuids); in tagkOnlyData() [all …]
|
/dports/databases/opentsdb/opentsdb-2.3.0/src/query/expression/ |
H A D | ExpressionDataPoint.java | 45 private final Set<String> tsuids; field in ExpressionDataPoint 70 tsuids = new HashSet<String>(); in ExpressionDataPoint() 90 tsuids = new HashSet<String>(dps.getTSUIDs()); in ExpressionDataPoint() 109 tsuids = new HashSet<String>(dps.tsuids); in ExpressionDataPoint() 130 tsuids.addAll(dps.getTSUIDs()); in add() 151 tsuids.addAll(dps.tsuids); in add() 175 public Set<String> tsuids() { in tsuids() method in ExpressionDataPoint 176 return tsuids; in tsuids() 212 .append(tsuids) in toString()
|
/dports/databases/opentsdb/opentsdb-2.3.0/src/core/ |
H A D | TSSubQuery.java | 55 private List<String> tsuids; field in TSSubQuery 94 return Objects.hashCode(aggregator, metric, tsuids, downsample, rate, in hashCode() 115 && Objects.equal(tsuids, query.tsuids) in equals() 139 if (tsuids != null && !tsuids.isEmpty()) { in toString() 141 for (String tsuid : tsuids) { in toString() 188 if ((tsuids == null || tsuids.isEmpty()) && in validateAndSetQuery() 252 return tsuids; in getTsuids() 339 public void setTsuids(List<String> tsuids) { in setTsuids() argument 340 this.tsuids = tsuids; in setTsuids()
|
H A D | TsdbQuery.java | 126 private List<String> tsuids; field in TsdbQuery 269 public void setTimeSeries(final List<String> tsuids, in setTimeSeries() argument 278 if (tsuids == null || tsuids.isEmpty()) { in setTimeSeries() 284 for (final String tsuid : tsuids) { in setTimeSeries() 300 this.tsuids = tsuids; in setTimeSeries() 346 for (final String tsuid : tsuids) { in configureFromQuery() 1039 if (tsuids != null && !tsuids.isEmpty()) { in getScanner() 1040 final String tsuid = tsuids.get(0); in getScanner() 1055 if (tsuids != null && !tsuids.isEmpty()) { in getScanner() 1182 if (tsuids != null && !tsuids.isEmpty()) { in toString() [all …]
|
H A D | Query.java | 131 public void setTimeSeries(final List<String> tsuids, in setTimeSeries() argument 153 public void setTimeSeries(final List<String> tsuids, in setTimeSeries() argument
|
H A D | Internal.java | 857 final List<String> tsuids) { in createAndSetTSUIDFilter() argument 858 Collections.sort(tsuids); in createAndSetTSUIDFilter() 864 final ArrayList<byte[]> uids = new ArrayList<byte[]>(tsuids.size()); in createAndSetTSUIDFilter() 865 for (final String tsuid : tsuids) { in createAndSetTSUIDFilter() 878 + (tsuids.size() * 11) // "\\Q" + "\\E|" in createAndSetTSUIDFilter()
|
H A D | Span.java | 158 final List<String> tsuids = new ArrayList<String>(1); in getTSUIDs() local 159 tsuids.add(UniqueId.uidToString(tsuid)); in getTSUIDs() 160 return tsuids; in getTSUIDs()
|
H A D | SpanGroup.java | 449 List<String> tsuids = new ArrayList<String>(spans.size()); in getTSUIDs() local 451 tsuids.addAll(sp.getTSUIDs()); in getTSUIDs() 453 return tsuids; in getTSUIDs()
|
/dports/databases/opentsdb/opentsdb-2.3.0/src/tsd/ |
H A D | AnnotationRpc.java | 266 (delete_request.tsuids == null || delete_request.tsuids.isEmpty())) { in executeBulkDelete() 272 delete_request.tsuids.size() + 1 : 1; in executeBulkDelete() 278 if (delete_request.tsuids != null) { in executeBulkDelete() 279 for (String tsuid : delete_request.tsuids) { in executeBulkDelete() 384 settings.tsuids = new ArrayList<String>(tsuids.length); in parseBulkDeleteQS() 385 for (String tsuid : tsuids) { in parseBulkDeleteQS() 386 settings.tsuids.add(tsuid.trim()); in parseBulkDeleteQS() 409 private List<String> tsuids; field in AnnotationRpc.AnnotationBulkDelete 439 return tsuids; in getTsuids() 464 public void setTsuids(List<String> tsuids) { in setTsuids() argument [all …]
|
H A D | QueryRpc.java | 408 if (tsuids == null || tsuids.isEmpty()) { in handleLastDataPointQuery() 413 for (Map.Entry<byte[], Long> entry : tsuids.entrySet()) { in handleLastDataPointQuery() 561 for (String q : tsuids) { in parseQuery() 867 private List<String> tsuids; field in QueryRpc.LastPointSubQuery 885 final String[] tsuids = query.split(","); in parseTSUIDQuery() local 886 sub_query.tsuids = new ArrayList<String>(tsuids.length); in parseTSUIDQuery() 887 for (String tsuid : tsuids) { in parseTSUIDQuery() 888 sub_query.tsuids.add(tsuid); in parseTSUIDQuery() 905 return tsuids; in getTSUIDs() 919 public void setTSUIDs(final List<String> tsuids) { in setTSUIDs() argument [all …]
|
H A D | TreeRpc.java | 437 final List<String> tsuids = (List<String>)map.get("tsuids"); in handleTest() local 438 if (tsuids == null || tsuids.isEmpty()) { in handleTest() 446 new HashMap<String, HashMap<String, Object>>(tsuids.size()); in handleTest() 448 for (String tsuid : tsuids) { in handleTest() 543 final List<String> tsuids = (List<String>)map.get("tsuids"); in handleCollisionNotMatched() local 545 Tree.fetchCollisions(tsdb, tree_id, tsuids).joinUninterruptibly() : in handleCollisionNotMatched() 546 Tree.fetchNotMatched(tsdb, tree_id, tsuids).joinUninterruptibly(); in handleCollisionNotMatched() 722 final String[] tsuids = tsquery.split(","); in parseTSUIDsList() local 723 map.put("tsuids", Arrays.asList(tsuids)); in parseTSUIDsList()
|
H A D | SearchRpc.java | 221 public Deferred<Object> call(final List<byte[]> tsuids) throws Exception { in processLookup() argument 222 final List<Object> results = new ArrayList<Object>(tsuids.size()); in processLookup() 223 search_query.setTotalResults(tsuids.size()); in processLookup() 226 new ArrayList<Deferred<Object>>(tsuids.size()); in processLookup() 228 for (final byte[] tsuid : tsuids) { in processLookup()
|
/dports/databases/opentsdb/opentsdb-2.3.0/test/query/expression/ |
H A D | TestPostAggregatedDataPoints.java | 60 private List<String> tsuids; field in TestPostAggregatedDataPoints 81 tsuids = new ArrayList<String>(1); in before() 82 tsuids.add("0101010202"); // just 1 byte UIDs for kicks in before() 96 when(base_data_points.getTSUIDs()).thenReturn(tsuids); in before() 112 assertSame(tsuids, dps.getTSUIDs()); in ctorDefaults() 186 assertSame(tsuids, dps.getTSUIDs()); in alias() 205 assertSame(tsuids, dps.getTSUIDs()); in emptyPoints()
|
/dports/databases/opentsdb/opentsdb-2.3.0/test/storage/ |
H A D | MockDataPoints.java | 54 private final List<String> tsuids = new ArrayList<String>(2); field in MockDataPoints 64 tsuids.add("000001000001000001"); in MockDataPoints() 65 tsuids.add("000001000001000002"); in MockDataPoints() 85 when(dps.getTSUIDs()).thenReturn(tsuids); in getMock()
|
/dports/databases/opentsdb/opentsdb-2.3.0/test/core/ |
H A D | TestTSSubQuery.java | 57 tsuids.add("ABCD"); in validateTS() 58 sub.setTsuids(tsuids); in validateTS() 310 List<String> tsuids = new ArrayList<String>(2); in testHashCodeandEqualsTSUIDs() local 311 tsuids.add("01010101"); in testHashCodeandEqualsTSUIDs() 312 tsuids.add("01010102"); in testHashCodeandEqualsTSUIDs() 313 sub1.setTsuids(tsuids); in testHashCodeandEqualsTSUIDs() 334 List<String> tsuids = new ArrayList<String>(2); in testHashCodeandEqualsTSUIDsChange() local 335 tsuids.add("01010101"); in testHashCodeandEqualsTSUIDsChange() 336 tsuids.add("01010102"); in testHashCodeandEqualsTSUIDsChange() 337 sub1.setTsuids(tsuids); in testHashCodeandEqualsTSUIDsChange() [all …]
|
H A D | TestTsdbQuery.java | 178 final List<String> tsuids = new ArrayList<String>(2); in setTimeSeriesTS() local 179 tsuids.add("000001000001000001"); in setTimeSeriesTS() 180 tsuids.add("000001000001000002"); in setTimeSeriesTS() 181 query.setTimeSeries(tsuids, Aggregators.SUM, false); in setTimeSeriesTS() 192 final List<String> tsuids = new ArrayList<String>(); in setTimeSeriesTSEmptyList() local 193 query.setTimeSeries(tsuids, Aggregators.SUM, false); in setTimeSeriesTSEmptyList() 198 final List<String> tsuids = new ArrayList<String>(2); in setTimeSeriesTSDifferentMetrics() local 199 tsuids.add("000001000001000001"); in setTimeSeriesTSDifferentMetrics() 200 tsuids.add("000002000001000002"); in setTimeSeriesTSDifferentMetrics() 201 query.setTimeSeries(tsuids, Aggregators.SUM, false); in setTimeSeriesTSDifferentMetrics()
|
H A D | TestTsdbQueryQueries.java | 970 tsuids.add("000001000001000001"); in runTSUIDQuery() 971 query.setTimeSeries(tsuids, Aggregators.SUM, false); in runTSUIDQuery() 994 tsuids.add("000001000001000001"); in runTSUIDsAggSum() 995 tsuids.add("000001000001000002"); in runTSUIDsAggSum() 996 query.setTimeSeries(tsuids, Aggregators.SUM, false); in runTSUIDsAggSum() 1018 tsuids.add("000001000001000001"); in runTSUIDQueryNoData() 1019 query.setTimeSeries(tsuids, Aggregators.SUM, false); in runTSUIDQueryNoData() 1035 tsuids.add("000001000001000005"); in runTSUIDQueryNoDataForTSUID() 1036 query.setTimeSeries(tsuids, Aggregators.SUM, false); in runTSUIDQueryNoDataForTSUID() 1052 tsuids.add("000001000001000001"); in runTSUIDQueryNSU() [all …]
|
/dports/databases/opentsdb/opentsdb-2.3.0/test/meta/ |
H A D | TestTSUIDQuery.java | 151 assertEquals(1, tsuids.size()); in getLastWriteTimes() 152 assertEquals(1388534400013L, (long)tsuids.get(TSUID)); in getLastWriteTimes() 160 assertEquals(1, tsuids.size()); in getLastWriteTimesSetQuery() 161 assertEquals(1388534400013L, (long)tsuids.get(TSUID)); in getLastWriteTimesSetQuery() 169 assertEquals(2, tsuids.size()); in getLastWriteTimesEmptyTags() 170 assertEquals(1388534400013L, (long)tsuids.get(TSUID)); in getLastWriteTimesEmptyTags() 172 (long)tsuids.get(new byte[] { 0, 0, 1, 0, 0, 1, 0, 0, 2 })); in getLastWriteTimesEmptyTags() 181 assertEquals(2, tsuids.size()); in getLastWriteTimesEmptyTagsSetQuery() 182 assertEquals(1388534400013L, (long)tsuids.get(TSUID)); in getLastWriteTimesEmptyTagsSetQuery() 184 (long)tsuids.get(new byte[] { 0, 0, 1, 0, 0, 1, 0, 0, 2 })); in getLastWriteTimesEmptyTagsSetQuery() [all …]
|
/dports/databases/opentsdb/opentsdb-2.3.0/src/query/ |
H A D | QueryUtil.java | 266 public static String getRowKeyTSUIDRegex(final List<String> tsuids) { in getRowKeyTSUIDRegex() argument 267 Collections.sort(tsuids); in getRowKeyTSUIDRegex() 273 final ArrayList<byte[]> uids = new ArrayList<byte[]>(tsuids.size()); in getRowKeyTSUIDRegex() 274 for (final String tsuid : tsuids) { in getRowKeyTSUIDRegex() 287 + (tsuids.size() * 11) // "\\Q" + "\\E|" in getRowKeyTSUIDRegex()
|
/dports/databases/opentsdb/opentsdb-2.3.0/test/tree/ |
H A D | TestTree.java | 462 final ArrayList<String> tsuids = new ArrayList<String>(1); in fetchCollisionsSingle() local 463 tsuids.add("020202"); in fetchCollisionsSingle() 465 Tree.fetchCollisions(storage.getTSDB(), 1, tsuids).joinUninterruptibly(); in fetchCollisionsSingle() 474 final ArrayList<String> tsuids = new ArrayList<String>(1); in fetchCollisionsSingleNotFound() local 475 tsuids.add("030303"); in fetchCollisionsSingleNotFound() 477 Tree.fetchCollisions(storage.getTSDB(), 1, tsuids).joinUninterruptibly(); in fetchCollisionsSingleNotFound() 520 final ArrayList<String> tsuids = new ArrayList<String>(1); in fetchNotMatchedSingle() local 521 tsuids.add("020202"); in fetchNotMatchedSingle() 523 Tree.fetchNotMatched(storage.getTSDB(), 1, tsuids).joinUninterruptibly(); in fetchNotMatchedSingle() 533 final ArrayList<String> tsuids = new ArrayList<String>(1); in fetchNotMatchedSingleNotFound() local [all …]
|
/dports/databases/opentsdb/opentsdb-2.3.0/src/search/ |
H A D | TimeSeriesLookup.java | 112 private final List<byte[]> tsuids; field in TimeSeriesLookup 123 tsuids = Collections.synchronizedList(new ArrayList<byte[]>()); in TimeSeriesLookup() 211 LOG.debug("Lookup query matched " + tsuids.size() + " time series in " + in lookupAsync() 214 return Deferred.fromResult(tsuids); in lookupAsync() 259 tsuids.add(tsuid); in lookupAsync() 276 LOG.debug("Lookup query matched " + tsuids.size() + " time series in " + in lookupAsync() 278 return tsuids; in lookupAsync()
|
/dports/databases/opentsdb/opentsdb-2.3.0/src/tree/ |
H A D | Tree.java | 634 final int tree_id, final List<String> tsuids) { in fetchCollisions() argument 648 if (tsuids != null && !tsuids.isEmpty()) { in fetchCollisions() 649 final byte[][] qualifiers = new byte[tsuids.size()][]; in fetchCollisions() 651 for (String tsuid : tsuids) { in fetchCollisions() 718 final int tree_id, final List<String> tsuids) { in fetchNotMatched() argument 732 if (tsuids != null && !tsuids.isEmpty()) { in fetchNotMatched() 733 final byte[][] qualifiers = new byte[tsuids.size()][]; in fetchNotMatched() 735 for (String tsuid : tsuids) { in fetchNotMatched()
|
/dports/databases/opentsdb/opentsdb-2.3.0/src/tools/ |
H A D | TreeSync.java | 271 public Deferred<Boolean> call(ArrayList<Boolean> tsuids) in run() argument 273 LOG.debug("Processed [" + tsuids.size() + "] tree_calls, continuing"); in run()
|
/dports/databases/opentsdb/opentsdb-2.3.0/src/meta/ |
H A D | Annotation.java | 446 final List<String> tsuids = new ArrayList<String>(1); in deleteRange() local 447 tsuids.add(UniqueId.uidToString(tsuid)); in deleteRange() 448 Internal.createAndSetTSUIDFilter(scanner, tsuids); in deleteRange()
|
H A D | TSUIDQuery.java | 255 final ByteMap<Long> tsuids = new ByteMap<Long>(); in getLastWriteTimes() local 296 results.callback(tsuids); in getLastWriteTimes() 302 tsuids.put(tsuid, row.get(0).timestamp()); in getLastWriteTimes()
|