Package org.apache.jackrabbit.oak.segment

Class SegmentBufferWriterPool

java.lang.Object

org.apache.jackrabbit.oak.segment.SegmentBufferWriterPool

public abstract 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	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 SegmentReader reader, @NotNull java.lang.String wid, @NotNull org.apache.jackrabbit.guava.common.base.Supplier<GCGeneration> gcGeneration)
void	flush(@NotNull SegmentStore store)	Flush any pending changes on any SegmentBufferWriter managed by this instance.
@NotNull GCGeneration	getGCGeneration()
protected @NotNull java.lang.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 SegmentReader reader,
                                                                             @NotNull
                                                                             @NotNull java.lang.String wid,
                                                                             @NotNull
                                                                             @NotNull org.apache.jackrabbit.guava.common.base.Supplier<GCGeneration> gcGeneration)

getGCGeneration

@NotNull
public @NotNull GCGeneration getGCGeneration()

newWriter

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

getWriterId

@NotNull
protected @NotNull java.lang.String getWriterId()

execute

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