public class CloudHttp2SolrClient extends BaseCloudSolrClient
LBHttp2SolrClient
to issue requests.
This class assumes the id field for your documents is called
'id' - if this is not the case, you must set the right name
with BaseCloudSolrClient.setIdField(String)
.Modifier and Type | Class and Description |
---|---|
static class |
CloudHttp2SolrClient.Builder
Constructs
CloudHttp2SolrClient instances from provided configuration. |
BaseCloudSolrClient.RouteException, BaseCloudSolrClient.RouteResponse<T extends LBSolrClient.Req>
collectionStateCache, STATE_VERSION
Modifier | Constructor and Description |
---|---|
protected |
CloudHttp2SolrClient(CloudHttp2SolrClient.Builder builder)
Create a new client object that connects to Zookeeper and is always aware
of the SolrCloud state.
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
ClusterStateProvider |
getClusterStateProvider() |
Http2SolrClient |
getHttpClient() |
LBHttp2SolrClient |
getLbClient() |
protected boolean |
wasCommError(Throwable rootCause) |
condenseResponse, condenseResponse, connect, connect, createRoutes, getDefaultCollection, getDocCollection, getIdField, getMinAchievedReplicationFactor, getParser, getRequestWriter, getRouteException, getShardReplicationFactor, getZkHost, getZkStateReader, isDirectUpdatesToLeadersOnly, isParallelUpdates, isUpdatesToLeaders, objectList, registerCollectionStateWatcher, registerDocCollectionWatcher, request, requestWithRetryOnStaleState, sendRequest, setCollectionCacheTTl, setDefaultCollection, setIdField, setParallelCacheRefreshes, setParser, setRequestWriter, setRetryExpiryTime, setZkClientTimeout, setZkConnectTimeout, waitForState, waitForState
add, add, add, add, add, add, add, add, add, add, addBean, addBean, addBean, addBean, addBeans, addBeans, addBeans, addBeans, addBeans, addBeans, commit, commit, commit, commit, commit, commit, deleteById, deleteById, deleteById, deleteById, deleteById, deleteById, deleteById, deleteById, deleteByQuery, deleteByQuery, deleteByQuery, deleteByQuery, getBinder, getById, getById, getById, getById, getById, getById, getById, getById, optimize, optimize, optimize, optimize, optimize, optimize, ping, ping, query, query, query, query, queryAndStreamResponse, queryAndStreamResponse, queryAndStreamResponse, request, rollback, rollback
protected CloudHttp2SolrClient(CloudHttp2SolrClient.Builder builder)
builder
- a Http2SolrClient.Builder
with the options used to create the client.public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class BaseCloudSolrClient
IOException
public LBHttp2SolrClient getLbClient()
getLbClient
in class BaseCloudSolrClient
public ClusterStateProvider getClusterStateProvider()
getClusterStateProvider
in class BaseCloudSolrClient
public Http2SolrClient getHttpClient()
protected boolean wasCommError(Throwable rootCause)
wasCommError
in class BaseCloudSolrClient
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.