Class InternalAggregationTestCase<T extends org.opensearch.search.aggregations.InternalAggregation>

java.lang.Object

org.junit.Assert

org.apache.lucene.tests.util.LuceneTestCase

org.opensearch.test.OpenSearchTestCase

org.opensearch.test.AbstractWireTestCase<T>

org.opensearch.test.AbstractNamedWriteableTestCase<T>

org.opensearch.test.InternalAggregationTestCase<T>

Direct Known Subclasses:

InternalMultiBucketAggregationTestCase, InternalSingleBucketAggregationTestCase

public abstract class InternalAggregationTestCase<T extends org.opensearch.search.aggregations.InternalAggregation>
extends AbstractNamedWriteableTestCase<T>

Implementors of this test case should be aware that the aggregation under test needs to be registered in the test's namedWriteableRegistry. Core aggregations are registered already, but non-core aggs should override registerPlugin() so that the NamedWriteables can be extracted from the AggregatorSpecs in the plugin (as well as any other custom NamedWriteables)

Nested Class Summary

Nested classes/interfaces inherited from class org.opensearch.test.OpenSearchTestCase

OpenSearchTestCase.AnnotatedFeatureFlagRule, OpenSearchTestCase.GeohashGenerator, OpenSearchTestCase.LockFeatureFlag, OpenSearchTestCase.TestAnalysis

Nested classes/interfaces inherited from class org.apache.lucene.tests.util.LuceneTestCase

org.apache.lucene.tests.util.LuceneTestCase.AwaitsFix, org.apache.lucene.tests.util.LuceneTestCase.Concurrency, org.apache.lucene.tests.util.LuceneTestCase.Monster, org.apache.lucene.tests.util.LuceneTestCase.Nightly, org.apache.lucene.tests.util.LuceneTestCase.SuppressCodecs, org.apache.lucene.tests.util.LuceneTestCase.SuppressFileSystems, org.apache.lucene.tests.util.LuceneTestCase.SuppressFsync, org.apache.lucene.tests.util.LuceneTestCase.SuppressReproduceLine, org.apache.lucene.tests.util.LuceneTestCase.SuppressSysoutChecks, org.apache.lucene.tests.util.LuceneTestCase.SuppressTempFileChecks, org.apache.lucene.tests.util.LuceneTestCase.ThrowingConsumer<T>, org.apache.lucene.tests.util.LuceneTestCase.ThrowingRunnable, org.apache.lucene.tests.util.LuceneTestCase.Weekly

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_MAX_BUCKETS
protected static final double	TOLERANCE

Fields inherited from class org.opensearch.test.AbstractWireTestCase

NUMBER_OF_TEST_RUNS

Fields inherited from class org.opensearch.test.OpenSearchTestCase

checkIndexFailures, DEFAULT_NAMED_WRITABLE_REGISTRY, DEFAULT_TEST_WORKER_ID, failureAndSuccessEvents, flagLockRule, JAVA_TIMEZONE_IDS, JAVA_ZONE_IDS, JODA_TIMEZONE_IDS, logger, TEST_WORKER_SYS_PROPERTY, TEST_WORKER_VM_ID

Fields inherited from class org.apache.lucene.tests.util.LuceneTestCase

assertsAreEnabled, classRules, DEFAULT_LINE_DOCS_FILE, INFOSTREAM, JENKINS_LARGE_LINE_DOCS_FILE, LEAVE_TEMPORARY, MAYBE_CACHE_POLICY, RANDOM_MULTIPLIER, ruleChain, suiteFailureMarker, SYSPROP_AWAITSFIX, SYSPROP_FAILFAST, SYSPROP_MAXFAILURES, SYSPROP_MONSTER, SYSPROP_NIGHTLY, SYSPROP_WEEKLY, TEST_ASSERTS_ENABLED, TEST_AWAITSFIX, TEST_CODEC, TEST_DIRECTORY, TEST_DOCVALUESFORMAT, TEST_LINE_DOCS_FILE, TEST_MONSTER, TEST_NIGHTLY, TEST_POSTINGSFORMAT, TEST_THROTTLING, TEST_WEEKLY, VERBOSE

Constructor Summary

Constructors

Constructor	Description
InternalAggregationTestCase()

Method Summary

Modifier and Type	Method	Description
protected abstract void	assertFromXContent(T aggregation, org.opensearch.search.aggregations.ParsedAggregation parsedAggregation)
static void	assertMultiBucketConsumer(org.opensearch.search.aggregations.Aggregation agg, org.opensearch.search.aggregations.MultiBucketConsumerService.MultiBucketConsumer bucketConsumer)
protected abstract void	assertReduced(T reduced, List<T> inputs)
protected final Class<T>	categoryClass()	The type of NamedWriteable to read.
final T	createTestInstance()	Creates a random test instance to use in the tests.
protected abstract T	createTestInstance(String name, Map<String,Object> metadata)
T	createTestInstanceForXContent()
final Map<String,Object>	createTestMetadata()
protected final T	createUnmappedInstance(String name)	Return an instance on an unmapped field.
protected T	createUnmappedInstance(String name, Map<String,Object> metadata)	Return an instance on an unmapped field.
protected void	doAssertReducedMultiBucketConsumer(org.opensearch.search.aggregations.Aggregation agg, org.opensearch.search.aggregations.MultiBucketConsumerService.MultiBucketConsumer bucketConsumer)
static org.opensearch.search.aggregations.InternalAggregation.ReduceContextBuilder	emptyReduceContextBuilder()	Builds an InternalAggregation.ReduceContextBuilder that is valid but empty.
static org.opensearch.search.aggregations.InternalAggregation.ReduceContextBuilder	emptyReduceContextBuilder(org.opensearch.search.aggregations.pipeline.PipelineAggregator.PipelineTree pipelineTree)	Builds an InternalAggregation.ReduceContextBuilder that is valid and nearly empty except that it contain PipelineAggregators.
protected Predicate<String>	excludePathsFromXContentInsertion()	Overwrite this in your test if other than the basic xContent paths should be excluded during insertion of random fields
static List<org.opensearch.core.xcontent.NamedXContentRegistry.Entry>	getDefaultNamedXContents()
protected final org.opensearch.core.common.io.stream.NamedWriteableRegistry	getNamedWriteableRegistry()	Get the NamedWriteableRegistry to use when de-serializing the object.
protected List<org.opensearch.core.common.io.stream.NamedWriteableRegistry.Entry>	getNamedWriteables()	Implementors can override this if they want to provide a custom list of namedWriteables.
protected List<org.opensearch.core.xcontent.NamedXContentRegistry.Entry>	getNamedXContents()
protected org.opensearch.script.ScriptService	mockScriptService()	overwrite in tests that need it
protected <P extends org.opensearch.search.aggregations.ParsedAggregation> P	parseAndAssert(org.opensearch.search.aggregations.InternalAggregation aggregation, boolean shuffled, boolean addRandomFields)
protected static org.opensearch.search.DocValueFormat	randomNumericDocValueFormat()
protected List<T>	randomResultsToReduce(String name, int size)	Generate a list of inputs to reduce.
protected org.opensearch.plugins.SearchPlugin	registerPlugin()	If a test needs to register additional aggregation specs for namedWriteable, etc, this method can be overridden by the implementor.
final void	testFromXContent()
final void	testFromXContentWithRandomFields()
void	testReduceRandom()
protected org.opensearch.core.xcontent.NamedXContentRegistry	xContentRegistry()	The NamedXContentRegistry to use for this test.

Methods inherited from class org.opensearch.test.AbstractNamedWriteableTestCase

copyInstance

Methods inherited from class org.opensearch.test.AbstractWireTestCase

assertEqualInstances, assertSerialization, assertSerialization, copyInstance, mutateInstance, testEqualsAndHashcode, testSerialization

Methods inherited from class org.opensearch.test.OpenSearchTestCase

after, afterIfFailed, afterIfSuccessful, allowedWarnings, assertArrayEquals, assertBusy, assertBusy, assertBusyWithFixedSleepTime, assertEquals, assertNoDeprecationWarnings, assertSettingDeprecationsAndWarnings, assertSettingDeprecationsAndWarnings, assertWarnings, assertWarnings, before, between, buildEnvSettings, buildNewFakeTransportAddress, checkStaticState, clearAdditionalRoles, copyInstance, copyNamedWriteable, copyNamedWriteable, copyWriteable, copyWriteable, createDefaultIndexAnalyzers, createParser, createParser, createParser, createParser, createParser, createParser, createTestAnalysis, createTestAnalysis, createTestAnalysis, enableJodaDeprecationWarningsCheck, enableWarningsCheck, ensureAllSearchContextsReleased, ensureCheckIndexPassed, ensureSupportedLocale, frequently, generateRandomStringArray, generateRandomStringArray, getBasePort, getBasePort, getDataPath, getPortRange, getShardLevelBlobPath, getSuiteFailureMarker, getTestTransportPlugin, getTestTransportType, inFipsJvm, iterations, maybeSet, mockScript, newNodeEnvironment, newNodeEnvironment, persistedStateRegistry, randomAlphaOfLength, randomAlphaOfLengthBetween, randomArray, randomArray, randomBigInteger, randomBoolean, randomByte, randomByteArrayOfLength, randomDateFormatterPattern, randomDateTimeZone, randomDouble, randomDoubleBetween, randomFloat, randomFrom, randomFrom, randomFrom, randomFrom, randomFrom, randomGeohash, randomInt, randomInt, randomIntBetween, randomIp, randomList, randomList, randomLong, randomLongBetween, randomNonNegativeInt, randomNonNegativeLong, randomPositiveTimeValue, randomRealisticUnicodeOfCodepointLength, randomRealisticUnicodeOfCodepointLengthBetween, randomRealisticUnicodeOfLength, randomRealisticUnicodeOfLengthBetween, randomShort, randomSubsetOf, randomSubsetOf, randomSubsetOf, randomTimeValue, randomTimeValue, randomTimeValue, randomTimeZone, randomUnicodeOfCodepointLength, randomUnicodeOfCodepointLengthBetween, randomUnicodeOfLength, randomUnicodeOfLengthBetween, randomUnique, randomUnsignedLong, randomValueOtherThan, randomValueOtherThanMany, randomZone, remoteIndexSettings, removeHeaderWarningAppender, replaceUnicodeControlCharacters, replaceUnicodeControlCharacters, resetCheckIndexStatus, resetPortCounter, restoreContentType, restoreFileSystem, scaledRandomIntBetween, setContentType, setFileSystem, setHeaderWarningAppender, settings, shuffleMap, shuffleXContent, shuffleXContent, spinForAtLeastNMilliseconds, spinForAtLeastOneMillisecond, tearDown, terminate, terminate, tmpPaths, toShuffledXContent, toShuffledXContent, waitUntil, waitUntil, warmIndexSettings, writableRegistry

Methods inherited from class org.apache.lucene.tests.util.LuceneTestCase

addVirusChecker, assertDeletedDocsEquals, assertDocsAndPositionsEnumEquals, assertDocsEnumEquals, assertDocsSkippingEquals, assertDocValuesEquals, assertDocValuesEquals, assertDoubleUlpEquals, assertFieldInfosEquals, assertFloatUlpEquals, assertNormsEquals, assertPointsEquals, assertPositionsSkippingEquals, assertReaderEquals, assertReaderStatisticsEquals, assertStoredFieldEquals, assertStoredFieldsEquals, assertTermsEnumEquals, assertTermsEquals, assertTermsEquals, assertTermsStatisticsEquals, assertTermStatsEquals, assertTermVectorsEquals, assertThat, assertThat, asSet, assumeFalse, assumeNoException, assumeTrue, atLeast, atLeast, callStackContains, callStackContains, callStackContainsAnyOf, closeAfterSuite, closeAfterTest, collate, createTempDir, createTempDir, createTempFile, createTempFile, dumpArray, dumpIterator, ensureSaneIWCOnNightly, expectThrows, expectThrows, expectThrows, expectThrowsAnyOf, expectThrowsAnyOf, getDataInputStream, getJvmForkArguments, getOnlyLeafReader, getTestClass, getTestName, isTestThread, localeForLanguageTag, maybeChangeLiveIndexWriterConfig, maybeWrapReader, newAlcoholicMergePolicy, newAlcoholicMergePolicy, newBytesRef, newBytesRef, newBytesRef, newBytesRef, newBytesRef, newBytesRef, newDirectory, newDirectory, newDirectory, newDirectory, newDirectory, newField, newField, newFSDirectory, newFSDirectory, newIndexWriterConfig, newIndexWriterConfig, newIndexWriterConfig, newIOContext, newIOContext, newLogMergePolicy, newLogMergePolicy, newLogMergePolicy, newLogMergePolicy, newLogMergePolicy, newMaybeVirusCheckingDirectory, newMaybeVirusCheckingFSDirectory, newMergePolicy, newMergePolicy, newMergePolicy, newMockDirectory, newMockDirectory, newMockDirectory, newMockFSDirectory, newMockFSDirectory, newSearcher, newSearcher, newSearcher, newSearcher, newSearcher, newSnapshotIndexWriterConfig, newStringField, newStringField, newStringField, newStringField, newTextField, newTextField, newTieredMergePolicy, newTieredMergePolicy, overrideDefaultQueryCache, overrideTestDefaultQueryCache, random, randomLocale, randomTimeZone, randomVectorFormat, rarely, rarely, replaceMaxFailureRule, resetDefaultQueryCache, restoreCPUCoreCount, restoreIndexWriterMaxDocs, runWithRestrictedPermissions, setIndexWriterMaxDocs, setUp, setupCPUCoreCount, setUpExecutorService, shutdownExecutorService, slowFileExists, usually, usually, wrapReader

Methods inherited from class org.junit.Assert

assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertArrayEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertFalse, assertFalse, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotNull, assertNotNull, assertNotSame, assertNotSame, assertNull, assertNull, assertSame, assertSame, assertThrows, assertThrows, assertTrue, assertTrue, fail, fail

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

DEFAULT_MAX_BUCKETS

public static final int DEFAULT_MAX_BUCKETS

See Also:

• Constant Field Values

TOLERANCE

protected static final double TOLERANCE

See Also:

• Constant Field Values

Constructor Details

InternalAggregationTestCase

public InternalAggregationTestCase()

Method Details

emptyReduceContextBuilder

public static org.opensearch.search.aggregations.InternalAggregation.ReduceContextBuilder emptyReduceContextBuilder()

Builds an InternalAggregation.ReduceContextBuilder that is valid but empty.

emptyReduceContextBuilder

public static org.opensearch.search.aggregations.InternalAggregation.ReduceContextBuilder emptyReduceContextBuilder(org.opensearch.search.aggregations.pipeline.PipelineAggregator.PipelineTree pipelineTree)

Builds an InternalAggregation.ReduceContextBuilder that is valid and nearly empty except that it contain PipelineAggregators.

getDefaultNamedXContents

public static List<org.opensearch.core.xcontent.NamedXContentRegistry.Entry> getDefaultNamedXContents()

getNamedXContents

protected List<org.opensearch.core.xcontent.NamedXContentRegistry.Entry> getNamedXContents()

xContentRegistry

protected org.opensearch.core.xcontent.NamedXContentRegistry xContentRegistry()

Description copied from class: OpenSearchTestCase

The NamedXContentRegistry to use for this test. Subclasses should override and use liberally.

Overrides:

xContentRegistry in class OpenSearchTestCase

getNamedWriteableRegistry

protected final org.opensearch.core.common.io.stream.NamedWriteableRegistry getNamedWriteableRegistry()

Description copied from class: AbstractWireTestCase

Get the NamedWriteableRegistry to use when de-serializing the object.

Override this method if you need to register NamedWriteables for the test object to de-serialize.

By default this will return a NamedWriteableRegistry with no registered NamedWriteables

Specified by:

getNamedWriteableRegistry in class AbstractNamedWriteableTestCase<T extends org.opensearch.search.aggregations.InternalAggregation>

getNamedWriteables

protected List<org.opensearch.core.common.io.stream.NamedWriteableRegistry.Entry> getNamedWriteables()

Implementors can override this if they want to provide a custom list of namedWriteables. If the implementor _just_ wants to register in namedWriteables provided by a plugin, prefer overriding registerPlugin() instead because that route handles the automatic conversion of AggSpecs into namedWriteables.

registerPlugin

protected org.opensearch.plugins.SearchPlugin registerPlugin()

If a test needs to register additional aggregation specs for namedWriteable, etc, this method can be overridden by the implementor.

createTestInstance

protected abstract T createTestInstance(String name,
 Map<String,Object> metadata)

createUnmappedInstance

protected T createUnmappedInstance(String name,
 Map<String,Object> metadata)

Return an instance on an unmapped field.

categoryClass

protected final Class<T> categoryClass()

Description copied from class: AbstractNamedWriteableTestCase

The type of NamedWriteable to read.

Specified by:

categoryClass in class AbstractNamedWriteableTestCase<T extends org.opensearch.search.aggregations.InternalAggregation>

randomResultsToReduce

protected List<T> randomResultsToReduce(String name,
 int size)

Generate a list of inputs to reduce. Defaults to calling createTestInstance(String) and createUnmappedInstance(String) but should be overridden if it isn't realistic to reduce test instances.

testReduceRandom

public void testReduceRandom()
                      throws IOException

Throws:

IOException

doAssertReducedMultiBucketConsumer

protected void doAssertReducedMultiBucketConsumer(org.opensearch.search.aggregations.Aggregation agg,
 org.opensearch.search.aggregations.MultiBucketConsumerService.MultiBucketConsumer bucketConsumer)

mockScriptService

protected org.opensearch.script.ScriptService mockScriptService()

overwrite in tests that need it

assertReduced

protected abstract void assertReduced(T reduced,
 List<T> inputs)

createTestInstance

public final T createTestInstance()

Description copied from class: AbstractWireTestCase

Creates a random test instance to use in the tests. This method will be called multiple times during test execution and should return a different random instance each time it is called.

Specified by:

createTestInstance in class AbstractWireTestCase<T extends org.opensearch.search.aggregations.InternalAggregation>

createTestMetadata

public final Map<String,Object> createTestMetadata()

createUnmappedInstance

protected final T createUnmappedInstance(String name)

Return an instance on an unmapped field.

createTestInstanceForXContent

public T createTestInstanceForXContent()

testFromXContent

public final void testFromXContent()
                            throws IOException

Throws:

IOException

testFromXContentWithRandomFields

public final void testFromXContentWithRandomFields()
                                            throws IOException

Throws:

IOException

assertFromXContent

protected abstract void assertFromXContent(T aggregation,
 org.opensearch.search.aggregations.ParsedAggregation parsedAggregation)
                                    throws IOException

Throws:

IOException

parseAndAssert

protected <P extends org.opensearch.search.aggregations.ParsedAggregation>
P parseAndAssert(org.opensearch.search.aggregations.InternalAggregation aggregation,
 boolean shuffled,
 boolean addRandomFields)
          throws IOException

Throws:

IOException

excludePathsFromXContentInsertion

protected Predicate<String> excludePathsFromXContentInsertion()

Overwrite this in your test if other than the basic xContent paths should be excluded during insertion of random fields

randomNumericDocValueFormat

protected static org.opensearch.search.DocValueFormat randomNumericDocValueFormat()

Returns:

a random DocValueFormat that can be used in aggregations which compute numbers.

assertMultiBucketConsumer

public static void assertMultiBucketConsumer(org.opensearch.search.aggregations.Aggregation agg,
 org.opensearch.search.aggregations.MultiBucketConsumerService.MultiBucketConsumer bucketConsumer)