| /dports/biology/gatk/gatk-4.2.0.0/src/test/java/org/broadinstitute/hellbender/utils/downsampling/ |
| H A D | ReservoirDownsamplerUnitTest.java | 75 Assert.assertFalse(downsampler.hasFinalizedItems() || downsampler.hasPendingItems()); in testReservoirDownsampler()
76 … Assert.assertTrue(downsampler.peekFinalized() == null && downsampler.peekPending() == null); in testReservoirDownsampler()
80 downsampler.signalEndOfInput(); in testReservoirDownsampler()
89 Assert.assertFalse(downsampler.hasFinalizedItems() || downsampler.hasPendingItems()); in testReservoirDownsampler()
90 … Assert.assertTrue(downsampler.peekFinalized() == null && downsampler.peekPending() == null); in testReservoirDownsampler()
95 Assert.assertFalse(downsampler.hasFinalizedItems() || downsampler.hasPendingItems()); in testReservoirDownsampler()
96 Assert.assertTrue(downsampler.peekFinalized() == null && downsampler.peekPending() == null); in testReservoirDownsampler()
103 downsampler.resetStats(); in testReservoirDownsampler()
152 downsampler.submit(read); in testConsumeFinalizedItemsBeforeEndOfInput()
188 downsampler.submit(read); in testConsumeFinalizedItemsAfterEndOfInputOnEmptyDownsampler()
[all …]
|
| H A D | LevelingDownsamplerUnitTest.java | 95 downsampler.submit(stacks); in testLevelingDownsamplerWithUniformStacks()
102 Assert.assertTrue(downsampler.hasPendingItems()); in testLevelingDownsamplerWithUniformStacks()
106 Assert.assertFalse(downsampler.hasFinalizedItems() || downsampler.hasPendingItems()); in testLevelingDownsamplerWithUniformStacks()
107 … Assert.assertTrue(downsampler.peekFinalized() == null && downsampler.peekPending() == null); in testLevelingDownsamplerWithUniformStacks()
110 downsampler.signalEndOfInput(); in testLevelingDownsamplerWithUniformStacks()
119 Assert.assertFalse(downsampler.hasFinalizedItems() || downsampler.hasPendingItems()); in testLevelingDownsamplerWithUniformStacks()
120 … Assert.assertTrue(downsampler.peekFinalized() == null && downsampler.peekPending() == null); in testLevelingDownsamplerWithUniformStacks()
123 final int sizeFromDownsampler = downsampler.size(); in testLevelingDownsamplerWithUniformStacks()
125 Assert.assertFalse(downsampler.hasFinalizedItems() || downsampler.hasPendingItems()); in testLevelingDownsamplerWithUniformStacks()
126 Assert.assertTrue(downsampler.peekFinalized() == null && downsampler.peekPending() == null); in testLevelingDownsamplerWithUniformStacks()
[all …]
|
| H A D | PositionalDownsamplerUnitTest.java | 59 Assert.assertEquals(downsampler.size(), 0); in testPositionalDownsampler()
62 downsampler.submit(allReads); in testPositionalDownsampler()
81 Assert.assertNull(downsampler.peekPending()); in testPositionalDownsampler()
84 downsampler.signalEndOfInput(); in testPositionalDownsampler()
98 Assert.assertNull(downsampler.peekPending()); in testPositionalDownsampler()
103 Assert.assertNull(downsampler.peekFinalized()); in testPositionalDownsampler()
104 Assert.assertNull(downsampler.peekPending()); in testPositionalDownsampler()
120 downsampler.resetStats(); in testPositionalDownsampler()
140 downsampler.submit(reads); in testSignalNoMoreReadsBefore()
142 Assert.assertTrue(downsampler.hasPendingItems()); in testSignalNoMoreReadsBefore()
[all …]
|
| H A D | FractionalDownsamplerUnitTest.java | 87 downsampler.submit(test.createReads()); in runFractionalDownsamplerTest()
94 Assert.assertFalse(downsampler.hasPendingItems()); in runFractionalDownsamplerTest()
97 Assert.assertFalse(downsampler.hasFinalizedItems() || downsampler.hasPendingItems()); in runFractionalDownsamplerTest()
98 … Assert.assertTrue(downsampler.peekFinalized() == null && downsampler.peekPending() == null); in runFractionalDownsamplerTest()
101 downsampler.signalEndOfInput(); in runFractionalDownsamplerTest()
108 Assert.assertFalse(downsampler.hasPendingItems()); in runFractionalDownsamplerTest()
111 Assert.assertFalse(downsampler.hasFinalizedItems() || downsampler.hasPendingItems()); in runFractionalDownsamplerTest()
112 … Assert.assertTrue(downsampler.peekFinalized() == null && downsampler.peekPending() == null); in runFractionalDownsamplerTest()
116 Assert.assertFalse(downsampler.hasFinalizedItems() || downsampler.hasPendingItems()); in runFractionalDownsamplerTest()
117 Assert.assertTrue(downsampler.peekFinalized() == null && downsampler.peekPending() == null); in runFractionalDownsamplerTest()
[all …]
|
| /dports/databases/opentsdb/opentsdb-2.3.0/test/core/ |
| H A D | TestFillingDownsampler.java | 40 private Downsampler downsampler; field in TestFillingDownsampler
98 step(downsampler, timestamp, 0.); in testZeroMissingInterval()
227 step(downsampler, 0, 63); in testDownsampler_allFullRange()
306 while (downsampler.hasNext()) { in testDownsampler_calendarHour()
328 while (downsampler.hasNext()) { in testDownsampler_calendarHour()
352 while (downsampler.hasNext()) { in testDownsampler_calendarHour()
380 while (downsampler.hasNext()) { in testDownsampler_calendarDay()
404 while (downsampler.hasNext()) { in testDownsampler_calendarDay()
432 while (downsampler.hasNext()) { in testDownsampler_calendarDay()
458 while (downsampler.hasNext()) { in testDownsampler_calendarDay()
[all …]
|
| H A D | TestDownsampler.java | 69 private Downsampler downsampler; field in TestDownsampler
84 while (downsampler.hasNext()) { in testDownsampler()
123 while (downsampler.hasNext()) { in testDownsamplerDeprecated_10seconds()
165 while (downsampler.hasNext()) { in testDownsampler_10seconds()
201 while (downsampler.hasNext()) { in testDownsamplerDeprecated_15seconds()
234 while (downsampler.hasNext()) { in testDownsampler_15seconds()
268 while (downsampler.hasNext()) { in testDownsampler_allFullRange()
296 while (downsampler.hasNext()) { in testDownsampler_allFilterOnQuery()
324 while (downsampler.hasNext()) { in testDownsampler_allFilterOnQueryOutOfRangeEarly()
1249 downsampler.next(); in testSeek_doubleIteration()
[all …]
|
| /dports/databases/opentsdb/opentsdb-2.3.0/test/query/pojo/ |
| H A D | TestDownsampler.java | 29 downsampler.validate(); in validationErrorWhenIntervalIsNull()
36 downsampler.validate(); in validationErrorWhenIntervalIsEmpty()
43 downsampler.validate(); in validationErrorWhenIntervalIsInvalid()
50 downsampler.validate(); in validationErrorWhenAggregatorIsNull()
57 downsampler.validate(); in validationErrorWhenAggregatorIsEmpty()
64 downsampler.validate(); in validationErrorWhenAggregatorIsInvalid()
71 downsampler.validate(); in deserialize()
74 assertEquals(expected, downsampler); in deserialize()
79 downsampler.validate(); in deserialize()
83 assertEquals(expected, downsampler); in deserialize()
[all …]
|
| /dports/graphics/mirtk/MIRTK-2.0.0-122-g38210fa/Modules/Image/src/ |
| H A D | VelocityToDisplacementFieldSS.cc | 213 downsampler.Input(_Displacement); in Run()
214 downsampler.Output(dout); in Run()
215 downsampler.Run(); in Run()
222 downsampler.Input(_Displacement); in Run()
223 downsampler.Output(dout); in Run()
224 downsampler.Run(); in Run()
250 downsampler.Input(_Displacement); in Run()
251 downsampler.Output(dout); in Run()
252 downsampler.Run(); in Run()
260 downsampler.Output(dout); in Run()
[all …]
|
| /dports/biology/gatk/gatk-4.2.0.0/src/main/java/org/broadinstitute/hellbender/utils/locusiterator/ |
| H A D | SamplePartitioner.java | 85 final Downsampler<GATKRead> downsampler = readsBySample.get(sampleName); in submitRead() local
86 …Utils.validate(downsampler != null, () -> "Offered read with sample name " + sampleName + " to Sam… in submitRead()
89 downsampler.submit(read); in submitRead()
101 for ( final Downsampler<GATKRead> downsampler : readsBySample.values() ) { in doneSubmittingReads()
102 downsampler.signalEndOfInput(); in doneSubmittingReads()
124 final Downsampler<GATKRead> downsampler = readsBySample.get(sampleName); in getReadsForSample() local
125 if ( downsampler == null ) throw new NoSuchElementException("Sample name not found"); in getReadsForSample()
127 return downsampler.consumeFinalizedItems(); in getReadsForSample()
135 for ( final Downsampler<GATKRead> downsampler : readsBySample.values() ) { in reset()
136 downsampler.clearItems(); in reset()
[all …]
|
| /dports/databases/opentsdb/opentsdb-2.3.0/src/query/pojo/ |
| H A D | Timespan.java | 43 private Downsampler downsampler; field in Timespan
59 downsampler = builder.downsampler; in Timespan()
81 return downsampler; in getDownsampler()
103 return Objects.equal(timespan.downsampler, downsampler) in equals()
113 return Objects.hashCode(start, end, timezone, downsampler, aggregator, rate); in hashCode()
134 if (downsampler != null) { in validate()
135 downsampler.validate(); in validate()
165 private Downsampler downsampler; field in Timespan.Builder
189 this.downsampler = downsample; in setDownsampler()
|
| H A D | Downsampler.java | 102 final Downsampler downsampler = (Downsampler) o; in equals()
104 return Objects.equal(interval, downsampler.interval) in equals()
105 && Objects.equal(aggregator, downsampler.aggregator) in equals()
106 && Objects.equal(fill_policy, downsampler.fill_policy); in equals()
|
| /dports/biology/gatk/gatk-4.2.0.0/src/main/java/org/broadinstitute/hellbender/tools/ |
| H A D | DownsampleableSparkReadShard.java | 21 private final ReadsDownsampler downsampler; field in DownsampleableSparkReadShard
28 …nal ShardBoundary boundaries, final Iterable<GATKRead> reads, final ReadsDownsampler downsampler) { in DownsampleableSparkReadShard() argument
31 this.downsampler = downsampler; in DownsampleableSparkReadShard()
48 if ( downsampler != null ) { in iterator()
49 readsIterator = new ReadsDownsamplingIterator(readsIterator, downsampler); in iterator()
|
| /dports/www/grafana8/grafana-8.3.6/pkg/expr/mathexp/ |
| H A D | resample_test.go | 16 downsampler string
25 downsampler: "mean",
40 downsampler: "mean",
55 downsampler: "mean",
83 downsampler: "max",
111 downsampler: "min",
139 downsampler: "sum",
167 downsampler: "mean",
195 downsampler: "mean",
223 downsampler: "mean",
[all …]
|
| H A D | resample.go | 11 func (s Series) Resample(refID string, interval time.Duration, downsampler string, upsampler string…
61 switch downsampler {
71 return s, fmt.Errorf("downsampling %v not implemented", downsampler)
|
| /dports/biology/gatk/gatk-4.2.0.0/src/main/java/org/broadinstitute/hellbender/engine/ |
| H A D | MultiIntervalLocalReadShard.java | 38 private ReadsDownsampler downsampler; field in MultiIntervalLocalReadShard
110 public void setDownsampler(final ReadsDownsampler downsampler) { in setDownsampler() argument
111 this.downsampler = downsampler; in setDownsampler()
148 if ( downsampler != null ) { in iterator()
149 readsIterator = new ReadsDownsamplingIterator(readsIterator, downsampler); in iterator()
|
| /dports/databases/opentsdb/opentsdb-2.3.0/src/core/ |
| H A D | SpanGroup.java | 95 private DownsamplingSpecification downsampler; field in SpanGroup
130 final long interval, final Aggregator downsampler) { in SpanGroup() argument
133 downsampler); in SpanGroup()
159 final long interval, final Aggregator downsampler) { in SpanGroup() argument
161 interval, downsampler, -1, FillPolicy.NONE); in SpanGroup()
193 downsampler != null ? in SpanGroup()
194 new DownsamplingSpecification(interval, downsampler, fill_policy) : in SpanGroup()
225 final DownsamplingSpecification downsampler, in SpanGroup() argument
242 this.downsampler = downsampler; in SpanGroup()
489 downsampler, query_start, query_end, in iterator()
[all …]
|
| H A D | AggregationIterator.java | 221 final Aggregator downsampler, in create() argument
225 return create(spans, start_time, end_time, aggregator, method, downsampler, in create()
256 final Aggregator downsampler, in create() argument
265 if (downsampler == null) { in create()
268 it = spans.get(i).downsampler(start_time, end_time, sample_interval_ms, in create()
269 downsampler, fill_policy); in create()
304 final DownsamplingSpecification downsampler, in create() argument
313 if (downsampler == null || in create()
314 downsampler == DownsamplingSpecification.NO_DOWNSAMPLER) { in create()
317 it = spans.get(i).downsampler(start_time, end_time, downsampler, in create()
|
| H A D | Span.java | 472 Downsampler downsampler(final long start_time, in downsampler() method in Span
475 final Aggregator downsampler, in downsampler() argument
480 return new Downsampler(spanIterator(), interval_ms, downsampler); in downsampler()
485 interval_ms, downsampler, fill_policy); in downsampler()
498 Downsampler downsampler(final long start_time, in downsampler() method in Span
500 final DownsamplingSpecification downsampler, in downsampler() argument
503 if (downsampler == null) { in downsampler()
506 if (FillPolicy.NONE == downsampler.getFillPolicy()) { in downsampler()
507 return new Downsampler(spanIterator(), downsampler, in downsampler()
511 downsampler, query_start, query_end); in downsampler()
|
| H A D | TsdbQuery.java | 123 private DownsamplingSpecification downsampler; field in TsdbQuery
338 downsampler = sub_query.downsamplingSpecification(); in configureFromQuery()
399 this.downsampler = new DownsamplingSpecification( in downsample()
400 interval, downsampler,fill_policy); in downsample()
412 if (downsampler == Aggregators.NONE) { in downsample()
416 downsample(interval, downsampler, FillPolicy.NONE); in downsample()
923 downsampler, in call()
992 downsampler, in call()
1076 if (downsampler != null && downsampler.getInterval() > 0) { in getScanStartTimeSeconds()
1108 if (downsampler != null && downsampler.getInterval() > 0) { in getScanEndTimeSeconds()
[all …]
|
| H A D | Query.java | 188 void downsample(long interval, Aggregator downsampler); in downsample() argument
200 void downsample(long interval, Aggregator downsampler, FillPolicy fill_policy); in downsample() argument
|
| /dports/www/grafana8/grafana-8.3.6/public/app/features/expressions/components/ |
| H A D | Resample.tsx | 14 const downsampler = downsamplingTypes.find((o) => o.value === query.downsampler);
26 onChange({ ...query, downsampler: value.value });
48 value={downsampler}
|
| /dports/databases/opentsdb/opentsdb-2.3.0/src/tsd/client/ |
| H A D | MetricForm.java | 54 private final ListBox downsampler = new ListBox(); field in MetricForm
70 downsampler.addChangeHandler(handler); in MetricForm()
267 downsampler.setEnabled(true); in updateFromQueryString()
297 downsampler.setEnabled(false); in disableDownsample()
359 hbox.add(downsampler); in assembleUi()
377 downsampler.addItem((String)agg); in setAggregators()
381 setSelectedItem(downsampler, "avg"); in setAggregators()
401 .append('-').append(selectedValue(downsampler)) in buildQueryString()
660 downsampler.setEnabled(false); in setupDownsampleWidgets()
670 downsampler.setEnabled(checked); in setupDownsampleWidgets()
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/pkg/expr/ |
| H A D | commands.go | 146 func NewResampleCommand(refID, rawWindow, varToResample string, downsampler string, upsampler strin…
155 Downsampler: downsampler,
188 downsampler, ok := rawDownsampler.(string)
190 …rf("expected resample downsampler to be a string, got type %T for refId %v", downsampler, rn.RefID)
202 return NewResampleCommand(rn.RefID, window, varToResample, downsampler, upsampler, rn.TimeRange)
|
| /dports/biology/gatk/gatk-4.2.0.0/src/main/java/org/broadinstitute/hellbender/utils/downsampling/ |
| H A D | ReadsDownsamplingIterator.java | 20 public ReadsDownsamplingIterator(Iterator<GATKRead> iter, ReadsDownsampler downsampler) { in ReadsDownsamplingIterator() argument
21 super(iter, downsampler); in ReadsDownsamplingIterator()
|
| /dports/www/grafana8/grafana-8.3.6/public/app/features/expressions/utils/ |
| H A D | expressionTypes.ts | 15 if (!query.downsampler) {
16 query.downsampler = ReducerID.mean;
|