honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-02-24 22:09:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

Further improve InternalTTestTests (#55081)

Browse Source 
A small follow-up to #54910. Now that we can generated consistent set of
internal aggs to reduce, we no longer need to keep agg parameters as class
variables.

Related to #54910
This commit is contained in:
Igor Motov 2020-04-13 10:26:23 -04:00 committed by GitHub
parent 16921ebbd8
commit 6861295706
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
x-pack/plugin/analytics/src/test/java/org/elasticsearch/xpack/analytics/ttest/InternalTTestTests.java
View File

@ -31,28 +31,28 @@ import static java.util.Collections.emptyList;
public class InternalTTestTests extends InternalAggregationTestCase<InternalTTest> {
private TTestType type = randomFrom(TTestType.values());
private int tails = randomIntBetween(1, 2);
@Override
protected InternalTTest createTestInstance(String name, Map<String, Object> metadata) {
TTestState state = randomState(Long.MAX_VALUE);
TTestState state = randomState(Long.MAX_VALUE, randomFrom(TTestType.values()), randomIntBetween(1, 2));
DocValueFormat formatter = randomNumericDocValueFormat();
return new InternalTTest(name, state, formatter, metadata);
}
@Override
protected List<InternalTTest> randomResultsToReduce(String name, int size) {
TTestType type = randomFrom(TTestType.values());
int tails = randomIntBetween(1, 2);
List<InternalTTest> inputs = new ArrayList<>(size);
for (int i = 0; i < size; i++) {
TTestState state = randomState(Long.MAX_VALUE / size); // Make sure the sum of all the counts doesn't wrap
// Make sure the sum of all the counts doesn't wrap and type and tail parameters are consistent
TTestState state = randomState(Long.MAX_VALUE / size, type, tails);
DocValueFormat formatter = randomNumericDocValueFormat();
inputs.add(new InternalTTest(name, state, formatter, null));
}
return inputs;
}
private TTestState randomState(long maxCount) {
private TTestState randomState(long maxCount, TTestType type, int tails) {
if (type == TTestType.PAIRED) {
return new PairedTTestState(randomStats(maxCount), tails);
} else {
@ -100,7 +100,7 @@ public class InternalTTestTests extends InternalAggregationTestCase<InternalTTes
name += randomAlphaOfLength(5);
break;
case 1:
state = randomState(Long.MAX_VALUE);
state = randomState(Long.MAX_VALUE, randomFrom(TTestType.values()), randomIntBetween(1, 2));
break;
case 2:
if (metadata == null) {