Class HdfsBackupRepository

    • Field Detail

      • copyBufferSize

        protected int copyBufferSize
    • Constructor Detail

      • HdfsBackupRepository

        public HdfsBackupRepository()
    • Method Detail

      • createURI

        public URI createURI​(String location)
        Description copied from interface: BackupRepository
        This method returns the URI representation for the specified path. Note - the specified path could be a fully qualified URI OR a relative path for a file-system.
        Specified by:
        createURI in interface BackupRepository
        Parameters:
        location - The path specified by the user.
        Returns:
        the URI representation of the user supplied value
      • resolve

        public URI resolve​(URI baseUri,
                           String... pathComponents)
        Description copied from interface: BackupRepository
        This method resolves a URI using the specified path components (as method arguments).
        Specified by:
        resolve in interface BackupRepository
        Parameters:
        baseUri - The base URI to use for creating the path
        pathComponents - The directory (or file-name) to be included in the URI.
        Returns:
        A URI containing absolute path
      • exists

        public boolean exists​(URI path)
                       throws IOException
        Description copied from interface: BackupRepository
        This method checks if the specified path exists in this repository.
        Specified by:
        exists in interface BackupRepository
        Parameters:
        path - The path whose existence needs to be checked.
        Returns:
        if the specified path exists in this repository.
        Throws:
        IOException - in case of errors
      • listAll

        public String[] listAll​(URI path)
                         throws IOException
        Description copied from interface: BackupRepository
        This method returns all the entries (files and directories) in the specified directory.
        Specified by:
        listAll in interface BackupRepository
        Parameters:
        path - The directory path
        Returns:
        an array of strings, one for each entry in the directory
        Throws:
        IOException - in case of errors
      • openInput

        public org.apache.lucene.store.IndexInput openInput​(URI dirPath,
                                                            String fileName,
                                                            org.apache.lucene.store.IOContext ctx)
                                                     throws IOException
        Description copied from interface: BackupRepository
        This method returns a Lucene input stream reading an existing file.
        Specified by:
        openInput in interface BackupRepository
        Parameters:
        dirPath - The parent directory of the file to be read
        fileName - The name of the file to be read
        ctx - the Lucene IO context
        Returns:
        Lucene IndexInput reference
        Throws:
        IOException - in case of errors
      • deleteDirectory

        public void deleteDirectory​(URI path)
                             throws IOException
        Description copied from interface: BackupRepository
        This method deletes a directory at the specified path.
        Specified by:
        deleteDirectory in interface BackupRepository
        Parameters:
        path - The path referring to the directory to be deleted.
        Throws:
        IOException - in case of errors
      • copyFileFrom

        public void copyFileFrom​(org.apache.lucene.store.Directory sourceDir,
                                 String fileName,
                                 URI dest)
                          throws IOException
        Description copied from interface: BackupRepository
        Copy a file from specified sourceDir to the destination repository (i.e. backup).
        Specified by:
        copyFileFrom in interface BackupRepository
        Parameters:
        sourceDir - The source directory hosting the file to be copied.
        fileName - The name of the file to by copied
        dest - The destination backup location.
        Throws:
        IOException - in case of errors
      • copyFileTo

        public void copyFileTo​(URI sourceRepo,
                               String fileName,
                               org.apache.lucene.store.Directory dest)
                        throws IOException
        Description copied from interface: BackupRepository
        Copy a file from specified sourceRepo to the destination directory (i.e. restore).
        Specified by:
        copyFileTo in interface BackupRepository
        Parameters:
        sourceRepo - The source URI hosting the file to be copied.
        fileName - The name of the file to by copied
        dest - The destination where the file should be copied.
        Throws:
        IOException - in case of errors.