org.apache.jackrabbit.oak.spi.blob.split

Class WrappingSplitBlobStore

java.lang.Object

org.apache.jackrabbit.oak.spi.blob.split.WrappingSplitBlobStore

All Implemented Interfaces:

BlobStore, BlobStoreWrapper, SplitBlobStore

public class WrappingSplitBlobStore
extends Object
implements BlobStoreWrapper, SplitBlobStore

Constructor Summary

Constructors

Constructor and Description
WrappingSplitBlobStore(String repositoryDir, BlobStore newBlobStore)

Method Summary

Modifier and Type	Method and Description
String	getBlobId(String reference) Returns the blobId that referred by the given binary reference.
long	getBlobLength(String blobId) Get the length of the blob.
InputStream	getInputStream(String blobId) Returns a new stream for given blobId.
String	getReference(String blobId) Returns a secure reference to blob referred by blobid, or null if no such reference is available.
boolean	isMigrated(String blobId)
int	readBlob(String blobId, long pos, byte[] buff, int off, int length) Read a number of bytes from a blob.
void	setBlobStore(BlobStore blobStore)
String	writeBlob(InputStream in) Write a blob from an input stream.
String	writeBlob(InputStream in, BlobOptions options) Ignores the options provided and delegates to writeBlob(InputStream).

Methods inherited from class java.lang.Object

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

Constructor Detail

WrappingSplitBlobStore

public WrappingSplitBlobStore(String repositoryDir,
                              BlobStore newBlobStore)

Method Detail

setBlobStore

public void setBlobStore(BlobStore blobStore)

Specified by:

setBlobStore in interface BlobStoreWrapper

writeBlob

public String writeBlob(InputStream in)
                 throws IOException

Description copied from interface: BlobStore

Write a blob from an input stream. This method closes the input stream.

Specified by:

writeBlob in interface BlobStore

Parameters:

in - the input stream

Returns:

the blob id

Throws:

IOException

writeBlob

public String writeBlob(InputStream in,
                        BlobOptions options)
                 throws IOException

Ignores the options provided and delegates to writeBlob(InputStream).

Specified by:

writeBlob in interface BlobStore

Parameters:

in - the input stream to write

options - the options to use

Returns:

Throws:

IOException

readBlob

public int readBlob(String blobId,
                    long pos,
                    byte[] buff,
                    int off,
                    int length)
             throws IOException

Description copied from interface: BlobStore

Read a number of bytes from a blob.

Specified by:

readBlob in interface BlobStore

Parameters:

blobId - the blob id

pos - the position within the blob

buff - the target byte array

off - the offset within the target array

length - the number of bytes to read

Returns:

the number of bytes read

Throws:

IOException

getBlobLength

public long getBlobLength(String blobId)
                   throws IOException

Description copied from interface: BlobStore

Get the length of the blob.

Specified by:

getBlobLength in interface BlobStore

Parameters:

blobId - the blob id

Returns:

the length

Throws:

IOException

getInputStream

public InputStream getInputStream(String blobId)
                           throws IOException

Description copied from interface: BlobStore

Returns a new stream for given blobId. The streams returned from multiple calls to this method are byte wise equals. That is, subsequent calls to read return the same sequence of bytes as long as neither call throws an exception.

Specified by:

getInputStream in interface BlobStore

Parameters:

blobId - the blob id

Returns:

a new stream for given blobId

Throws:

IOException

getBlobId

public String getBlobId(String reference)

Description copied from interface: BlobStore

Returns the blobId that referred by the given binary reference. Returns null if the reference is invalid, for example if it points to a blob that does not exist.

Specified by:

getBlobId in interface BlobStore

Parameters:

reference - binary reference

Returns:

matching blobId, or null

getReference

public String getReference(String blobId)

Description copied from interface: BlobStore

Returns a secure reference to blob referred by blobid, or null if no such reference is available.

Specified by:

getReference in interface BlobStore

Parameters:

blobId - blobId referring the blob for which reference is required

Returns:

binary reference, or null

isMigrated

public boolean isMigrated(String blobId)
                   throws IOException

Specified by:

isMigrated in interface SplitBlobStore

Throws:

IOException