Home
last modified time | relevance | path

Searched refs:tsuids (Results 1 – 25 of 27) sorted by relevance

12

/dports/databases/opentsdb/opentsdb-2.3.0/test/search/
H A DTestTimeSeriesLookup.java85 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 DExpressionDataPoint.java45 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 DTSSubQuery.java55 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 DTsdbQuery.java126 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 DQuery.java131 public void setTimeSeries(final List<String> tsuids, in setTimeSeries() argument
153 public void setTimeSeries(final List<String> tsuids, in setTimeSeries() argument
H A DInternal.java857 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 DSpan.java158 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 DSpanGroup.java449 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 DAnnotationRpc.java266 (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 DQueryRpc.java408 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 DTreeRpc.java437 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 DSearchRpc.java221 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 DTestPostAggregatedDataPoints.java60 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 DMockDataPoints.java54 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 DTestTSSubQuery.java57 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 DTestTsdbQuery.java178 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 DTestTsdbQueryQueries.java970 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 DTestTSUIDQuery.java151 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 DQueryUtil.java266 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 DTestTree.java462 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 DTimeSeriesLookup.java112 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 DTree.java634 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 DTreeSync.java271 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 DAnnotation.java446 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 DTSUIDQuery.java255 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()

12