public class AwsSegmentArchiveWriter extends AbstractRemoteSegmentArchiveWriter
created, entries, index, ioMonitor, monitor, queue, totalLength
Constructor and Description |
---|
AwsSegmentArchiveWriter(S3Directory directory,
java.lang.String archiveName,
IOMonitor ioMonitor,
FileStoreMonitor monitor) |
Modifier and Type | Method and 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.
|
close, containsSegment, flush, getEntryCount, getLength, isCreated, readSegment, writeBinaryReferences, writeDataFile, writeGraph, writeSegment
public AwsSegmentArchiveWriter(S3Directory directory, java.lang.String archiveName, IOMonitor ioMonitor, FileStoreMonitor monitor)
public java.lang.String getName()
SegmentArchiveWriter
protected void doWriteArchiveEntry(RemoteSegmentArchiveEntry indexEntry, byte[] data, int offset, int size) throws java.io.IOException
AbstractRemoteSegmentArchiveWriter
doWriteArchiveEntry
in class AbstractRemoteSegmentArchiveWriter
java.io.IOException
protected Buffer doReadArchiveEntry(RemoteSegmentArchiveEntry indexEntry) throws java.io.IOException
AbstractRemoteSegmentArchiveWriter
doReadArchiveEntry
in class AbstractRemoteSegmentArchiveWriter
java.io.IOException
protected void doWriteDataFile(byte[] data, java.lang.String extension) throws java.io.IOException
AbstractRemoteSegmentArchiveWriter
doWriteDataFile
in class AbstractRemoteSegmentArchiveWriter
java.io.IOException
protected void afterQueueClosed() throws java.io.IOException
AbstractRemoteSegmentArchiveWriter
afterQueueClosed
in class AbstractRemoteSegmentArchiveWriter
java.io.IOException
protected void afterQueueFlushed() throws java.io.IOException
AbstractRemoteSegmentArchiveWriter
afterQueueFlushed
in class AbstractRemoteSegmentArchiveWriter
java.io.IOException
Copyright © 2012–2022 The Apache Software Foundation. All rights reserved.