Constructor Detail

• ReplicationZKNodeCleaner

  public ReplicationZKNodeCleaner(org.apache.hadoop.conf.Configuration conf,
                          ZooKeeperWatcher zkw,
                          Abortable abortable)
                           throws IOException

  Throws:

  IOException

Method Detail

• getUnDeletedQueues

  public Map<String,List<String>> getUnDeletedQueues()
                                              throws IOException

  Returns:

  undeletedQueues replicator with its queueIds for removed peers

  Throws:

  IOException

• getUnDeletedHFileRefsQueues

  public Set<String> getUnDeletedHFileRefsQueues()
                                          throws IOException

  Returns:

  undeletedHFileRefsQueue replicator with its undeleted queueIds for removed peers in hfile-refs queue

  Throws:

  IOException

• removeQueues

  public void removeQueues(Map<String,List<String>> undeletedQueues)
                    throws IOException

  Remove the undeleted replication queue's zk node for removed peers.

  Parameters:

  undeletedQueues - replicator with its queueIds for removed peers

  Throws:

  IOException

• removeHFileRefsQueues

  public void removeHFileRefsQueues(Set<String> undeletedHFileRefsQueues)
                             throws IOException

  Remove the undeleted hfile-refs queue's zk node for removed peers.

  Parameters:

  undeletedHFileRefsQueues - replicator with its undeleted queueIds for removed peers in hfile-refs queue

  Throws:

  IOException