Package org.apache.jackrabbit.oak.segment.azure

Class AzureSegmentArchiveWriter

java.lang.Object

org.apache.jackrabbit.oak.segment.remote.AbstractRemoteSegmentArchiveWriter

org.apache.jackrabbit.oak.segment.azure.AzureSegmentArchiveWriter

All Implemented Interfaces:

SegmentArchiveWriter

public class AzureSegmentArchiveWriter
extends AbstractRemoteSegmentArchiveWriter

Field Summary

Fields inherited from class org.apache.jackrabbit.oak.segment.remote.AbstractRemoteSegmentArchiveWriter

created, entries, index, ioMonitor, monitor, queue, totalLength, writeAccessController

Constructor Summary

Constructors

Constructor	Description
AzureSegmentArchiveWriter(com.microsoft.azure.storage.blob.CloudBlobDirectory archiveDirectory, IOMonitor ioMonitor, FileStoreMonitor monitor, WriteAccessController writeAccessController)

Method Summary

Modifier and Type	Method	Description
protected void	afterQueueClosed()	Hook for executing additional actions after the segment write queue is closed.
protected void	afterQueueFlushed()	Hook for executing additional actions after the segment write queue is flushed.
protected Buffer	doReadArchiveEntry(RemoteSegmentArchiveEntry indexEntry)	Reads a segment from remote storage into a buffer.
protected void	doWriteArchiveEntry(RemoteSegmentArchiveEntry indexEntry, byte[] data, int offset, int size)	Writes a segment to the remote storage.
protected void	doWriteDataFile(byte[] data, java.lang.String extension)	Writes a data file inside the archive.
java.lang.String	getName()	Get the name of the archive.

Methods inherited from class org.apache.jackrabbit.oak.segment.remote.AbstractRemoteSegmentArchiveWriter

close, containsSegment, flush, getEntryCount, getLength, isCreated, isRemote, readSegment, writeBinaryReferences, writeDataFile, writeGraph, writeSegment

Methods inherited from class java.lang.Object

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

Constructor Detail

AzureSegmentArchiveWriter

public AzureSegmentArchiveWriter(com.microsoft.azure.storage.blob.CloudBlobDirectory archiveDirectory,
                                 IOMonitor ioMonitor,
                                 FileStoreMonitor monitor,
                                 WriteAccessController writeAccessController)

Method Detail

getName

public java.lang.String getName()

Description copied from interface: SegmentArchiveWriter

Get the name of the archive.

Returns:

archive name

doWriteArchiveEntry

protected void doWriteArchiveEntry(RemoteSegmentArchiveEntry indexEntry,
                                   byte[] data,
                                   int offset,
                                   int size)
                            throws java.io.IOException

Description copied from class: AbstractRemoteSegmentArchiveWriter

Writes a segment to the remote storage.

Specified by:

doWriteArchiveEntry in class AbstractRemoteSegmentArchiveWriter

Parameters:

indexEntry - , the archive index entry to write

data - , the actual bytes in the entry

offset - , the start offset in the data.

size - , the number of bytes to write.

Throws:

java.io.IOException

doReadArchiveEntry

protected Buffer doReadArchiveEntry(RemoteSegmentArchiveEntry indexEntry)
                             throws java.io.IOException

Description copied from class: AbstractRemoteSegmentArchiveWriter

Reads a segment from remote storage into a buffer.

Specified by:

doReadArchiveEntry in class AbstractRemoteSegmentArchiveWriter

Parameters:

indexEntry - , the archive index entry to read

Returns:

th buffer containing the segment bytes

Throws:

java.io.IOException

doWriteDataFile

protected void doWriteDataFile(byte[] data,
                               java.lang.String extension)
                        throws java.io.IOException

Description copied from class: AbstractRemoteSegmentArchiveWriter

Writes a data file inside the archive. This entry is not a segment. Its full name is given by archive name + extension.

Specified by:

doWriteDataFile in class AbstractRemoteSegmentArchiveWriter

Parameters:

data - , bytes to write

extension - , the extension of the data file

Throws:

java.io.IOException

afterQueueClosed

protected void afterQueueClosed()
                         throws java.io.IOException

Description copied from class: AbstractRemoteSegmentArchiveWriter

Hook for executing additional actions after the segment write queue is closed.

Specified by:

afterQueueClosed in class AbstractRemoteSegmentArchiveWriter

Throws:

java.io.IOException

afterQueueFlushed

protected void afterQueueFlushed()

Description copied from class: AbstractRemoteSegmentArchiveWriter

Hook for executing additional actions after the segment write queue is flushed.

Specified by:

afterQueueFlushed in class AbstractRemoteSegmentArchiveWriter