Constructor Detail

• ReplicationHFileCleaner

  public ReplicationHFileCleaner()

Method Detail

• getDeletableFiles

  public Iterable<org.apache.hadoop.fs.FileStatus> getDeletableFiles(Iterable<org.apache.hadoop.fs.FileStatus> files)

  Description copied from interface: FileCleanerDelegate
  Determines which of the given files are safe to delete

  Specified by:

  getDeletableFiles in interface FileCleanerDelegate

  Overrides:

  getDeletableFiles in class BaseFileCleanerDelegate

  Parameters:

  files - files to check for deletion

  Returns:

  files that are ok to delete according to this cleaner

• setConf

  public void setConf(org.apache.hadoop.conf.Configuration config)

  Specified by:

  setConf in interface org.apache.hadoop.conf.Configurable

  Overrides:

  setConf in class BaseConfigurable

• setConf

  public void setConf(org.apache.hadoop.conf.Configuration conf,
             ZooKeeperWatcher zk)

• stop

  public void stop(String why)

  Description copied from interface: Stoppable
  Stop this service. Implementers should favor logging errors over throwing RuntimeExceptions.

  Specified by:

  stop in interface Stoppable

  Overrides:

  stop in class BaseHFileCleanerDelegate

  Parameters:

  why - Why we're stopping.

• isStopped

  public boolean isStopped()

  Specified by:

  isStopped in interface Stoppable

  Overrides:

  isStopped in class BaseHFileCleanerDelegate

  Returns:

  True if Stoppable.stop(String) has been closed.

• isFileDeletable

  public boolean isFileDeletable(org.apache.hadoop.fs.FileStatus fStat)

  Description copied from class: BaseFileCleanerDelegate
  Should the master delete the file or keep it?

  Specified by:

  isFileDeletable in class BaseFileCleanerDelegate

  Parameters:

  fStat - file status of the file to check

  Returns:

  true if the file is deletable, false if not