org.apache.jackrabbit.oak.segment.scheduler

Class LockBasedScheduler

java.lang.Object

org.apache.jackrabbit.oak.segment.scheduler.LockBasedScheduler

All Implemented Interfaces:

Scheduler

public class LockBasedScheduler
extends Object
implements Scheduler

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LockBasedScheduler.LockBasedSchedulerBuilder

Nested classes/interfaces inherited from interface org.apache.jackrabbit.oak.segment.scheduler.Scheduler

Scheduler.SchedulerOption

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicReference<SegmentNodeState>	head

Constructor Summary

Constructors

Constructor and Description
LockBasedScheduler(LockBasedScheduler.LockBasedSchedulerBuilder builder)

Method Summary

Modifier and Type	Method and Description
static LockBasedScheduler.LockBasedSchedulerBuilder	builder(@NotNull Revisions revisions, @NotNull SegmentReader reader, @NotNull SegmentNodeStoreStats stats)
String	checkpoint(long lifetime, @NotNull Map<String,String> properties) Creates a new checkpoint of the latest root of the tree.
protected void	contentChanged(NodeState root, CommitInfo info)
NodeState	getHeadNodeState() Returns the latest state of the tree.
boolean	removeCheckpoint(String name) Releases the provided checkpoint.
NodeState	schedule(@NotNull Commit commit, Scheduler.SchedulerOption... schedulingOptions) Schedule a commit.

Methods inherited from class java.lang.Object

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

Field Detail

head

protected final AtomicReference<SegmentNodeState> head

Constructor Detail

LockBasedScheduler

public LockBasedScheduler(LockBasedScheduler.LockBasedSchedulerBuilder builder)

Method Detail

builder

public static LockBasedScheduler.LockBasedSchedulerBuilder builder(@NotNull
                                                                   @NotNull Revisions revisions,
                                                                   @NotNull
                                                                   @NotNull SegmentReader reader,
                                                                   @NotNull
                                                                   @NotNull SegmentNodeStoreStats stats)

getHeadNodeState

public NodeState getHeadNodeState()

Description copied from interface: Scheduler

Returns the latest state of the tree.

Specified by:

getHeadNodeState in interface Scheduler

Returns:

the latest state.

contentChanged

protected void contentChanged(NodeState root,
                              CommitInfo info)

schedule

public NodeState schedule(@NotNull
                          @NotNull Commit commit,
                          Scheduler.SchedulerOption... schedulingOptions)
                   throws CommitFailedException

Description copied from interface: Scheduler

Schedule a commit. This method blocks until the changes in this commit have been processed and persisted. That is, until a call to Scheduler.getHeadNodeState() would return a node state reflecting those changes.

Specified by:

schedule in interface Scheduler

Parameters:

commit - the commit

schedulingOptions - implementation specific scheduling options

Throws:

CommitFailedException - if the commit failed and none of the changes have been applied.

checkpoint

public String checkpoint(long lifetime,
                         @NotNull
                         @NotNull Map<String,String> properties)

Description copied from interface: Scheduler

Creates a new checkpoint of the latest root of the tree. The checkpoint remains valid for at least as long as requested and allows that state of the repository to be retrieved using the returned opaque string reference.

The properties passed to this methods are associated with the checkpoint and can be retrieved through the NodeStore.checkpointInfo(String) method. Its semantics is entirely application specific.

Specified by:

checkpoint in interface Scheduler

Parameters:

lifetime - time (in milliseconds, > 0) that the checkpoint should remain available

properties - properties to associate with the checkpoint

Returns:

string reference of this checkpoint

removeCheckpoint

public boolean removeCheckpoint(String name)

Description copied from interface: Scheduler

Releases the provided checkpoint. If the provided checkpoint doesn't exist this method should return true.

Specified by:

removeCheckpoint in interface Scheduler

Parameters:

name - string reference of a checkpoint

Returns:

true if the checkpoint was successfully removed, or if it doesn't exist