org.apache.jackrabbit.oak.segment

Class SegmentBufferWriterPool

java.lang.Object

org.apache.jackrabbit.oak.segment.SegmentBufferWriterPool

public class SegmentBufferWriterPool
extends Object

This WriteOperationHandler uses a pool of SegmentBufferWriters, which it passes to its execute method.

Instances of this class are thread safe.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	WriteOperationHandler.WriteOperation A WriteOperation encapsulates an operation on a SegmentWriter.

Constructor Summary

Constructors

Constructor and Description
SegmentBufferWriterPool(SegmentIdProvider idProvider, SegmentReader reader, String wid, Supplier<GCGeneration> gcGeneration)

Method Summary

Modifier and Type	Method and Description
RecordId	execute(WriteOperationHandler.WriteOperation writeOperation) Execute the passed writeOperation by passing it a SegmentBufferWriter.
void	flush(SegmentStore store) Flush any pending changes on any SegmentBufferWriter managed by this instance.

Methods inherited from class java.lang.Object

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

Constructor Detail

SegmentBufferWriterPool

public SegmentBufferWriterPool(@Nonnull
                               SegmentIdProvider idProvider,
                               @Nonnull
                               SegmentReader reader,
                               @Nonnull
                               String wid,
                               @Nonnull
                               Supplier<GCGeneration> gcGeneration)

Method Detail

execute

@Nonnull
public RecordId execute(@Nonnull
                                  WriteOperationHandler.WriteOperation writeOperation)
                           throws IOException

Execute the passed writeOperation by passing it a SegmentBufferWriter.

Parameters:

writeOperation - WriteOperationHandler.WriteOperation to execute

Returns:

RecordId that resulted from persisting the changes.

Throws:

IOException

flush

public void flush(@Nonnull
                  SegmentStore store)
           throws IOException

Flush any pending changes on any SegmentBufferWriter managed by this instance.

Parameters:

store - the SegmentStore instance to write the Segment to

Throws:

IOException