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 ClusterState |
ClusterState.createFromJsonSupportingLegacyConfigName(int version,
byte[] bytes,
Set<String> liveNodes,
String coll,
SolrZkClient zkClient) |
Deprecated.
|
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 PerReplicaStates |
PerReplicaStates.fetch(String path,
SolrZkClient zkClient,
PerReplicaStates current) |
|
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.
|