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.CreateAndFailSilent
ZKUtilOp representing createAndFailSilent in ZooKeeper
(attempt to create node, ignore error if already exists)
|
static class |
ZKUtil.ZKUtilOp.DeleteNodeFailSilent
ZKUtilOp representing deleteNodeFailSilent in ZooKeeper
(attempt to delete node, ignore error if node doesn't exist)
|
static class |
ZKUtil.ZKUtilOp.SetData
ZKUtilOp 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
ops by size (using ZKUtil.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
ops by size (using ZKUtil.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
ops when their approximate size exceeds the the configured limit. |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.