Package org.elasticsearch.test

Class InternalAggregationTestCase<T extends InternalAggregation>

java.lang.Object

org.junit.Assert

org.apache.lucene.util.LuceneTestCase

org.elasticsearch.test.ESTestCase

org.elasticsearch.test.AbstractWireTestCase<T>

org.elasticsearch.test.AbstractWireSerializingTestCase<T>

org.elasticsearch.test.InternalAggregationTestCase<T>

Direct Known Subclasses:

InternalMultiBucketAggregationTestCase, InternalSingleBucketAggregationTestCase

public abstract class InternalAggregationTestCase<T extends InternalAggregation>
extends AbstractWireSerializingTestCase<T>

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.test.ESTestCase

ESTestCase.GeohashGenerator, ESTestCase.TestAnalysis

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

org.apache.lucene.util.LuceneTestCase.AwaitsFix, org.apache.lucene.util.LuceneTestCase.BadApple, org.apache.lucene.util.LuceneTestCase.Monster, org.apache.lucene.util.LuceneTestCase.Nightly, org.apache.lucene.util.LuceneTestCase.Slow, org.apache.lucene.util.LuceneTestCase.SuppressCodecs, org.apache.lucene.util.LuceneTestCase.SuppressFileSystems, org.apache.lucene.util.LuceneTestCase.SuppressFsync, org.apache.lucene.util.LuceneTestCase.SuppressReproduceLine, org.apache.lucene.util.LuceneTestCase.SuppressSysoutChecks, org.apache.lucene.util.LuceneTestCase.SuppressTempFileChecks, org.apache.lucene.util.LuceneTestCase.ThrowingRunnable, org.apache.lucene.util.LuceneTestCase.Weekly

Field Summary

Fields

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

Fields inherited from class org.elasticsearch.test.AbstractWireTestCase

NUMBER_OF_TEST_RUNS

Fields inherited from class org.elasticsearch.test.ESTestCase

checkIndexFailed, deprecationLogger, failureAndSuccessEvents, logger

Fields inherited from class org.apache.lucene.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_BADAPPLES, SYSPROP_FAILFAST, SYSPROP_MAXFAILURES, SYSPROP_MONSTER, SYSPROP_NIGHTLY, SYSPROP_SLOW, SYSPROP_WEEKLY, TEST_ASSERTS_ENABLED, TEST_AWAITSFIX, TEST_BADAPPLES, TEST_CODEC, TEST_DIRECTORY, TEST_DOCVALUESFORMAT, TEST_LINE_DOCS_FILE, TEST_MONSTER, TEST_NIGHTLY, TEST_POSTINGSFORMAT, TEST_SLOW, TEST_THROTTLING, TEST_WEEKLY, VERBOSE

Constructor Summary

Constructors

Constructor	Description
InternalAggregationTestCase()

Method Summary

Modifier and Type	Method	Description
protected abstract void	assertFromXContent(T aggregation, ParsedAggregation parsedAggregation)
static void	assertMultiBucketConsumer(Aggregation agg, MultiBucketConsumerService.MultiBucketConsumer bucketConsumer)
protected abstract void	assertReduced(T reduced, java.util.List<T> inputs)
T	createTestInstance()	Creates a random test instance to use in the tests.
protected abstract T	createTestInstance(java.lang.String name, java.util.List<PipelineAggregator> pipelineAggregators, java.util.Map<java.lang.String,java.lang.Object> metaData)
protected T	createUnmappedInstance(java.lang.String name)	Return an instance on an unmapped field.
protected T	createUnmappedInstance(java.lang.String name, java.util.List<PipelineAggregator> pipelineAggregators, java.util.Map<java.lang.String,java.lang.Object> metaData)	Return an instance on an unmapped field.
protected java.util.function.Predicate<java.lang.String>	excludePathsFromXContentInsertion()	Overwrite this in your test if other than the basic xContent paths should be excluded during insertion of random fields
static java.util.List<NamedXContentRegistry.Entry>	getDefaultNamedXContents()
protected NamedWriteableRegistry	getNamedWriteableRegistry()	Get the NamedWriteableRegistry to use when de-serializing the object.
protected java.util.List<NamedXContentRegistry.Entry>	getNamedXContents()
protected ScriptService	mockScriptService()	overwrite in tests that need it
protected <P extends ParsedAggregation> P	parseAndAssert(InternalAggregation aggregation, boolean shuffled, boolean addRandomFields)
protected static DocValueFormat	randomNumericDocValueFormat()
void	testFromXContent()
void	testFromXContentWithRandomFields()
void	testReduceRandom()
protected NamedXContentRegistry	xContentRegistry()	The NamedXContentRegistry to use for this test.

Methods inherited from class org.elasticsearch.test.AbstractWireSerializingTestCase

copyInstance

Methods inherited from class org.elasticsearch.test.AbstractWireTestCase

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

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, assertThat, assertThat, assertTrue, assertTrue, fail, fail

Methods inherited from class org.elasticsearch.test.ESTestCase

after, afterIfFailed, afterIfSuccessful, assertAllIndicesRemovedAndDeletionCompleted, assertArrayEquals, assertBusy, assertBusy, assertEquals, assertEqualsWithErrorMessageFromXContent, assertPathHasBeenCleared, assertSettingDeprecationsAndWarnings, assertSettingDeprecationsAndWarnings, assertWarnings, awaitBusy, awaitBusy, before, between, buildNewFakeTransportAddress, checkStaticState, copyStreamable, copyWriteable, copyWriteable, createParser, createParser, createParser, createParser, createParser, createTestAnalysis, createTestAnalysis, createTestAnalysis, enableWarningsCheck, ensureAllSearchContextsReleased, ensureCheckIndexPassed, frequently, generateRandomStringArray, generateRandomStringArray, getBwcIndicesPath, getDataPath, getSuiteFailureMarker, getTestTransportPlugin, getTestTransportType, iterations, maybeSet, mockScript, newNodeEnvironment, newNodeEnvironment, newTestIndicesModule, newTestScriptModule, randomAlphaOfLength, randomAlphaOfLengthBetween, randomBoolean, randomByte, randomByteArrayOfLength, randomDateTimeZone, randomDouble, randomDoubleBetween, randomFloat, randomFrom, randomFrom, randomFrom, randomFrom, randomFrom, randomGeohash, randomInt, randomInt, randomIntBetween, randomLong, randomLongBetween, randomNonNegativeLong, randomPositiveTimeValue, randomRealisticUnicodeOfCodepointLength, randomRealisticUnicodeOfCodepointLengthBetween, randomRealisticUnicodeOfLength, randomRealisticUnicodeOfLengthBetween, randomShort, randomSubsetOf, randomSubsetOf, randomSubsetOf, randomTimeValue, randomTimeValue, randomTimeValue, randomTimeZone, randomUnicodeOfCodepointLength, randomUnicodeOfCodepointLengthBetween, randomUnicodeOfLength, randomUnicodeOfLengthBetween, randomUnique, randomValueOtherThan, randomValueOtherThanMany, resetCheckIndexStatus, resetPortCounter, restoreContentType, restoreFileSystem, scaledRandomIntBetween, setContentType, setFileSystem, settings, setUseNio, shuffleMap, shuffleXContent, shuffleXContent, spinForAtLeastNMilliseconds, spinForAtLeastOneMillisecond, terminate, terminate, tmpPaths, toShuffledXContent, toShuffledXContent, writableRegistry

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

addVirusChecker, assertDeletedDocsEquals, assertDocsAndPositionsEnumEquals, assertDocsEnumEquals, assertDocsSkippingEquals, assertDocValuesEquals, assertDocValuesEquals, assertFieldInfosEquals, assertFieldsEquals, assertFieldStatisticsEquals, assertNormsEquals, assertPointsEquals, assertPositionsSkippingEquals, assertReaderEquals, assertReaderStatisticsEquals, assertStoredFieldEquals, assertStoredFieldsEquals, assertTermsEnumEquals, assertTermsEquals, assertTermsStatisticsEquals, assertTermStatsEquals, assertTermVectorsEquals, asSet, assumeFalse, assumeNoException, assumeTrue, assumeWorkingMMapOnWindows, atLeast, atLeast, closeAfterSuite, closeAfterTest, collate, createTempDir, createTempDir, createTempFile, createTempFile, dumpArray, dumpIterator, expectThrows, expectThrows, getBaseTempDirForTestClass, getDataInputStream, getOnlyLeafReader, getTestClass, getTestName, hasWorkingMMapOnWindows, isTestThread, localeForLanguageTag, maybeChangeLiveIndexWriterConfig, maybeWrapReader, newAlcoholicMergePolicy, newAlcoholicMergePolicy, newDirectory, newDirectory, newDirectory, newDirectory, newDirectory, newField, newField, newFSDirectory, newFSDirectory, newIndexWriterConfig, newIndexWriterConfig, newIndexWriterConfig, newIOContext, newIOContext, newLogMergePolicy, newLogMergePolicy, newLogMergePolicy, newLogMergePolicy, newLogMergePolicy, newMaybeVirusCheckingDirectory, newMaybeVirusCheckingFSDirectory, newMergePolicy, newMergePolicy, newMockDirectory, newMockDirectory, newMockDirectory, newMockFSDirectory, newMockFSDirectory, newSearcher, newSearcher, newSearcher, newStringField, newStringField, newStringField, newStringField, newTextField, newTextField, newTieredMergePolicy, newTieredMergePolicy, overrideDefaultQueryCache, overrideTestDefaultQueryCache, random, randomLocale, randomTimeZone, rarely, rarely, replaceMaxFailureRule, resetDefaultQueryCache, restoreCPUCoreCount, restoreIndexWriterMaxDocs, restoreSpins, runWithRestrictedPermissions, setIndexWriterMaxDocs, setUp, setupCPUCoreCount, setupSpins, slowFileExists, tearDown, usually, usually, wrapReader

Methods inherited from class java.lang.Object

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

Field Detail

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 Detail

InternalAggregationTestCase

public InternalAggregationTestCase()

Method Detail

getDefaultNamedXContents

public static java.util.List<NamedXContentRegistry.Entry> getDefaultNamedXContents()

getNamedXContents

protected java.util.List<NamedXContentRegistry.Entry> getNamedXContents()

createTestInstance

protected abstract T createTestInstance(java.lang.String name,
                                        java.util.List<PipelineAggregator> pipelineAggregators,
                                        java.util.Map<java.lang.String,java.lang.Object> metaData)

createUnmappedInstance

protected T createUnmappedInstance(java.lang.String name,
                                   java.util.List<PipelineAggregator> pipelineAggregators,
                                   java.util.Map<java.lang.String,java.lang.Object> metaData)

Return an instance on an unmapped field.

testReduceRandom

public void testReduceRandom()

mockScriptService

protected ScriptService mockScriptService()

overwrite in tests that need it

assertReduced

protected abstract void assertReduced(T reduced,
                                      java.util.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 InternalAggregation>

createUnmappedInstance

protected final T createUnmappedInstance(java.lang.String name)

Return an instance on an unmapped field.

getNamedWriteableRegistry

protected 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

Overrides:

getNamedWriteableRegistry in class AbstractWireTestCase<T extends InternalAggregation>

xContentRegistry

protected NamedXContentRegistry xContentRegistry()

Description copied from class: ESTestCase

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

Overrides:

xContentRegistry in class ESTestCase

testFromXContent

public final void testFromXContent()
                            throws java.io.IOException

Throws:

java.io.IOException

testFromXContentWithRandomFields

public final void testFromXContentWithRandomFields()
                                            throws java.io.IOException

Throws:

java.io.IOException

assertFromXContent

protected abstract void assertFromXContent(T aggregation,
                                           ParsedAggregation parsedAggregation)
                                    throws java.io.IOException

Throws:

java.io.IOException

parseAndAssert

protected <P extends ParsedAggregation> P parseAndAssert(InternalAggregation aggregation,
                                                         boolean shuffled,
                                                         boolean addRandomFields)
                                                  throws java.io.IOException

Throws:

java.io.IOException

excludePathsFromXContentInsertion

protected java.util.function.Predicate<java.lang.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 DocValueFormat randomNumericDocValueFormat()

Returns:

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

assertMultiBucketConsumer

public static void assertMultiBucketConsumer(Aggregation agg,
                                             MultiBucketConsumerService.MultiBucketConsumer bucketConsumer)