From commits-return-78776-archive-asf-public=cust-asf.ponee.io@hbase.apache.org Tue Oct 2 16:54:01 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id 0DB1C180677 for ; Tue, 2 Oct 2018 16:53:59 +0200 (CEST) Received: (qmail 40269 invoked by uid 500); 2 Oct 2018 14:53:55 -0000 Mailing-List: contact commits-help@hbase.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@hbase.apache.org Delivered-To: mailing list commits@hbase.apache.org Received: (qmail 39294 invoked by uid 99); 2 Oct 2018 14:53:54 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 02 Oct 2018 14:53:54 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 29373E10D1; Tue, 2 Oct 2018 14:53:52 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: git-site-role@apache.org To: commits@hbase.apache.org Date: Tue, 02 Oct 2018 14:54:15 -0000 Message-Id: <4b6118a2e59e44f299c5e65f6ba3fea9@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [24/26] hbase-site git commit: Published site at 42aa3dd463c0d30a9b940d296b87316b5c67e1f5. http://git-wip-us.apache.org/repos/asf/hbase-site/blob/37b8a04a/devapidocs/org/apache/hadoop/hbase/replication/ZKReplicationQueueStorage.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/replication/ZKReplicationQueueStorage.html b/devapidocs/org/apache/hadoop/hbase/replication/ZKReplicationQueueStorage.html index 85c6bf7..20c5cc1 100644 --- a/devapidocs/org/apache/hadoop/hbase/replication/ZKReplicationQueueStorage.html +++ b/devapidocs/org/apache/hadoop/hbase/replication/ZKReplicationQueueStorage.html @@ -374,8 +374,10 @@ implements getReplicableHFiles0(String peerId)  -private String -getRsNode(ServerName serverName)  +String +getRsNode(ServerName serverName) +
Get full znode name for given region server
+ (package private) String @@ -621,7 +623,17 @@ implements
  • getRsNode

    -
    private String getRsNode(ServerName serverName)
    +
    public String getRsNode(ServerName serverName)
    +
    Description copied from interface: ReplicationQueueStorage
    +
    Get full znode name for given region server
    +
    +
    Specified by:
    +
    getRsNode in interface ReplicationQueueStorage
    +
    Parameters:
    +
    serverName - the name of the region server
    +
    Returns:
    +
    full znode name
    +
  • @@ -630,7 +642,7 @@ implements
  • getQueueNode

    -
    private String getQueueNode(ServerName serverName,
    +
    private String getQueueNode(ServerName serverName,
                                 String queueId)
  • @@ -640,7 +652,7 @@ implements
  • getFileNode

    -
    private String getFileNode(String queueNode,
    +
    private String getFileNode(String queueNode,
                                String fileName)
  • @@ -650,7 +662,7 @@ implements
  • getFileNode

    -
    private String getFileNode(ServerName serverName,
    +
    private String getFileNode(ServerName serverName,
                                String queueId,
                                String fileName)
  • @@ -661,7 +673,7 @@ implements
  • getSerialReplicationRegionPeerNode

    -
    String getSerialReplicationRegionPeerNode(String encodedRegionName,
    +
    String getSerialReplicationRegionPeerNode(String encodedRegionName,
                                               String peerId)

    Put all regions under /hbase/replication/regions znode will lead to too many children because @@ -696,7 +708,7 @@ implements

  • removeQueue

    -
    public void removeQueue(ServerName serverName,
    +
    public void removeQueue(ServerName serverName,
                             String queueId)
                      throws ReplicationException
    Description copied from interface: ReplicationQueueStorage
    @@ -718,7 +730,7 @@ implements
  • addWAL

    -
    public void addWAL(ServerName serverName,
    +
    public void addWAL(ServerName serverName,
                        String queueId,
                        String fileName)
                 throws ReplicationException
    @@ -743,7 +755,7 @@ implements
  • removeWAL

    -
    public void removeWAL(ServerName serverName,
    +
    public void removeWAL(ServerName serverName,
                           String queueId,
                           String fileName)
                    throws ReplicationException
    @@ -767,7 +779,7 @@ implements
  • addLastSeqIdsToOps

    -
    private void addLastSeqIdsToOps(String queueId,
    +
    private void addLastSeqIdsToOps(String queueId,
                                     Map<String,Long> lastSeqIds,
                                     List<ZKUtil.ZKUtilOp> listOfOps)
                              throws org.apache.zookeeper.KeeperException,
    @@ -785,7 +797,7 @@ implements 
     
  • setWALPosition

    -
    public void setWALPosition(ServerName serverName,
    +
    public void setWALPosition(ServerName serverName,
                                String queueId,
                                String fileName,
                                long position,
    @@ -813,7 +825,7 @@ implements 
     
  • getLastSequenceIdWithVersion

    -
    protected Pair<Long,IntegergetLastSequenceIdWithVersion(String encodedRegionName,
    +
    protected Pair<Long,IntegergetLastSequenceIdWithVersion(String encodedRegionName,
                                                               String peerId)
                                                        throws org.apache.zookeeper.KeeperException
    Return the {lastPushedSequenceId, ZNodeDataVersion} pair. if ZNodeDataVersion is -1, it means @@ -830,7 +842,7 @@ implements
  • getLastSequenceId

    -
    public long getLastSequenceId(String encodedRegionName,
    +
    public long getLastSequenceId(String encodedRegionName,
                                   String peerId)
                            throws ReplicationException
    Description copied from interface: ReplicationQueueStorage
    @@ -855,7 +867,7 @@ implements
  • setLastSequenceIds

    -
    public void setLastSequenceIds(String peerId,
    +
    public void setLastSequenceIds(String peerId,
                                    Map<String,Long> lastSeqIds)
                             throws ReplicationException
    Description copied from interface: ReplicationQueueStorage
    @@ -878,7 +890,7 @@ implements
  • removeLastSequenceIds

    -
    public void removeLastSequenceIds(String peerId)
    +
    public void removeLastSequenceIds(String peerId)
                                throws ReplicationException
    Description copied from interface: ReplicationQueueStorage
    Remove all the max sequence id record for the given peer.
    @@ -898,7 +910,7 @@ implements
  • removeLastSequenceIds

    -
    public void removeLastSequenceIds(String peerId,
    +
    public void removeLastSequenceIds(String peerId,
                                       List<String> encodedRegionNames)
                                throws ReplicationException
    Description copied from interface: ReplicationQueueStorage
    @@ -920,7 +932,7 @@ implements
  • getWALPosition

    -
    public long getWALPosition(ServerName serverName,
    +
    public long getWALPosition(ServerName serverName,
                                String queueId,
                                String fileName)
                         throws ReplicationException
    @@ -946,7 +958,7 @@ implements
  • claimQueue

    -
    public Pair<String,SortedSet<String>> claimQueue(ServerName sourceServerName,
    +
    public Pair<String,SortedSet<String>> claimQueue(ServerName sourceServerName,
                                                      String queueId,
                                                      ServerName destServerName)
                                               throws ReplicationException
    @@ -972,7 +984,7 @@ implements
  • removeReplicatorIfQueueIsEmpty

    -
    public void removeReplicatorIfQueueIsEmpty(ServerName serverName)
    +
    public void removeReplicatorIfQueueIsEmpty(ServerName serverName)
                                         throws ReplicationException
    Description copied from interface: ReplicationQueueStorage
    Remove the record of region server if the queue is empty.
    @@ -990,7 +1002,7 @@ implements
  • getListOfReplicators0

    -
    private List<ServerNamegetListOfReplicators0()
    +
    private List<ServerNamegetListOfReplicators0()
                                             throws org.apache.zookeeper.KeeperException
    Throws:
    @@ -1004,7 +1016,7 @@ implements
  • getListOfReplicators

    -
    public List<ServerNamegetListOfReplicators()
    +
    public List<ServerNamegetListOfReplicators()
                                           throws ReplicationException
    Description copied from interface: ReplicationQueueStorage
    Get a list of all region servers that have outstanding replication queues. These servers could @@ -1025,7 +1037,7 @@ implements
  • getWALsInQueue0

    -
    private List<StringgetWALsInQueue0(ServerName serverName,
    +
    private List<StringgetWALsInQueue0(ServerName serverName,
                                          String queueId)
                                   throws org.apache.zookeeper.KeeperException
    @@ -1040,7 +1052,7 @@ implements
  • getWALsInQueue

    -
    public List<StringgetWALsInQueue(ServerName serverName,
    +
    public List<StringgetWALsInQueue(ServerName serverName,
                                        String queueId)
                                 throws ReplicationException
    Description copied from interface: ReplicationQueueStorage
    @@ -1064,7 +1076,7 @@ implements
  • getAllQueues0

    -
    private List<StringgetAllQueues0(ServerName serverName)
    +
    private List<StringgetAllQueues0(ServerName serverName)
                                 throws org.apache.zookeeper.KeeperException
    Throws:
    @@ -1078,7 +1090,7 @@ implements
  • getAllQueues

    -
    public List<StringgetAllQueues(ServerName serverName)
    +
    public List<StringgetAllQueues(ServerName serverName)
                               throws ReplicationException
    Description copied from interface: ReplicationQueueStorage
    Get a list of all queues for the specified region server.
    @@ -1100,7 +1112,7 @@ implements
  • getQueuesZNodeCversion

    -
    protected int getQueuesZNodeCversion()
    +
    protected int getQueuesZNodeCversion()
                                   throws org.apache.zookeeper.KeeperException
    Throws:
    @@ -1114,7 +1126,7 @@ implements
  • getAllWALs

    -
    public Set<StringgetAllWALs()
    +
    public Set<StringgetAllWALs()
                            throws ReplicationException
    Description copied from interface: ReplicationQueueStorage
    Load all wals in all replication queues. This method guarantees to return a snapshot which @@ -1134,7 +1146,7 @@ implements
  • getHFileRefsPeerNode

    -
    private String getHFileRefsPeerNode(String peerId)
    +
    private String getHFileRefsPeerNode(String peerId)
  • @@ -1143,7 +1155,7 @@ implements
  • getHFileNode

    -
    private String getHFileNode(String peerNode,
    +
    private String getHFileNode(String peerNode,
                                 String fileName)
  • @@ -1153,7 +1165,7 @@ implements
  • addPeerToHFileRefs

    -
    public void addPeerToHFileRefs(String peerId)
    +
    public void addPeerToHFileRefs(String peerId)
                             throws ReplicationException
    Description copied from interface: ReplicationQueueStorage
    Add a peer to hfile reference queue if peer does not exist.
    @@ -1173,7 +1185,7 @@ implements
  • removePeerFromHFileRefs

    -
    public void removePeerFromHFileRefs(String peerId)
    +
    public void removePeerFromHFileRefs(String peerId)
                                  throws ReplicationException
    Description copied from interface: ReplicationQueueStorage
    Remove a peer from hfile reference queue.
    @@ -1193,7 +1205,7 @@ implements
  • addHFileRefs

    -
    public void addHFileRefs(String peerId,
    +
    public void addHFileRefs(String peerId,
                              List<Pair<org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path>> pairs)
                       throws ReplicationException
    Description copied from interface: ReplicationQueueStorage
    @@ -1216,7 +1228,7 @@ implements
  • removeHFileRefs

    -
    public void removeHFileRefs(String peerId,
    +
    public void removeHFileRefs(String peerId,
                                 List<String> files)
                          throws ReplicationException
    Description copied from interface: ReplicationQueueStorage
    @@ -1238,7 +1250,7 @@ implements
  • getAllPeersFromHFileRefsQueue0

    -
    private List<StringgetAllPeersFromHFileRefsQueue0()
    +
    private List<StringgetAllPeersFromHFileRefsQueue0()
                                                  throws org.apache.zookeeper.KeeperException
    Throws:
    @@ -1252,7 +1264,7 @@ implements
  • getAllPeersFromHFileRefsQueue

    -
    public List<StringgetAllPeersFromHFileRefsQueue()
    +
    public List<StringgetAllPeersFromHFileRefsQueue()
                                                throws ReplicationException
    Description copied from interface: ReplicationQueueStorage
    Get list of all peers from hfile reference queue.
    @@ -1272,7 +1284,7 @@ implements
  • getReplicableHFiles0

    -
    private List<StringgetReplicableHFiles0(String peerId)
    +
    private List<StringgetReplicableHFiles0(String peerId)
                                        throws org.apache.zookeeper.KeeperException
    Throws:
    @@ -1286,7 +1298,7 @@ implements
  • getReplicableHFiles

    -
    public List<StringgetReplicableHFiles(String peerId)
    +
    public List<StringgetReplicableHFiles(String peerId)
                                      throws ReplicationException
    Description copied from interface: ReplicationQueueStorage
    Get a list of all hfile references in the given peer.
    @@ -1308,7 +1320,7 @@ implements
  • getHFileRefsZNodeCversion

    -
    protected int getHFileRefsZNodeCversion()
    +
    protected int getHFileRefsZNodeCversion()
                                      throws ReplicationException
    Throws:
    @@ -1322,7 +1334,7 @@ implements
  • getAllHFileRefs

    -
    public Set<StringgetAllHFileRefs()
    +
    public Set<StringgetAllHFileRefs()
                                 throws ReplicationException
    Description copied from interface: ReplicationQueueStorage
    Load all hfile references in all replication queues. This method guarantees to return a