Package org.apache.solr

Class BaseDistributedSearchTestCase

java.lang.Object

org.junit.Assert

org.apache.lucene.tests.util.LuceneTestCase

org.apache.solr.SolrTestCase

org.apache.solr.SolrTestCaseJ4

org.apache.solr.BaseDistributedSearchTestCase

Direct Known Subclasses:

AbstractFullDistribZkTestBase

public abstract class BaseDistributedSearchTestCase
extends SolrTestCaseJ4

Helper base class for distributed search test cases

By default, for Nightly runs, all tests in sub-classes will execute with 1, 2, ... DEFAULT_MAX_SHARD_COUNT number of shards set up repeatedly. For non-nightly tests, they will execute with 2 shards, to speed up total execution time.

In general, it's preferable to annotate the tests in sub-classes with a @ShardsFixed(num = N) or a @ShardsRepeat(min = M, max = N) to indicate whether the test should be called once, with a fixed number of shards, or called repeatedly for number of shards = M to N.

In some cases though, if the number of shards has to be fixed, but the number itself is dynamic, or if it has to be set as a default for all sub-classes of a sub-class, there's a fixShardCount(N) available, which is identical to @ShardsFixed(num = N) for all tests without annotations in that class hierarchy. Ideally this function should be retired in favour of better annotations..

Since:

solr 1.5

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BaseDistributedSearchTestCase.RandDate
static class	BaseDistributedSearchTestCase.RandVal
static @interface	BaseDistributedSearchTestCase.ShardsFixed
static @interface	BaseDistributedSearchTestCase.ShardsRepeat
class	BaseDistributedSearchTestCase.ShardsRepeatRule

Nested classes/interfaces inherited from class org.apache.solr.SolrTestCaseJ4

SolrTestCaseJ4.BVal, SolrTestCaseJ4.Doc, SolrTestCaseJ4.Fld, SolrTestCaseJ4.FldType, SolrTestCaseJ4.FVal, SolrTestCaseJ4.IRange, SolrTestCaseJ4.IVals, SolrTestCaseJ4.IValsPercent, SolrTestCaseJ4.RandomizingCloudHttp2SolrClientBuilder, SolrTestCaseJ4.RandomizingCloudSolrClientBuilder, SolrTestCaseJ4.SuppressPointFields, SolrTestCaseJ4.SuppressSSL, SolrTestCaseJ4.SVal, SolrTestCaseJ4.Vals, SolrTestCaseJ4.XmlDoc

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
protected final List<org.apache.solr.client.solrj.SolrClient>	clients
protected org.apache.solr.client.solrj.SolrClient	controlClient
protected JettySolrRunner	controlJetty
protected String[]	deadServers
protected ExecutorService	executor
static String[]	fieldNames
protected int	flags
static int	FUZZY	When this flag is set, Double values will be allowed a difference ratio of 1E-8 between the non-distributed and the distributed returned values
protected Map<String,Integer>	handle
protected String	id
protected final List<JettySolrRunner>	jettys
protected int	nThreads
static final int	ORDERED
static Random	r
static BaseDistributedSearchTestCase.RandVal[]	randVals
static BaseDistributedSearchTestCase.RandVal	rdate
static BaseDistributedSearchTestCase.RandVal	rdouble
BaseDistributedSearchTestCase.ShardsRepeatRule	repeatRule
static BaseDistributedSearchTestCase.RandVal	rfloat
static BaseDistributedSearchTestCase.RandVal	rint
static BaseDistributedSearchTestCase.RandVal	rlong
protected String	shards
protected String[]	shardsArr
static final int	SKIP
static final int	SKIPVAL
protected int	stress
protected Path	testDir
static final int	UNORDERED
protected boolean	useExplicitNodeNames
protected boolean	verifyStress

Fields inherited from class org.apache.solr.SolrTestCaseJ4

configString, CORE_PROPERTIES_FILENAME, coreName, DEAD_HOST_1, DEAD_HOST_2, DEAD_HOST_3, DEFAULT_CONNECTION_TIMEOUT, DEFAULT_TEST_COLLECTION_NAME, DEFAULT_TEST_CORENAME, h, lrf, NUMERIC_DOCVALUES_SYSPROP, NUMERIC_POINTS_SYSPROP, ONE_ONE, RANDOMIZED_NUMERIC_FIELDTYPES, schemaString, solrConfig, solrTestRules, sslConfig, SYSTEM_PROPERTY_SOLR_TESTS_MERGEPOLICYFACTORY, TEST_URL_ALLOW_LIST, testExecutor, testSolrHome, UPDATELOG_SYSPROP, USE_NUMERIC_POINTS_SYSPROP, ZERO_ONE, ZERO_TWO

Fields inherited from class org.apache.solr.SolrTestCase

methodRules, solrClassRules

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

Modifier	Constructor	Description
protected	BaseDistributedSearchTestCase()

Method Summary

Modifier and Type	Method	Description
protected org.apache.solr.client.solrj.response.UpdateResponse	add(org.apache.solr.client.solrj.SolrClient client, org.apache.solr.common.params.SolrParams params, Iterable<org.apache.solr.common.SolrInputDocument> sdocs)
protected org.apache.solr.client.solrj.response.UpdateResponse	add(org.apache.solr.client.solrj.SolrClient client, org.apache.solr.common.params.SolrParams params, org.apache.solr.common.SolrInputDocument sdoc)	This should not be called in a loop, use add(SolrClient, SolrParams, Iterable) instead
protected static void	addFields(org.apache.solr.common.SolrInputDocument doc, Object... fields)
protected org.apache.solr.common.SolrInputDocument	addRandFields(org.apache.solr.common.SolrInputDocument sdoc)
static void	clearSolrEnableUrlUrlAllowList()
protected void	commit()
static String	compare(Object[] a, Object[] b, int flags, Map<String,Integer> handle)
static String	compare(Object a, Object b, int flags, Map<String,Integer> handle)
static String	compare(Map a, Map b, int flags, Map<String,Integer> handle)
static String	compare(org.apache.solr.common.SolrDocumentList a, org.apache.solr.common.SolrDocumentList b, int flags, Map<String,Integer> handle)
static String	compare(org.apache.solr.common.SolrDocument a, org.apache.solr.common.SolrDocument b, int flags, Map<String,Integer> handle)
static String	compare(org.apache.solr.common.util.NamedList a, org.apache.solr.common.util.NamedList b, int flags, Map<String,Integer> handle)
static String	compare1(Map a, Map b, int flags, Map<String,Integer> handle)
protected void	compareResponses(org.apache.solr.client.solrj.response.QueryResponse a, org.apache.solr.client.solrj.response.QueryResponse b)
protected void	compareSolrResponses(org.apache.solr.client.solrj.SolrResponse a, org.apache.solr.client.solrj.SolrResponse b)
protected JettySolrRunner	createControlJetty()
JettySolrRunner	createJetty(Path solrHome, String dataDir)
JettySolrRunner	createJetty(Path solrHome, String dataDir, String shardId)
JettySolrRunner	createJetty(Path solrHome, String dataDir, String shardList, String solrConfigOverride, String schemaOverride)
JettySolrRunner	createJetty(Path solrHome, String dataDir, String shardList, String solrConfigOverride, String schemaOverride, boolean explicitCoreNodeName)
protected org.apache.solr.client.solrj.SolrClient	createNewSolrClient(int port)
protected org.apache.solr.common.params.ModifiableSolrParams	createParams(Object... q)
protected void	createServers(int numShards)
protected void	del(String q)
protected org.apache.solr.client.solrj.response.UpdateResponse	del(org.apache.solr.client.solrj.SolrClient client, org.apache.solr.common.params.SolrParams params, Object... ids)
protected org.apache.solr.client.solrj.response.UpdateResponse	delQ(org.apache.solr.client.solrj.SolrClient client, org.apache.solr.common.params.SolrParams params, String... queries)
protected void	destroyServers()
void	distribSetUp()
void	distribTearDown()
void	fixShardCount(int count)
static int	flags(Map<String,Integer> handle, Object key)
SortedMap<Class<? extends jakarta.servlet.Filter>,String>	getExtraRequestFilters()	Override this method to insert extra filters into the JettySolrRunners that are created using createJetty()
SortedMap<org.eclipse.jetty.ee10.servlet.ServletHolder,String>	getExtraServlets()	Override this method to insert extra servlets into the JettySolrRunners that are created using createJetty()
protected String[]	getFieldNames()
static Object[]	getRandFields(String[] fields, BaseDistributedSearchTestCase.RandVal[] randVals)
protected BaseDistributedSearchTestCase.RandVal[]	getRandValues()
int	getShardCount()
protected String	getShardsString()
Path	getSolrHome()	Subclasses can override this to change a test's solr home (default is in test-files)
protected String	getSolrXml()
protected void	index(Object... fields)
protected void	index_specific(int serverNumber, Object... fields)
protected void	indexDoc(org.apache.solr.client.solrj.SolrClient client, org.apache.solr.common.params.SolrParams params, org.apache.solr.common.SolrInputDocument doc)
protected void	indexDoc(org.apache.solr.common.SolrInputDocument doc)	Indexes the document in both the control client, and a randomly selected client
void	indexDocs(Iterator<org.apache.solr.common.SolrInputDocument> docs)	Indexes the stream of documents in both the control client and randomly selected clients (per batch)
protected org.apache.solr.client.solrj.response.UpdateResponse	indexDocs(org.apache.solr.client.solrj.SolrClient client, org.apache.solr.common.params.SolrParams params, Iterable<org.apache.solr.common.SolrInputDocument> sdocs)	Indexes the document in both the control client and the specified client asserting that the responses are equivalent
protected void	indexr(Object... fields)
static void	initialize()
protected org.apache.solr.client.solrj.response.QueryResponse	query(boolean setDistribParams, Object[] q)	Returns the distributed QueryResponse
protected org.apache.solr.client.solrj.response.QueryResponse	query(boolean setDistribParams, org.apache.solr.common.params.SolrParams p)	Returns the distributed QueryResponse
protected org.apache.solr.client.solrj.response.QueryResponse	query(Object... q)	Sets distributed params.
protected org.apache.solr.client.solrj.response.QueryResponse	query(org.apache.solr.common.params.SolrParams params)	Sets distributed params.
org.apache.solr.client.solrj.response.QueryResponse	queryAndCompare(org.apache.solr.common.params.SolrParams params, Iterable<org.apache.solr.client.solrj.SolrClient> clients)
org.apache.solr.client.solrj.response.QueryResponse	queryAndCompare(org.apache.solr.common.params.SolrParams params, org.apache.solr.client.solrj.SolrClient... clients)
protected org.apache.solr.client.solrj.response.QueryResponse	queryRandomShard(org.apache.solr.common.params.ModifiableSolrParams params)	Queries a random shard; nothing more.
protected void	seedSolrHome(Path jettyHome)	Given a directory that will be used as the SOLR_HOME for a jetty instance, seeds that directory with the contents of getSolrHome() and ensures that the proper getSolrXml() file is in place.
protected void	setDistributedParams(org.apache.solr.common.params.ModifiableSolrParams params)
static void	setSolrEnableUrlUrlAllowList()
protected void	setupJettySolrHome(Path jettyHome)
void	validateControlData(org.apache.solr.client.solrj.response.QueryResponse control)	Implementations can pre-test the control data for basic correctness before using it as a check for the shard data.

Methods inherited from class org.apache.solr.SolrTestCaseJ4

add, addAndGetVersion, addDoc, adoc, adoc, assertExceptionThrownWithMessageContaining, assertFailedU, assertFailedU, assertFieldValues, assertJQ, assertJQ, assertNonBlockingRandomGeneratorAvailable, assertQ, assertQ, assertQEx, assertQEx, assertQEx, assertResponseValues, assertSolrInputFieldEquals, assertThatJQ, assertThatJQ, assertU, assertU, assertXmlFile, assumeWorkingMockito, buildUrl, clearIndex, commit, compareSolrDocument, compareSolrDocumentList, compareSolrInputDocument, configset, copyMinConf, copyMinConf, copyMinConf, copyMinFullSetup, copySolrHomeToTemp, copyXmlToHome, createComparator, createComparator, createCore, createCoreContainer, createCoreContainer, createCoreContainer, createDefaultCoreContainer, createDistributedUpdateProcessor, createDoc, createSort, deleteAndGetVersion, deleteByQueryAndGetVersion, deleteCore, delI, delQ, doc, getClassName, getFile, getHttpClient, getHttpSolrClient, getHttpSolrClient, getHttpSolrClient, getRootCause, getSaferTestName, getSchemaFile, getSimpleClassName, getSolrConfigFile, getWrappedException, hasInitException, hasInitException, ignoreException, indexDocs, initAndGetDataDir, initCore, initCore, initCore, initCore, invertField, isSSLMode, JQ, json, json, json, jsonAdd, jsonDelId, jsonDelQ, legacyExampleCollection1SolrHome, map, map, newRandomConfig, optimize, params, pickRandom, postSetUp, preTearDown, randomDate, randomSkewedDate, randomXmlUsableUnicodeString, req, req, req, resetExceptionIgnores, resetFactory, sdoc, sdocs, sdocWithChildren, sdocWithChildren, sdocWithChildren, setUp, setupNoCoreTest, setupTestCases, skewed, startTrackingSearchers, systemClearPropertySolrEnableUrlAllowList, systemClearPropertySolrTestsMergePolicyFactory, systemSetPropertyEnableUrlAllowList, systemSetPropertySolrTestsMergePolicyFactory, tearDown, teardownTestCases, TEST_COLL1_CONF, TEST_HOME, TEST_PATH, toJSON, unIgnoreException, updateJ, useFactory, waitForWarming, waitForWarming, whitespaceMockTokenizer, whitespaceMockTokenizer, writeCoreProperties, writeCoreProperties

Methods inherited from class org.apache.solr.SolrTestCase

afterClassShutdownLogging, assertJSONEquals, assertThat, assertThat, beforeSolrTestCase, checkSyspropForceBeforeAssumptionFailure, checkSyspropForceBeforeClassAssumptionFailure

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, 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, getDataPath, 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, 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

executor

protected ExecutorService executor

r

public static Random r

useExplicitNodeNames

protected boolean useExplicitNodeNames

controlJetty

protected volatile JettySolrRunner controlJetty

clients

protected final List<org.apache.solr.client.solrj.SolrClient> clients

jettys

protected final List<JettySolrRunner> jettys

deadServers

protected volatile String[] deadServers

shards

protected volatile String shards

shardsArr

protected volatile String[] shardsArr

testDir

protected volatile Path testDir

controlClient

protected volatile org.apache.solr.client.solrj.SolrClient controlClient

stress

protected volatile int stress

verifyStress

protected volatile boolean verifyStress

nThreads

protected volatile int nThreads

ORDERED

public static final int ORDERED

See Also:

• Constant Field Values

SKIP

public static final int SKIP

See Also:

• Constant Field Values

SKIPVAL

public static final int SKIPVAL

See Also:

• Constant Field Values

UNORDERED

public static final int UNORDERED

See Also:

• Constant Field Values

FUZZY

public static int FUZZY

When this flag is set, Double values will be allowed a difference ratio of 1E-8 between the non-distributed and the distributed returned values

flags

protected volatile int flags

handle

protected Map<String,Integer> handle

id

protected String id

rint

public static BaseDistributedSearchTestCase.RandVal rint

rlong

public static BaseDistributedSearchTestCase.RandVal rlong

rfloat

public static BaseDistributedSearchTestCase.RandVal rfloat

rdouble

public static BaseDistributedSearchTestCase.RandVal rdouble

rdate

public static BaseDistributedSearchTestCase.RandVal rdate

fieldNames

public static String[] fieldNames

randVals

public static BaseDistributedSearchTestCase.RandVal[] randVals

repeatRule

public BaseDistributedSearchTestCase.ShardsRepeatRule repeatRule

Constructor Details

BaseDistributedSearchTestCase

protected BaseDistributedSearchTestCase()

Method Details

initialize

public static void initialize()

setSolrEnableUrlUrlAllowList

public static void setSolrEnableUrlUrlAllowList()
                                         throws Exception

Throws:

Exception

clearSolrEnableUrlUrlAllowList

public static void clearSolrEnableUrlUrlAllowList()
                                           throws Exception

Throws:

Exception

getShardCount

public int getShardCount()

fixShardCount

public void fixShardCount(int count)

getFieldNames

protected String[] getFieldNames()

getRandValues

protected BaseDistributedSearchTestCase.RandVal[] getRandValues()

getSolrHome

public Path getSolrHome()

Subclasses can override this to change a test's solr home (default is in test-files)

distribSetUp

public void distribSetUp()
                  throws Exception

Throws:

Exception

distribTearDown

public void distribTearDown()
                     throws Exception

Throws:

Exception

createControlJetty

protected JettySolrRunner createControlJetty()
                                      throws Exception

Throws:

Exception

createServers

protected void createServers(int numShards)
                      throws Exception

Throws:

Exception

setDistributedParams

protected void setDistributedParams(org.apache.solr.common.params.ModifiableSolrParams params)

getShardsString

protected String getShardsString()

destroyServers

protected void destroyServers()
                       throws Exception

Throws:

Exception

createJetty

public JettySolrRunner createJetty(Path solrHome,
 String dataDir)
                            throws Exception

Throws:

Exception

createJetty

public JettySolrRunner createJetty(Path solrHome,
 String dataDir,
 String shardId)
                            throws Exception

Throws:

Exception

createJetty

public JettySolrRunner createJetty(Path solrHome,
 String dataDir,
 String shardList,
 String solrConfigOverride,
 String schemaOverride)
                            throws Exception

Throws:

Exception

createJetty

public JettySolrRunner createJetty(Path solrHome,
 String dataDir,
 String shardList,
 String solrConfigOverride,
 String schemaOverride,
 boolean explicitCoreNodeName)
                            throws Exception

Throws:

Exception

getExtraServlets

public SortedMap<org.eclipse.jetty.ee10.servlet.ServletHolder,String> getExtraServlets()

Override this method to insert extra servlets into the JettySolrRunners that are created using createJetty()

getExtraRequestFilters

public SortedMap<Class<? extends jakarta.servlet.Filter>,String> getExtraRequestFilters()

Override this method to insert extra filters into the JettySolrRunners that are created using createJetty()

createNewSolrClient

protected org.apache.solr.client.solrj.SolrClient createNewSolrClient(int port)

addFields

protected static void addFields(org.apache.solr.common.SolrInputDocument doc,
 Object... fields)

indexr

protected void indexr(Object... fields)
               throws Exception

Throws:

Exception

addRandFields

protected org.apache.solr.common.SolrInputDocument addRandFields(org.apache.solr.common.SolrInputDocument sdoc)

index

protected void index(Object... fields)
              throws Exception

Throws:

Exception

indexDoc

protected void indexDoc(org.apache.solr.common.SolrInputDocument doc)
                 throws IOException,
org.apache.solr.client.solrj.SolrServerException

Indexes the document in both the control client, and a randomly selected client

Throws:

IOException

org.apache.solr.client.solrj.SolrServerException

indexDoc

protected void indexDoc(org.apache.solr.client.solrj.SolrClient client,
 org.apache.solr.common.params.SolrParams params,
 org.apache.solr.common.SolrInputDocument doc)
                 throws IOException,
org.apache.solr.client.solrj.SolrServerException

Throws:

IOException

org.apache.solr.client.solrj.SolrServerException

indexDocs

public void indexDocs(Iterator<org.apache.solr.common.SolrInputDocument> docs)
               throws org.apache.solr.client.solrj.SolrServerException,
IOException

Indexes the stream of documents in both the control client and randomly selected clients (per batch)

Throws:

org.apache.solr.client.solrj.SolrServerException

IOException

indexDocs

protected org.apache.solr.client.solrj.response.UpdateResponse indexDocs(org.apache.solr.client.solrj.SolrClient client,
 org.apache.solr.common.params.SolrParams params,
 Iterable<org.apache.solr.common.SolrInputDocument> sdocs)
                                                                  throws IOException,
org.apache.solr.client.solrj.SolrServerException

Indexes the document in both the control client and the specified client asserting that the responses are equivalent

Throws:

IOException

org.apache.solr.client.solrj.SolrServerException

add

protected org.apache.solr.client.solrj.response.UpdateResponse add(org.apache.solr.client.solrj.SolrClient client,
 org.apache.solr.common.params.SolrParams params,
 org.apache.solr.common.SolrInputDocument sdoc)
                                                            throws IOException,
org.apache.solr.client.solrj.SolrServerException

This should not be called in a loop, use add(SolrClient, SolrParams, Iterable) instead

Throws:

IOException

org.apache.solr.client.solrj.SolrServerException

add

protected org.apache.solr.client.solrj.response.UpdateResponse add(org.apache.solr.client.solrj.SolrClient client,
 org.apache.solr.common.params.SolrParams params,
 Iterable<org.apache.solr.common.SolrInputDocument> sdocs)
                                                            throws IOException,
org.apache.solr.client.solrj.SolrServerException

Throws:

IOException

org.apache.solr.client.solrj.SolrServerException

del

protected org.apache.solr.client.solrj.response.UpdateResponse del(org.apache.solr.client.solrj.SolrClient client,
 org.apache.solr.common.params.SolrParams params,
 Object... ids)
                                                            throws IOException,
org.apache.solr.client.solrj.SolrServerException

Throws:

IOException

org.apache.solr.client.solrj.SolrServerException

delQ

protected org.apache.solr.client.solrj.response.UpdateResponse delQ(org.apache.solr.client.solrj.SolrClient client,
 org.apache.solr.common.params.SolrParams params,
 String... queries)
                                                             throws IOException,
org.apache.solr.client.solrj.SolrServerException

Throws:

IOException

org.apache.solr.client.solrj.SolrServerException

index_specific

protected void index_specific(int serverNumber,
 Object... fields)
                       throws Exception

Throws:

Exception

del

protected void del(String q)
            throws Exception

Throws:

Exception

commit

protected void commit()
               throws Exception

Throws:

Exception

queryRandomShard

protected org.apache.solr.client.solrj.response.QueryResponse queryRandomShard(org.apache.solr.common.params.ModifiableSolrParams params)
                                                                        throws org.apache.solr.client.solrj.SolrServerException,
IOException

Queries a random shard; nothing more.

WARNING: tests should generally not call this as it doesn't compare to the control client

Throws:

org.apache.solr.client.solrj.SolrServerException

IOException

query

protected org.apache.solr.client.solrj.response.QueryResponse query(Object... q)
                                                             throws Exception

Sets distributed params. Returns the distributed QueryResponse

Throws:

Exception

query

protected org.apache.solr.client.solrj.response.QueryResponse query(org.apache.solr.common.params.SolrParams params)
                                                             throws Exception

Sets distributed params. Returns the distributed QueryResponse

Throws:

Exception

query

protected org.apache.solr.client.solrj.response.QueryResponse query(boolean setDistribParams,
 Object[] q)
                                                             throws Exception

Returns the distributed QueryResponse

Throws:

Exception

query

protected org.apache.solr.client.solrj.response.QueryResponse query(boolean setDistribParams,
 org.apache.solr.common.params.SolrParams p)
                                                             throws Exception

Returns the distributed QueryResponse

Throws:

Exception

queryAndCompare

public org.apache.solr.client.solrj.response.QueryResponse queryAndCompare(org.apache.solr.common.params.SolrParams params,
 org.apache.solr.client.solrj.SolrClient... clients)
                                                                    throws org.apache.solr.client.solrj.SolrServerException,
IOException

Throws:

org.apache.solr.client.solrj.SolrServerException

IOException

queryAndCompare

public org.apache.solr.client.solrj.response.QueryResponse queryAndCompare(org.apache.solr.common.params.SolrParams params,
 Iterable<org.apache.solr.client.solrj.SolrClient> clients)
                                                                    throws org.apache.solr.client.solrj.SolrServerException,
IOException

Throws:

org.apache.solr.client.solrj.SolrServerException

IOException

flags

public static int flags(Map<String,Integer> handle,
 Object key)

compare

public static String compare(org.apache.solr.common.util.NamedList a,
 org.apache.solr.common.util.NamedList b,
 int flags,
 Map<String,Integer> handle)

compare1

public static String compare1(Map a,
 Map b,
 int flags,
 Map<String,Integer> handle)

compare

public static String compare(Map a,
 Map b,
 int flags,
 Map<String,Integer> handle)

compare

public static String compare(org.apache.solr.common.SolrDocument a,
 org.apache.solr.common.SolrDocument b,
 int flags,
 Map<String,Integer> handle)

compare

public static String compare(org.apache.solr.common.SolrDocumentList a,
 org.apache.solr.common.SolrDocumentList b,
 int flags,
 Map<String,Integer> handle)

compare

public static String compare(Object[] a,
 Object[] b,
 int flags,
 Map<String,Integer> handle)

compare

public static String compare(Object a,
 Object b,
 int flags,
 Map<String,Integer> handle)

compareSolrResponses

protected void compareSolrResponses(org.apache.solr.client.solrj.SolrResponse a,
 org.apache.solr.client.solrj.SolrResponse b)

compareResponses

protected void compareResponses(org.apache.solr.client.solrj.response.QueryResponse a,
 org.apache.solr.client.solrj.response.QueryResponse b)

getRandFields

public static Object[] getRandFields(String[] fields,
 BaseDistributedSearchTestCase.RandVal[] randVals)

validateControlData

public void validateControlData(org.apache.solr.client.solrj.response.QueryResponse control)
                         throws Exception

Implementations can pre-test the control data for basic correctness before using it as a check for the shard data. This is useful, for instance, if a test bug is introduced causing a spelling index not to get built: both control & shard data would have no results but because they match the test would pass. This method gives us a chance to ensure something exists in the control data.

Throws:

Exception

getSolrXml

protected String getSolrXml()

seedSolrHome

protected void seedSolrHome(Path jettyHome)
                     throws IOException

Given a directory that will be used as the SOLR_HOME for a jetty instance, seeds that directory with the contents of getSolrHome() and ensures that the proper getSolrXml() file is in place.

Throws:

IOException

setupJettySolrHome

protected void setupJettySolrHome(Path jettyHome)
                           throws IOException

Throws:

IOException

createParams

protected org.apache.solr.common.params.ModifiableSolrParams createParams(Object... q)