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

Class AsyncCheckpointCreator

java.lang.Object

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

All Implemented Interfaces:

Runnable

public class AsyncCheckpointCreator
extends Object
implements 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 String	CHECKPOINT_CREATED_KEY
static String	CHECKPOINT_CREATED_TIMESTAMP_KEY
static String	CHECKPOINT_CREATOR_KEY
static String	CHECKPOINT_NAME_KEY
static String	CHECKPOINT_THREAD_KEY
static 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 String name, long checkpointLifetimeInSeconds, long minConcurrentCheckpoints, long maxConcurrentCheckpoints)

Method Summary

Modifier and Type	Method	Description
protected long	getCheckpointLifetimeInSeconds()
protected long	getMaxConcurrentCheckpoints()
protected long	getMinConcurrentCheckpoints()
String	getName()
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

PROP_ASYNC_NAME

public static final 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 String CHECKPOINT_CREATOR_KEY

See Also:

Constant Field Values

CHECKPOINT_CREATED_KEY

public static final String CHECKPOINT_CREATED_KEY

See Also:

Constant Field Values

CHECKPOINT_CREATED_TIMESTAMP_KEY

public static final String CHECKPOINT_CREATED_TIMESTAMP_KEY

See Also:

Constant Field Values

CHECKPOINT_THREAD_KEY

public static final String CHECKPOINT_THREAD_KEY

See Also:

Constant Field Values

CHECKPOINT_NAME_KEY

public static final String CHECKPOINT_NAME_KEY

See Also:

Constant Field Values

Constructor Detail

AsyncCheckpointCreator

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

Method Detail

getName

public String getName()

getCheckpointLifetimeInSeconds

protected long getCheckpointLifetimeInSeconds()

getMinConcurrentCheckpoints

protected long getMinConcurrentCheckpoints()

getMaxConcurrentCheckpoints

protected long getMaxConcurrentCheckpoints()

run

public void run()

Specified by:

run in interface Runnable