org.apache.jackrabbit.oak.segment

Class SegmentBufferWriterPool

java.lang.Object

org.apache.jackrabbit.oak.segment.SegmentBufferWriterPool

public class SegmentBufferWriterPool
extends java.lang.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(@NotNull SegmentIdProvider idProvider, @NotNull SegmentReader reader, @NotNull java.lang.String wid, @NotNull Supplier<GCGeneration> gcGeneration)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

SegmentBufferWriterPool

public SegmentBufferWriterPool(@NotNull
                               @NotNull SegmentIdProvider idProvider,
                               @NotNull
                               @NotNull SegmentReader reader,
                               @NotNull
                               @NotNull java.lang.String wid,
                               @NotNull
                               @NotNull Supplier<GCGeneration> gcGeneration)

Method Detail

getGCGeneration

@NotNull
public @NotNull GCGeneration getGCGeneration()

Returns:

the current GCGeneration of the store.

execute

@NotNull
public @NotNull RecordId execute(@NotNull
                                          @NotNull GCGeneration gcGeneration,
                                          @NotNull
                                          @NotNull WriteOperationHandler.WriteOperation writeOperation)
                                   throws java.io.IOException

Execute the passed writeOperation by passing it a SegmentBufferWriter.

Parameters:

gcGeneration - the GCGeneration the changes should persisted with.

writeOperation - WriteOperationHandler.WriteOperation to execute

Returns:

RecordId that resulted from persisting the changes.

Throws:

java.io.IOException

flush

public void flush(@NotNull
                  @NotNull SegmentStore store)
           throws java.io.IOException

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

Parameters:

store - the SegmentStore instance to write the Segment to

Throws:

java.io.IOException