| Package | Description | 
|---|---|
| org.apache.hadoop.hbase.replication | Multi Cluster Replication | 
| org.apache.hadoop.hbase.zookeeper | 
| Modifier and Type | Method and Description | 
|---|---|
| private void | ZKReplicationQueueStorage. addLastSeqIdsToOps(String queueId,
                  Map<String,Long> lastSeqIds,
                  List<ZKUtil.ZKUtilOp> listOfOps) | 
| Modifier and Type | Class and Description | 
|---|---|
| static class  | ZKUtil.ZKUtilOp.CreateAndFailSilentZKUtilOp representing createAndFailSilent in ZooKeeper
 (attempt to create node, ignore error if already exists) | 
| static class  | ZKUtil.ZKUtilOp.DeleteNodeFailSilentZKUtilOp representing deleteNodeFailSilent in ZooKeeper
 (attempt to delete node, ignore error if node doesn't exist) | 
| static class  | ZKUtil.ZKUtilOp.SetDataZKUtilOp representing setData in ZooKeeper | 
| Modifier and Type | Method and Description | 
|---|---|
| static ZKUtil.ZKUtilOp | ZKUtil.ZKUtilOp. createAndFailSilent(String path,
                   byte[] data) | 
| static ZKUtil.ZKUtilOp | ZKUtil.ZKUtilOp. deleteNodeFailSilent(String path) | 
| static ZKUtil.ZKUtilOp | ZKUtil.ZKUtilOp. setData(String path,
       byte[] data) | 
| static ZKUtil.ZKUtilOp | ZKUtil.ZKUtilOp. setData(String path,
       byte[] data,
       int version) | 
| Modifier and Type | Method and Description | 
|---|---|
| (package private) static List<List<ZKUtil.ZKUtilOp>> | ZKUtil. partitionOps(List<ZKUtil.ZKUtilOp> ops,
            int maxPartitionSize)Partition the list of  opsby size (usingZKUtil.estimateSize(ZKUtilOp)). | 
| Modifier and Type | Method and Description | 
|---|---|
| (package private) static int | ZKUtil. estimateSize(ZKUtil.ZKUtilOp op) | 
| private static org.apache.zookeeper.Op | ZKUtil. toZooKeeperOp(ZKWatcher zkw,
             ZKUtil.ZKUtilOp op)Convert from ZKUtilOp to ZKOp | 
| Modifier and Type | Method and Description | 
|---|---|
| static void | ZKUtil. multiOrSequential(ZKWatcher zkw,
                 List<ZKUtil.ZKUtilOp> ops,
                 boolean runSequentialOnMultiFailure)Use ZooKeeper's multi-update functionality. | 
| (package private) static List<List<ZKUtil.ZKUtilOp>> | ZKUtil. partitionOps(List<ZKUtil.ZKUtilOp> ops,
            int maxPartitionSize)Partition the list of  opsby size (usingZKUtil.estimateSize(ZKUtilOp)). | 
| private static void | ZKUtil. processSequentially(ZKWatcher zkw,
                   List<ZKUtil.ZKUtilOp> ops) | 
| private static void | ZKUtil. submitBatchedMultiOrSequential(ZKWatcher zkw,
                              boolean runSequentialOnMultiFailure,
                              List<ZKUtil.ZKUtilOp> ops)Chunks the provided  opswhen their approximate size exceeds the the configured limit. | 
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.