org.apache.jackrabbit.oak.plugins.index.lucene

Class IndexCopier

java.lang.Object

org.apache.jackrabbit.oak.plugins.index.lucene.IndexCopier

All Implemented Interfaces:

Closeable, AutoCloseable, CopyOnReadStatsMBean

public class IndexCopier
extends Object
implements CopyOnReadStatsMBean, Closeable

Field Summary

Fields inherited from interface org.apache.jackrabbit.oak.plugins.index.lucene.CopyOnReadStatsMBean

TYPE

Constructor Summary

Constructors

Constructor and Description
IndexCopier(Executor executor, File indexRootDir)
IndexCopier(Executor executor, File indexRootDir, boolean prefetchEnabled)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
protected org.apache.lucene.store.Directory	createLocalDirForIndexReader(String indexPath, org.apache.jackrabbit.oak.plugins.index.lucene.IndexDefinition definition)
protected org.apache.lucene.store.Directory	createLocalDirForIndexWriter(org.apache.jackrabbit.oak.plugins.index.lucene.IndexDefinition definition)
int	getCopyInProgressCount()
String[]	getCopyInProgressDetails()
String	getCopyInProgressSize()
int	getDeletedFilesCount()
int	getDownloadCount()
String	getDownloadSize()
long	getDownloadTime()
String	getGarbageCollectedSize()
String[]	getGarbageDetails()
String	getGarbageSize()
File	getIndexDir(String indexPath)
TabularData	getIndexPathMapping()
int	getInvalidFileCount()
String	getLocalIndexSize()
int	getMaxCopyInProgressCount()
int	getMaxScheduledForCopyCount()
int	getReaderLocalReadCount()
int	getReaderRemoteReadCount()
int	getScheduledForCopyCount()
String	getSkippedFromUploadSize()
int	getUploadCount()
String	getUploadSize()
long	getUploadTime()
int	getWriterLocalReadCount()
int	getWriterRemoteReadCount()
boolean	isPrefetchEnabled()
org.apache.lucene.store.Directory	wrapForRead(String indexPath, org.apache.jackrabbit.oak.plugins.index.lucene.IndexDefinition definition, org.apache.lucene.store.Directory remote)
org.apache.lucene.store.Directory	wrapForWrite(org.apache.jackrabbit.oak.plugins.index.lucene.IndexDefinition definition, org.apache.lucene.store.Directory remote, boolean reindexMode)

Methods inherited from class java.lang.Object

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

Constructor Detail

IndexCopier

public IndexCopier(Executor executor,
           File indexRootDir)
            throws IOException

Throws:

IOException

IndexCopier

public IndexCopier(Executor executor,
           File indexRootDir,
           boolean prefetchEnabled)
            throws IOException

Throws:

IOException

Method Detail

wrapForRead

public org.apache.lucene.store.Directory wrapForRead(String indexPath,
                                            org.apache.jackrabbit.oak.plugins.index.lucene.IndexDefinition definition,
                                            org.apache.lucene.store.Directory remote)
                                              throws IOException

Throws:

IOException

wrapForWrite

public org.apache.lucene.store.Directory wrapForWrite(org.apache.jackrabbit.oak.plugins.index.lucene.IndexDefinition definition,
                                             org.apache.lucene.store.Directory remote,
                                             boolean reindexMode)
                                               throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

createLocalDirForIndexWriter

protected org.apache.lucene.store.Directory createLocalDirForIndexWriter(org.apache.jackrabbit.oak.plugins.index.lucene.IndexDefinition definition)
                                                                  throws IOException

Throws:

IOException

createLocalDirForIndexReader

protected org.apache.lucene.store.Directory createLocalDirForIndexReader(String indexPath,
                                                             org.apache.jackrabbit.oak.plugins.index.lucene.IndexDefinition definition)
                                                                  throws IOException

Throws:

IOException

getIndexDir

public File getIndexDir(String indexPath)

getIndexPathMapping

public TabularData getIndexPathMapping()

Specified by:

getIndexPathMapping in interface CopyOnReadStatsMBean

isPrefetchEnabled

public boolean isPrefetchEnabled()

Specified by:

isPrefetchEnabled in interface CopyOnReadStatsMBean

getReaderLocalReadCount

public int getReaderLocalReadCount()

Specified by:

getReaderLocalReadCount in interface CopyOnReadStatsMBean

getReaderRemoteReadCount

public int getReaderRemoteReadCount()

Specified by:

getReaderRemoteReadCount in interface CopyOnReadStatsMBean

getWriterLocalReadCount

public int getWriterLocalReadCount()

Specified by:

getWriterLocalReadCount in interface CopyOnReadStatsMBean

getWriterRemoteReadCount

public int getWriterRemoteReadCount()

Specified by:

getWriterRemoteReadCount in interface CopyOnReadStatsMBean

getInvalidFileCount

public int getInvalidFileCount()

getDownloadSize

public String getDownloadSize()

Specified by:

getDownloadSize in interface CopyOnReadStatsMBean

getDownloadTime

public long getDownloadTime()

Specified by:

getDownloadTime in interface CopyOnReadStatsMBean

getDownloadCount

public int getDownloadCount()

Specified by:

getDownloadCount in interface CopyOnReadStatsMBean

getUploadCount

public int getUploadCount()

Specified by:

getUploadCount in interface CopyOnReadStatsMBean

getUploadSize

public String getUploadSize()

Specified by:

getUploadSize in interface CopyOnReadStatsMBean

getUploadTime

public long getUploadTime()

Specified by:

getUploadTime in interface CopyOnReadStatsMBean

getLocalIndexSize

public String getLocalIndexSize()

Specified by:

getLocalIndexSize in interface CopyOnReadStatsMBean

getGarbageDetails

public String[] getGarbageDetails()

Specified by:

getGarbageDetails in interface CopyOnReadStatsMBean

getGarbageSize

public String getGarbageSize()

Specified by:

getGarbageSize in interface CopyOnReadStatsMBean

getScheduledForCopyCount

public int getScheduledForCopyCount()

Specified by:

getScheduledForCopyCount in interface CopyOnReadStatsMBean

getCopyInProgressCount

public int getCopyInProgressCount()

Specified by:

getCopyInProgressCount in interface CopyOnReadStatsMBean

getCopyInProgressSize

public String getCopyInProgressSize()

Specified by:

getCopyInProgressSize in interface CopyOnReadStatsMBean

getMaxCopyInProgressCount

public int getMaxCopyInProgressCount()

Specified by:

getMaxCopyInProgressCount in interface CopyOnReadStatsMBean

getMaxScheduledForCopyCount

public int getMaxScheduledForCopyCount()

Specified by:

getMaxScheduledForCopyCount in interface CopyOnReadStatsMBean

getSkippedFromUploadSize

public String getSkippedFromUploadSize()

Specified by:

getSkippedFromUploadSize in interface CopyOnReadStatsMBean

getCopyInProgressDetails

public String[] getCopyInProgressDetails()

Specified by:

getCopyInProgressDetails in interface CopyOnReadStatsMBean

getDeletedFilesCount

public int getDeletedFilesCount()

Specified by:

getDeletedFilesCount in interface CopyOnReadStatsMBean

getGarbageCollectedSize

public String getGarbageCollectedSize()

Specified by:

getGarbageCollectedSize in interface CopyOnReadStatsMBean