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.downloadFromZK(SolrZkClient zkClient,
String zkPath,
Path file) |
|
void |
ZkCmdExecutor.ensureExists(String path,
byte[] data,
SolrZkClient zkClient) |
Create a persistent znode with the given data if it does not already exist
|
void |
ZkCmdExecutor.ensureExists(String path,
byte[] data,
org.apache.zookeeper.CreateMode createMode,
SolrZkClient zkClient) |
Create a znode with the given mode and data if it does not already exist
|
void |
ZkCmdExecutor.ensureExists(String path,
byte[] data,
org.apache.zookeeper.CreateMode createMode,
SolrZkClient zkClient,
int skipPathParts) |
Create a node if it does not exist
|
void |
ZkCmdExecutor.ensureExists(String path,
SolrZkClient zkClient) |
Create a persistent znode with no data if it does not already exist
|
static org.apache.solr.common.cloud.PerReplicaStates |
PerReplicaStatesFetcher.fetch(String path,
SolrZkClient zkClient,
org.apache.solr.common.cloud.PerReplicaStates current) |
Fetch the latest PerReplicaStates .
|
static org.apache.solr.common.cloud.DocCollection.PrsSupplier |
PerReplicaStatesFetcher.getZkClientPrsSupplier(SolrZkClient zkClient,
String collectionPath) |
|
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.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.
|