Package org.apache.jackrabbit.oak.segment

Class SegmentBufferWriterPool

java.lang.Object

org.apache.jackrabbit.oak.segment.SegmentBufferWriterPool

public abstract 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	Description
static class	SegmentBufferWriterPool.PoolType
static class	SegmentBufferWriterPool.SegmentBufferWriterPoolFactory

Method Summary

Modifier and Type	Method	Description
@NotNull RecordId	execute(@NotNull GCGeneration gcGeneration, @NotNull org.apache.jackrabbit.oak.segment.WriteOperationHandler.WriteOperation writeOperation)	Execute the passed writeOperation by passing it a SegmentBufferWriter.
static SegmentBufferWriterPool.SegmentBufferWriterPoolFactory	factory(@NotNull SegmentIdProvider idProvider, @NotNull String wid, @NotNull Supplier<GCGeneration> gcGeneration)
void	flush(@NotNull SegmentStore store)	Flush any pending changes on any SegmentBufferWriter managed by this instance.
@NotNull GCGeneration	getGCGeneration()
protected @NotNull String	getWriterId()
protected @NotNull SegmentBufferWriter	newWriter(@NotNull GCGeneration gcGeneration)

Methods inherited from class java.lang.Object

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

Method Detail

factory

public static SegmentBufferWriterPool.SegmentBufferWriterPoolFactory factory(@NotNull
                                                                             @NotNull SegmentIdProvider idProvider,
                                                                             @NotNull
                                                                             @NotNull String wid,
                                                                             @NotNull
                                                                             @NotNull Supplier<GCGeneration> gcGeneration)

getGCGeneration

@NotNull
public @NotNull GCGeneration getGCGeneration()

newWriter

@NotNull
protected @NotNull SegmentBufferWriter newWriter(@NotNull
                                                 @NotNull GCGeneration gcGeneration)

getWriterId

@NotNull
protected @NotNull String getWriterId()

execute

@NotNull
public abstract @NotNull RecordId execute(@NotNull
                                          @NotNull GCGeneration gcGeneration,
                                          @NotNull
                                          @NotNull org.apache.jackrabbit.oak.segment.WriteOperationHandler.WriteOperation writeOperation)
                                   throws 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:

IOException

flush

public abstract void flush(@NotNull
                           @NotNull 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