Package org.apache.solr.hdfs.backup.repository

Class HdfsBackupRepository

java.lang.Object

org.apache.solr.hdfs.backup.repository.HdfsBackupRepository

All Implemented Interfaces:

Closeable, AutoCloseable, BackupRepository, NamedListInitializedPlugin

public class HdfsBackupRepository
extends Object
implements BackupRepository

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.solr.core.backup.repository.BackupRepository

BackupRepository.PathType

Field Summary

Fields

Modifier and Type	Field	Description
protected int	copyBufferSize

Constructor Summary

Constructors

Constructor	Description
HdfsBackupRepository()

Method Summary

Modifier and Type	Method	Description
void	close()
void	copyIndexFileFrom(org.apache.lucene.store.Directory sourceDir, String sourceFileName, URI destDir, String destFileName)
void	copyIndexFileTo(URI sourceRepo, String sourceFileName, org.apache.lucene.store.Directory dest, String destFileName)
void	createDirectory(URI path)
OutputStream	createOutput(URI path)
URI	createURI(String location)
void	delete(URI path, Collection<String> files, boolean ignoreNoSuchFileException)
void	deleteDirectory(URI path)
boolean	exists(URI path)
<T> T	getConfigProperty(String name)
BackupRepository.PathType	getPathType(URI path)
void	init(org.apache.solr.common.util.NamedList<?> args)
String[]	listAll(URI path)
org.apache.lucene.store.IndexInput	openInput(URI dirPath, String fileName, org.apache.lucene.store.IOContext ctx)
URI	resolve(URI baseUri, String... pathComponents)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.solr.core.backup.repository.BackupRepository

checksum, copyFileFrom, copyFileTo, copyIndexFileFrom, createDirectoryURI, getBackupLocation, listAllOrEmpty, resolveDirectory

Field Detail

copyBufferSize

protected int copyBufferSize

Constructor Detail

HdfsBackupRepository

public HdfsBackupRepository()

Method Detail

init

public void init(org.apache.solr.common.util.NamedList<?> args)

Specified by:

init in interface NamedListInitializedPlugin

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

getConfigProperty

public <T> T getConfigProperty(String name)

Specified by:

getConfigProperty in interface BackupRepository

createURI

public URI createURI(String location)

Specified by:

createURI in interface BackupRepository

resolve

public URI resolve(URI baseUri,
                   String... pathComponents)

Specified by:

resolve in interface BackupRepository

exists

public boolean exists(URI path)
               throws IOException

Specified by:

exists in interface BackupRepository

Throws:

IOException

getPathType

public BackupRepository.PathType getPathType(URI path)
                                      throws IOException

Specified by:

getPathType in interface BackupRepository

Throws:

IOException

listAll

public String[] listAll(URI path)
                 throws IOException

Specified by:

listAll in interface BackupRepository

Throws:

IOException

openInput

public org.apache.lucene.store.IndexInput openInput(URI dirPath,
                                                    String fileName,
                                                    org.apache.lucene.store.IOContext ctx)
                                             throws IOException

Specified by:

openInput in interface BackupRepository

Throws:

IOException

createOutput

public OutputStream createOutput(URI path)
                          throws IOException

Specified by:

createOutput in interface BackupRepository

Throws:

IOException

createDirectory

public void createDirectory(URI path)
                     throws IOException

Specified by:

createDirectory in interface BackupRepository

Throws:

IOException

deleteDirectory

public void deleteDirectory(URI path)
                     throws IOException

Specified by:

deleteDirectory in interface BackupRepository

Throws:

IOException

copyIndexFileFrom

public void copyIndexFileFrom(org.apache.lucene.store.Directory sourceDir,
                              String sourceFileName,
                              URI destDir,
                              String destFileName)
                       throws IOException

Specified by:

copyIndexFileFrom in interface BackupRepository

Throws:

IOException

copyIndexFileTo

public void copyIndexFileTo(URI sourceRepo,
                            String sourceFileName,
                            org.apache.lucene.store.Directory dest,
                            String destFileName)
                     throws IOException

Specified by:

copyIndexFileTo in interface BackupRepository

Throws:

IOException

delete

public void delete(URI path,
                   Collection<String> files,
                   boolean ignoreNoSuchFileException)
            throws IOException

Specified by:

delete in interface BackupRepository

Throws:

IOException