Package org.apache.jackrabbit.oak.plugins.index

Class AsyncCheckpointCreator

java.lang.Object

org.apache.jackrabbit.oak.plugins.index.AsyncCheckpointCreator

All Implemented Interfaces:

java.lang.Runnable

public class AsyncCheckpointCreator
extends java.lang.Object
implements java.lang.Runnable

This class is responsible for creating and deleting checkpoints asynchronously. The number of minimum concurrent checkpoints to keep in the system, along with the default lifetime of a checkpoint can be configured. When executed, this class should create one checkpoint in a single run with a configurable name. Following the creation of the checkpoint, it should try to delete checkpoints with the given name, in case the total number of such checkpoints is greater than the configured minimum concurrent checkpoints. By default, this task is registered using AsyncCheckpointService

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	CHECKPOINT_CREATED_KEY
static java.lang.String	CHECKPOINT_CREATED_TIMESTAMP_KEY
static java.lang.String	CHECKPOINT_CREATOR_KEY
static java.lang.String	CHECKPOINT_NAME_KEY
static java.lang.String	CHECKPOINT_THREAD_KEY
static java.lang.String	PROP_ASYNC_NAME	Name of service property which determines the name of this Async task

Constructor Summary

Constructors

Constructor	Description
AsyncCheckpointCreator(@NotNull NodeStore store, @NotNull java.lang.String name, long checkpointLifetimeInSeconds, long minConcurrentCheckpoints, long maxConcurrentCheckpoints)

Method Summary

Modifier and Type	Method	Description
java.lang.String	getName()
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

PROP_ASYNC_NAME

public static final java.lang.String PROP_ASYNC_NAME

Name of service property which determines the name of this Async task

See Also:

Constant Field Values

CHECKPOINT_CREATOR_KEY

public static final java.lang.String CHECKPOINT_CREATOR_KEY

See Also:

Constant Field Values

CHECKPOINT_CREATED_KEY

public static final java.lang.String CHECKPOINT_CREATED_KEY

See Also:

Constant Field Values

CHECKPOINT_CREATED_TIMESTAMP_KEY

public static final java.lang.String CHECKPOINT_CREATED_TIMESTAMP_KEY

See Also:

Constant Field Values

CHECKPOINT_THREAD_KEY

public static final java.lang.String CHECKPOINT_THREAD_KEY

See Also:

Constant Field Values

CHECKPOINT_NAME_KEY

public static final java.lang.String CHECKPOINT_NAME_KEY

See Also:

Constant Field Values

Constructor Detail

AsyncCheckpointCreator

public AsyncCheckpointCreator(@NotNull
                              @NotNull NodeStore store,
                              @NotNull
                              @NotNull java.lang.String name,
                              long checkpointLifetimeInSeconds,
                              long minConcurrentCheckpoints,
                              long maxConcurrentCheckpoints)

Method Detail

getName

public java.lang.String getName()

run

public void run()

Specified by:

run in interface java.lang.Runnable