@LuceneTestCase.Slow public abstract class AbstractFullDistribZkTestBase extends AbstractDistribZkTestBase
Modifier and Type | Class and Description |
---|---|
static class |
AbstractFullDistribZkTestBase.CloudJettyRunner |
BaseDistributedSearchTestCase.RandDate, BaseDistributedSearchTestCase.RandVal
SolrTestCaseJ4.Doc, SolrTestCaseJ4.Fld, SolrTestCaseJ4.FldType, SolrTestCaseJ4.FVal, SolrTestCaseJ4.IRange, SolrTestCaseJ4.IVals, SolrTestCaseJ4.SVal, SolrTestCaseJ4.Vals, SolrTestCaseJ4.XmlDoc
org.apache.lucene.util.LuceneTestCase.AwaitsFix, org.apache.lucene.util.LuceneTestCase.BadApple, org.apache.lucene.util.LuceneTestCase.Nightly, org.apache.lucene.util.LuceneTestCase.Slow, org.apache.lucene.util.LuceneTestCase.SuppressCodecs, org.apache.lucene.util.LuceneTestCase.Weekly
Modifier and Type | Field and Description |
---|---|
protected ChaosMonkey |
chaosMonkey |
protected org.apache.solr.client.solrj.impl.CloudSolrServer |
cloudClient |
protected List<AbstractFullDistribZkTestBase.CloudJettyRunner> |
cloudJettys |
protected org.apache.solr.client.solrj.impl.CloudSolrServer |
controlClientCloud |
protected boolean |
printLayoutOnTearDown |
static String |
SHARD1 |
static String |
SHARD2 |
protected Map<String,List<AbstractFullDistribZkTestBase.CloudJettyRunner>> |
shardToJetty |
protected Map<String,AbstractFullDistribZkTestBase.CloudJettyRunner> |
shardToLeaderJetty |
protected int |
sliceCount |
DEFAULT_COLLECTION, zkServer
clients, context, controlClient, controlJetty, deadServers, fieldNames, fixShardCount, flags, handle, id, jettys, nThreads, ORDERED, r, randVals, rdate, rdouble, rfloat, rint, rlong, shardCount, shards, shardsArr, SKIP, SKIPVAL, stress, testDir, UNORDERED, verifyStress
configString, dataDir, DEFAULT_CONNECTION_TIMEOUT, formatter, h, lrf, ONE_ONE, schemaString, solrClassRules, solrConfig, solrTestRules, testSolrHome, ZERO_ONE, ZERO_TWO
classRules, DEFAULT_LINE_DOCS_FILE, doesntSupportOffsets, INFOSTREAM, JENKINS_LARGE_LINE_DOCS_FILE, PREFLEX_IMPERSONATION_IS_ACTIVE, RANDOM_MULTIPLIER, ruleChain, suiteFailureMarker, SYSPROP_AWAITSFIX, SYSPROP_BADAPPLES, SYSPROP_NIGHTLY, SYSPROP_SLOW, SYSPROP_WEEKLY, TEMP_DIR, TEST_AWAITSFIX, TEST_CODEC, TEST_DIRECTORY, TEST_LINE_DOCS_FILE, TEST_NIGHTLY, TEST_POSTINGSFORMAT, TEST_SLOW, TEST_THROTTLING, TEST_VERSION_CURRENT, TEST_WEEKLY, VERBOSE
Constructor and Description |
---|
AbstractFullDistribZkTestBase() |
Modifier and Type | Method and Description |
---|---|
static void |
afterClass() |
protected void |
assertDocCounts(boolean verbose) |
static void |
beforeClass() |
static void |
beforeFullSolrCloudTest() |
protected void |
checkQueries() |
protected void |
checkShardConsistency() |
protected void |
checkShardConsistency(boolean checkVsControl,
boolean verbose) |
protected void |
checkShardConsistency(String shard) |
protected String |
checkShardConsistency(String shard,
boolean expectFailure,
boolean verbose) |
protected void |
commit() |
protected org.apache.solr.client.solrj.impl.CloudSolrServer |
createCloudClient(String defaultCollection) |
org.apache.solr.client.solrj.embedded.JettySolrRunner |
createJetty(String dataDir,
String shardList,
String solrConfigOverride) |
protected List<org.apache.solr.client.solrj.embedded.JettySolrRunner> |
createJettys(int numJettys) |
protected List<org.apache.solr.client.solrj.embedded.JettySolrRunner> |
createJettys(int numJettys,
boolean checkCreatedVsState) |
protected org.apache.solr.client.solrj.SolrServer |
createNewSolrServer(int port) |
protected void |
createServers(int numServers) |
protected void |
del(String q) |
protected void |
destroyServers() |
protected org.apache.solr.client.solrj.SolrServer |
getClient(String nodeName) |
protected int |
getTotalReplicas(String collection) |
protected void |
index_specific(int serverNumber,
Object... fields) |
protected void |
index_specific(org.apache.solr.client.solrj.SolrServer client,
Object... fields) |
protected void |
indexAbunchOfDocs() |
protected void |
indexDoc(org.apache.solr.common.SolrInputDocument doc) |
protected void |
initCloud() |
protected org.apache.solr.client.solrj.response.QueryResponse |
queryServer(org.apache.solr.common.params.ModifiableSolrParams params) |
protected void |
setDistributedParams(org.apache.solr.common.params.ModifiableSolrParams params) |
void |
setUp() |
protected org.apache.solr.client.solrj.SolrServer |
startCloudJetty(String collection,
String shard) |
void |
tearDown() |
protected void |
updateMappingsFromZk(List<org.apache.solr.client.solrj.embedded.JettySolrRunner> jettys,
List<org.apache.solr.client.solrj.SolrServer> clients) |
protected void |
waitForCollection(org.apache.solr.common.cloud.ZkStateReader reader,
String collection,
int slices) |
protected void |
waitForRecoveriesToFinish(boolean verbose) |
protected void |
waitForRecoveriesToFinish(boolean verbose,
int timeoutSeconds) |
void |
waitForThingsToLevelOut(int waitForRecTimeSeconds) |
assertAllActive, beforeThisClass, printLayout, waitForRecoveriesToFinish, waitForRecoveriesToFinish, waitForRecoveriesToFinish
add, addFields, addRandFields, clearHostContext, compare, compare, compare, compare, compare, compare, compare1, compareResponses, createJetty, createJetty, createJetty, del, delQ, doTest, eq, flags, getFieldNames, getRandFields, getRandValues, getShardsString, getSolrHome, index, indexr, initHostContext, initialize, query, query, queryAndCompare, testDistribSearch, validateControlData
add, addAndGetVersion, adoc, adoc, assertFailedU, assertFailedU, assertJQ, assertJQ, assertQ, assertQ, assertQEx, assertQEx, assertU, assertU, clearIndex, commit, createComparator, createComparator, createCore, createDoc, createSort, createTempDir, deleteAndGetVersion, deleteByQueryAndGetVersion, deleteCore, delI, delQ, doc, endTrackingSearchers, endTrackingZkClients, getClassName, getFile, getRootCause, getSchemaFile, getSimpleClassName, getSolrConfigFile, ignoreException, indexDocs, initCore, initCore, initCore, initCore, JQ, json, jsonAdd, jsonDelId, jsonDelQ, map, optimize, params, postSetUp, preTearDown, recurseDelete, req, req, req, resetExceptionIgnores, sdoc, setLoggingLevel, setupLogging, startTrackingSearchers, startTrackingZkClients, TEST_HOME, toJSON, unIgnoreException, updateJ, useFactory
assertSaneFieldCaches, asSet, assumeFalse, assumeNoException, assumeTrue, atLeast, atLeast, closeAfterSuite, closeAfterTest, defaultCodecSupportsDocValues, dumpArray, dumpIterator, getDataFile, getOnlySegmentReader, getTestClass, getTestName, isTestThread, localeForName, maybeWrapReader, newAlcoholicMergePolicy, newAlcoholicMergePolicy, newDirectory, newDirectory, newDirectory, newDirectory, newField, newField, newFSDirectory, newFSDirectory, newIndexWriterConfig, newIndexWriterConfig, newIOContext, newIOContext, newLogMergePolicy, newLogMergePolicy, newLogMergePolicy, newLogMergePolicy, newLogMergePolicy, newMockDirectory, newMockDirectory, newMockFSDirectory, newSearcher, newSearcher, newStringField, newStringField, newTextField, newTextField, newTieredMergePolicy, newTieredMergePolicy, random, randomLocale, randomTimeZone, rarely, rarely, usually, usually
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, assertFalse, assertFalse, assertNotNull, assertNotNull, assertNotSame, assertNotSame, assertNull, assertNull, assertSame, assertSame, assertThat, assertThat, assertTrue, assertTrue, fail, fail
public static final String SHARD1
public static final String SHARD2
protected boolean printLayoutOnTearDown
protected int sliceCount
protected org.apache.solr.client.solrj.impl.CloudSolrServer controlClientCloud
protected volatile org.apache.solr.client.solrj.impl.CloudSolrServer cloudClient
protected List<AbstractFullDistribZkTestBase.CloudJettyRunner> cloudJettys
protected Map<String,List<AbstractFullDistribZkTestBase.CloudJettyRunner>> shardToJetty
protected ChaosMonkey chaosMonkey
protected Map<String,AbstractFullDistribZkTestBase.CloudJettyRunner> shardToLeaderJetty
public static void beforeFullSolrCloudTest()
public void setUp() throws Exception
setUp
in class AbstractDistribZkTestBase
Exception
public static void beforeClass()
public static void afterClass()
protected org.apache.solr.client.solrj.impl.CloudSolrServer createCloudClient(String defaultCollection) throws MalformedURLException
MalformedURLException
protected void createServers(int numServers) throws Exception
createServers
in class AbstractDistribZkTestBase
Exception
protected void waitForCollection(org.apache.solr.common.cloud.ZkStateReader reader, String collection, int slices) throws Exception
Exception
protected List<org.apache.solr.client.solrj.embedded.JettySolrRunner> createJettys(int numJettys) throws Exception
Exception
protected List<org.apache.solr.client.solrj.embedded.JettySolrRunner> createJettys(int numJettys, boolean checkCreatedVsState) throws Exception
checkCreatedVsState
- if true, make sure the number created (numJettys) matches the
number in the cluster state - if you add more jetties this may not
be the caseException
protected org.apache.solr.client.solrj.SolrServer startCloudJetty(String collection, String shard) throws Exception
Exception
protected int getTotalReplicas(String collection)
public org.apache.solr.client.solrj.embedded.JettySolrRunner createJetty(String dataDir, String shardList, String solrConfigOverride) throws Exception
Exception
protected void updateMappingsFromZk(List<org.apache.solr.client.solrj.embedded.JettySolrRunner> jettys, List<org.apache.solr.client.solrj.SolrServer> clients) throws Exception
Exception
protected void setDistributedParams(org.apache.solr.common.params.ModifiableSolrParams params)
setDistributedParams
in class BaseDistributedSearchTestCase
protected void indexDoc(org.apache.solr.common.SolrInputDocument doc) throws IOException, org.apache.solr.client.solrj.SolrServerException
indexDoc
in class BaseDistributedSearchTestCase
IOException
org.apache.solr.client.solrj.SolrServerException
protected void index_specific(int serverNumber, Object... fields) throws Exception
index_specific
in class BaseDistributedSearchTestCase
Exception
protected void index_specific(org.apache.solr.client.solrj.SolrServer client, Object... fields) throws Exception
Exception
protected void del(String q) throws Exception
del
in class BaseDistributedSearchTestCase
Exception
protected void waitForRecoveriesToFinish(boolean verbose) throws Exception
Exception
protected void waitForRecoveriesToFinish(boolean verbose, int timeoutSeconds) throws Exception
Exception
protected void checkShardConsistency(String shard) throws Exception
Exception
protected String checkShardConsistency(String shard, boolean expectFailure, boolean verbose) throws Exception
Exception
protected void checkShardConsistency(boolean checkVsControl, boolean verbose) throws Exception
Exception
protected org.apache.solr.client.solrj.SolrServer getClient(String nodeName)
protected org.apache.solr.client.solrj.response.QueryResponse queryServer(org.apache.solr.common.params.ModifiableSolrParams params) throws org.apache.solr.client.solrj.SolrServerException
queryServer
in class BaseDistributedSearchTestCase
org.apache.solr.client.solrj.SolrServerException
public void waitForThingsToLevelOut(int waitForRecTimeSeconds) throws Exception
Exception
public void tearDown() throws Exception
tearDown
in class AbstractDistribZkTestBase
Exception
protected void commit() throws Exception
commit
in class BaseDistributedSearchTestCase
Exception
protected void destroyServers() throws Exception
destroyServers
in class BaseDistributedSearchTestCase
Exception
protected org.apache.solr.client.solrj.SolrServer createNewSolrServer(int port)
createNewSolrServer
in class BaseDistributedSearchTestCase
Copyright © 2000-2013 Apache Software Foundation. All Rights Reserved.