Package | Description |
---|---|
org.apache.solr.client.solrj.impl |
Concrete implementations of client API classes.
|
org.apache.solr.common.cloud |
Common Solr Cloud and ZooKeeper related classes reused on both clients & server.
|
org.apache.solr.common.util |
Common utility classes reused on both clients & server.
|
Modifier and Type | Method and Description |
---|---|
SolrZkClient |
ZkDistribStateManager.getZkClient() |
SolrZkClient |
SolrClientCloudManager.getZkClient() |
Constructor and Description |
---|
ZkDistribStateManager(SolrZkClient zkClient) |
Modifier and Type | Method and Description |
---|---|
SolrZkClient |
ZkStateReader.getZkClient() |
Modifier and Type | Method and Description |
---|---|
static void |
ZkMaintenanceUtils.clean(SolrZkClient zkClient,
String path) |
static void |
ZkMaintenanceUtils.clean(SolrZkClient zkClient,
String path,
Predicate<String> filter)
Delete a path and all of its sub nodes
|
static void |
ZkMaintenanceUtils.downConfig(SolrZkClient zkClient,
String confName,
Path confPath) |
static void |
ZkMaintenanceUtils.downloadFromZK(SolrZkClient zkClient,
String zkPath,
Path file) |
void |
ZkCmdExecutor.ensureExists(String path,
byte[] data,
org.apache.zookeeper.CreateMode createMode,
SolrZkClient zkClient) |
void |
ZkCmdExecutor.ensureExists(String path,
byte[] data,
org.apache.zookeeper.CreateMode createMode,
SolrZkClient zkClient,
int skipPathParts) |
void |
ZkCmdExecutor.ensureExists(String path,
byte[] data,
SolrZkClient zkClient) |
void |
ZkCmdExecutor.ensureExists(String path,
SolrZkClient zkClient) |
static PerReplicaStates |
PerReplicaStates.fetch(String path,
SolrZkClient zkClient,
PerReplicaStates current)
Fetch the latest
PerReplicaStates . |
static String |
ZkMaintenanceUtils.listZnode(SolrZkClient zkClient,
String path,
Boolean recurse)
Lists a ZNode child and (optionally) the znodes of all the children.
|
static void |
ZkMaintenanceUtils.moveZnode(SolrZkClient zkClient,
String src,
String dst) |
void |
PerReplicaStatesOps.persist(String znode,
SolrZkClient zkClient)
This is a persist operation with retry if a write fails due to stale state
|
static void |
ZkMaintenanceUtils.traverseZkTree(SolrZkClient zkClient,
String path,
ZkMaintenanceUtils.VISIT_ORDER visitOrder,
ZkMaintenanceUtils.ZkVisitor visitor)
Recursively visit a zk tree rooted at path and apply the given visitor to each path.
|
static void |
ZkMaintenanceUtils.upConfig(SolrZkClient zkClient,
Path confPath,
String confName) |
static void |
ZkMaintenanceUtils.uploadToZK(SolrZkClient zkClient,
Path fromPath,
String zkPath,
Pattern filenameExclusions) |
static void |
ZkMaintenanceUtils.zkTransfer(SolrZkClient zkClient,
String src,
Boolean srcIsZk,
String dst,
Boolean dstIsZk,
Boolean recurse)
Copy between local file system and Zookeeper, or from one Zookeeper node to another,
optionally copying recursively.
|
Constructor and Description |
---|
ClusterProperties(SolrZkClient client)
Creates a ClusterProperties object using a provided SolrZkClient
|
CollectionProperties(SolrZkClient client)
Creates a CollectionProperties object using a provided SolrZkClient
|
ConnectionManager(String name,
SolrZkClient client,
String zkServerAddress,
ZkClientConnectionStrategy strat,
OnReconnect onConnect,
BeforeReconnect beforeReconnect,
ConnectionManager.IsClosed isClosed) |
ZkConfigManager(SolrZkClient zkClient)
Creates a new ZkConfigManager
|
ZkStateReader(SolrZkClient zkClient) |
ZkStateReader(SolrZkClient zkClient,
Runnable securityNodeListener) |
Modifier and Type | Method and Description |
---|---|
static Map<String,Object> |
Utils.getJson(SolrZkClient zkClient,
String path,
boolean retryOnConnLoss)
Assumes data in ZooKeeper is a JSON string, deserializes it and returns as a Map
|
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.