Package org.apache.jackrabbit.oak.segment.file

Class ReadOnlyFileStore

java.lang.Object

org.apache.jackrabbit.oak.segment.file.AbstractFileStore

org.apache.jackrabbit.oak.segment.file.ReadOnlyFileStore

All Implemented Interfaces:

Closeable, AutoCloseable, SegmentStore

public class ReadOnlyFileStore
extends AbstractFileStore

A read only AbstractFileStore implementation that supports going back to old revisions.

All write methods are no-ops.

Field Summary

Fields inherited from class org.apache.jackrabbit.oak.segment.file.AbstractFileStore

binariesInlineThreshold, ioMonitor, persistentCache, remoteStoreMonitor

Fields inherited from interface org.apache.jackrabbit.oak.segment.SegmentStore

EMPTY_STORE

Method Summary

Modifier and Type	Method	Description
void	collectBlobReferences(Consumer<String> collector)	Finds all external blob references that are currently accessible in this repository and adds them to the given collector.
boolean	containsSegment(SegmentId id)	Checks whether the identified segment exists in this store.
Set<SegmentId>	getReferencedSegmentIds()
ReadOnlyRevisions	getRevisions()
Iterable<SegmentId>	getSegmentIds()
Map<UUID,Set<UUID>>	getTarGraph(String fileName)
Map<String,Set<UUID>>	getTarReaderIndex()
@NotNull SegmentWriter	getWriter()
@NotNull Segment	readSegment(SegmentId id)	Reads the identified segment from this store.
protected void	registerCloseables(Closer closer)
void	setRevision(String revision)	Go to the specified revision
void	writeSegment(SegmentId id, byte[] data, int offset, int length)	Writes the given segment to the segment store.

Methods inherited from class org.apache.jackrabbit.oak.segment.file.AbstractFileStore

close, doClose, getBinariesInlineThreshold, getBlobStore, getHead, getReader, getSegmentCacheStats, getSegmentIdProvider, getStringCacheStats, getTemplateCacheStats

Methods inherited from class java.lang.Object

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

Method Detail

setRevision

public void setRevision(String revision)

Go to the specified revision

Parameters:

revision -

writeSegment

public void writeSegment(SegmentId id,
                         byte[] data,
                         int offset,
                         int length)

Description copied from interface: SegmentStore

Writes the given segment to the segment store.

Parameters:

id - segment identifier

data - byte buffer that contains the raw contents of the segment

offset - start offset within the byte buffer

length - length of the segment

containsSegment

public boolean containsSegment(SegmentId id)

Description copied from interface: SegmentStore

Checks whether the identified segment exists in this store.

Parameters:

id - segment identifier

Returns:

true if the segment exists, false otherwise

readSegment

@NotNull
public @NotNull Segment readSegment(SegmentId id)

Description copied from interface: SegmentStore

Reads the identified segment from this store.

Parameters:

id - segment identifier

Returns:

identified segment, or a SegmentNotFoundException thrown if not found

registerCloseables

protected void registerCloseables(Closer closer)

Overrides:

registerCloseables in class AbstractFileStore

getWriter

@NotNull
public @NotNull SegmentWriter getWriter()

Specified by:

getWriter in class AbstractFileStore

getTarReaderIndex

public Map<String,Set<UUID>> getTarReaderIndex()

getTarGraph

public Map<UUID,Set<UUID>> getTarGraph(String fileName)
                                      throws IOException

Throws:

IOException

getSegmentIds

public Iterable<SegmentId> getSegmentIds()

getRevisions

public ReadOnlyRevisions getRevisions()

Specified by:

getRevisions in class AbstractFileStore

Returns:

the Revisions object bound to the current store.

getReferencedSegmentIds

public Set<SegmentId> getReferencedSegmentIds()

collectBlobReferences

public void collectBlobReferences(Consumer<String> collector)
                           throws IOException

Description copied from class: AbstractFileStore

Finds all external blob references that are currently accessible in this repository and adds them to the given collector. Useful for collecting garbage in an external data store.

Note that this method only collects blob references that are already stored in the repository (at the time when this method is called), so the garbage collector will need some other mechanism for tracking in-memory references and references stored while this method is running.

Specified by:

collectBlobReferences in class AbstractFileStore

Parameters:

collector - reference collector called back for each blob reference found

Throws:

IOException