org.apache.jackrabbit.oak.plugins.document

Class DocumentNodeStore

java.lang.Object

org.apache.jackrabbit.oak.plugins.document.DocumentNodeStore

All Implemented Interfaces:

NodeStateDiffer, RevisionContext, Observable, Clusterable, NodeStore

public final class DocumentNodeStore
extends java.lang.Object
implements NodeStore, RevisionContext, Observable, Clusterable, NodeStateDiffer

Implementation of a NodeStore on DocumentStore.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.jackrabbit.oak.plugins.document.CommitQueue	commitQueue The commit queue to coordinate the commits.
static java.util.List<java.lang.String>	META_PROP_NAMES List of meta properties which are created by DocumentNodeStore and which needs to be retained in any cloned copy of DocumentNodeState.
static java.lang.String	SYS_PROP_DISABLE_JOURNAL
static java.lang.String	SYS_PROP_DISABLE_SWEEP2
static FormatVersion	VERSION

Fields inherited from interface org.apache.jackrabbit.oak.plugins.document.NodeStateDiffer

DEFAULT_DIFFER

Constructor Summary

Constructors

Constructor and Description
DocumentNodeStore(DocumentNodeStoreBuilder<?> builder)

Method Summary

Modifier and Type	Method and Description
java.io.Closeable	addObserver(Observer observer) Register a new Observer.
@NotNull java.lang.String	checkpoint(long lifetime) Creates a new checkpoint of the latest root of the tree.
@NotNull java.lang.String	checkpoint(long lifetime, @NotNull java.util.Map<java.lang.String,java.lang.String> properties) Creates a new checkpoint of the latest root of the tree.
@NotNull java.util.Map<java.lang.String,java.lang.String>	checkpointInfo(@NotNull java.lang.String checkpoint) Retrieve the properties associated with a checkpoint.
@NotNull java.lang.Iterable<java.lang.String>	checkpoints() Returns all valid checkpoints.
boolean	compare(@NotNull AbstractDocumentNodeState node, @NotNull AbstractDocumentNodeState base, @NotNull NodeStateDiff diff) Compares the given node against the base state and reports the differences to the NodeStateDiff.
@NotNull BlobStoreBlob	createBlob(java.io.InputStream inputStream) Create a Blob from the given input stream.
@Nullable MarkSweepGarbageCollector	createBlobGarbageCollector(long blobGcMaxAgeInSecs, java.lang.String repositoryId, Whiteboard whiteboard, StatisticsProvider statisticsProvider) Creates and returns a MarkSweepGarbageCollector if the current BlobStore supports garbage collection
@NotNull PropertyState	createPropertyState(java.lang.String name, java.lang.String value)
void	dispose()
int	getAsyncDelay()
Blob	getBlob(@NotNull java.lang.String reference) Returns the Blob with the given reference.
Blob	getBlobFromBlobId(java.lang.String blobId) Returns the Blob with the given blobId.
BlobStore	getBlobStore()
org.apache.jackrabbit.oak.plugins.document.UnmergedBranches	getBranches()
BundlingConfigHandler	getBundlingConfigHandler()
int	getChangeSetMaxDepth()
int	getChangeSetMaxItems()
org.apache.jackrabbit.oak.plugins.document.Checkpoints	getCheckpoints()
@NotNull Clock	getClock()
int	getClusterId()
@NotNull ClusterNodeInfo	getClusterInfo()
java.lang.String	getCommitValue(@NotNull Revision changeRevision, @NotNull NodeDocument doc) Retrieves the commit value for a given change.
org.apache.jackrabbit.oak.plugins.document.DiffCache	getDiffCache()
@NotNull java.lang.Iterable<CacheStats>	getDiffCacheStats()
@NotNull DocumentStore	getDocumentStore()
@NotNull RevisionVector	getHeadRevision()
java.lang.String	getInstanceId() Will return a unique number per instance across the cluster.
@NotNull JournalGarbageCollector	getJournalGarbageCollector()
JournalPropertyHandlerFactory	getJournalPropertyHandlerFactory()
@NotNull LastRevRecoveryAgent	getLastRevRecoveryAgent()
int	getMaxBackOffMillis()
long	getMaxTimeDiffMillis()
DocumentNodeStoreMBean	getMBean()
@Nullable DocumentNodeState	getNode(@NotNull Path path, @NotNull RevisionVector rev) Get the node for the given path and revision.
Cache<PathRev,DocumentNodeState>	getNodeCache()
Predicate<Path>	getNodeCachePredicate()
CacheStats	getNodeCacheStats()
Cache<NamePathRev,DocumentNodeState.Children>	getNodeChildrenCache()
CacheStats	getNodeChildrenCacheStats()
DocumentNodeStateCache	getNodeStateCache()
org.apache.jackrabbit.oak.plugins.document.UnsavedModifications	getPendingModifications()
int	getPendingWriteCount()
java.util.Iterator<ReferencedBlob>	getReferencedBlobsIterator() Returns an iterator for all the blob present in the store.
@NotNull DocumentNodeState	getRoot() Returns the latest state of the tree.
DocumentNodeStoreStatsCollector	getStatsCollector()
@NotNull VersionGarbageCollector	getVersionGarbageCollector()
java.lang.String	getVisibilityToken() Returns the visibility token of the underlying NodeStore.
boolean	isDisableBranches()
boolean	isVisible(@NotNull java.lang.String visibilityToken, long maxWaitMillis) Checks if the underlying NodeStore sees at least the changes that were visible at the time the visibility token was created on potentially another instance if in a clustered NodeStore setup.
@NotNull NodeState	merge(@NotNull NodeBuilder builder, @NotNull CommitHook commitHook, @NotNull CommitInfo info) Merges the changes between the base and head states of the given builder to this store.
@NotNull Revision	newRevision()
@NotNull NodeState	rebase(@NotNull NodeBuilder builder) Rebases the changes between the base and head states of the given builder on top of the current root state.
boolean	release(@NotNull java.lang.String checkpoint) Releases the provided checkpoint.
NodeState	reset(@NotNull NodeBuilder builder) Reset the passed builder by throwing away all its changes and setting its base state to the current root state.
@Nullable NodeState	retrieve(@NotNull java.lang.String checkpoint) Retrieves the root node from a previously created repository checkpoint.
void	runBackgroundOperations() Used for testing only
void	setAsyncDelay(int delay)
void	setChangeSetMaxDepth(int changeSetMaxDepth)
void	setChangeSetMaxItems(int changeSetMaxItems)
void	setMaxBackOffMillis(int time)
void	setNodeStateCache(DocumentNodeStateCache nodeStateCache)

Methods inherited from class java.lang.Object

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

Field Detail

VERSION

public static final FormatVersion VERSION

META_PROP_NAMES

public static final java.util.List<java.lang.String> META_PROP_NAMES

List of meta properties which are created by DocumentNodeStore and which needs to be retained in any cloned copy of DocumentNodeState.

SYS_PROP_DISABLE_JOURNAL

public static final java.lang.String SYS_PROP_DISABLE_JOURNAL

See Also:

Constant Field Values

SYS_PROP_DISABLE_SWEEP2

public static final java.lang.String SYS_PROP_DISABLE_SWEEP2

See Also:

Constant Field Values

commitQueue

protected final org.apache.jackrabbit.oak.plugins.document.CommitQueue commitQueue

The commit queue to coordinate the commits.

Constructor Detail

DocumentNodeStore

public DocumentNodeStore(DocumentNodeStoreBuilder<?> builder)

Method Detail

dispose

public void dispose()

getDocumentStore

@NotNull
public @NotNull DocumentStore getDocumentStore()

setAsyncDelay

public void setAsyncDelay(int delay)

getAsyncDelay

public int getAsyncDelay()

setMaxBackOffMillis

public void setMaxBackOffMillis(int time)

getMaxBackOffMillis

public int getMaxBackOffMillis()

getChangeSetMaxItems

public int getChangeSetMaxItems()

setChangeSetMaxItems

public void setChangeSetMaxItems(int changeSetMaxItems)

getChangeSetMaxDepth

public int getChangeSetMaxDepth()

setChangeSetMaxDepth

public void setChangeSetMaxDepth(int changeSetMaxDepth)

getClusterInfo

@NotNull
public @NotNull ClusterNodeInfo getClusterInfo()

getNodeCacheStats

public CacheStats getNodeCacheStats()

getNodeChildrenCacheStats

public CacheStats getNodeChildrenCacheStats()

getDiffCacheStats

@NotNull
public @NotNull java.lang.Iterable<CacheStats> getDiffCacheStats()

getNodeCache

public Cache<PathRev,DocumentNodeState> getNodeCache()

getNodeChildrenCache

public Cache<NamePathRev,DocumentNodeState.Children> getNodeChildrenCache()

getNodeCachePredicate

public Predicate<Path> getNodeCachePredicate()

getPendingWriteCount

public int getPendingWriteCount()

isDisableBranches

public boolean isDisableBranches()

getMaxTimeDiffMillis

public long getMaxTimeDiffMillis()

createPropertyState

@NotNull
public @NotNull PropertyState createPropertyState(java.lang.String name,
                                                           java.lang.String value)

getNode

@Nullable
public @Nullable DocumentNodeState getNode(@NotNull
                                                     @NotNull Path path,
                                                     @NotNull
                                                     @NotNull RevisionVector rev)

Get the node for the given path and revision. The returned object might not be modified directly.

Parameters:

path - the path of the node.

rev - the read revision.

Returns:

the node or null if the node does not exist at the given revision.

getBundlingConfigHandler

public BundlingConfigHandler getBundlingConfigHandler()

compare

public boolean compare(@NotNull
                       @NotNull AbstractDocumentNodeState node,
                       @NotNull
                       @NotNull AbstractDocumentNodeState base,
                       @NotNull
                       @NotNull NodeStateDiff diff)

Compares the given node against the base state and reports the differences to the NodeStateDiff.

Specified by:

compare in interface NodeStateDiffer

Parameters:

node - the node to compare.

base - the base node to compare against.

diff - handler of node state differences

Returns:

true if the full diff was performed, or false if it was aborted as requested by the handler (see the NodeStateDiff contract for more details)

addObserver

public java.io.Closeable addObserver(Observer observer)

Description copied from interface: Observable

Register a new Observer. Clients need to call Closeable.close() to stop getting notifications on the registered observer and to free up any resources associated with the registration.

Specified by:

addObserver in interface Observable

Returns:

a Closeable instance.

getRoot

@NotNull
public @NotNull DocumentNodeState getRoot()

Description copied from interface: NodeStore

Returns the latest state of the tree.

Specified by:

getRoot in interface NodeStore

Returns:

root node state

merge

@NotNull
public @NotNull NodeState merge(@NotNull
                                         @NotNull NodeBuilder builder,
                                         @NotNull
                                         @NotNull CommitHook commitHook,
                                         @NotNull
                                         @NotNull CommitInfo info)
                                  throws CommitFailedException

Description copied from interface: NodeStore

Merges the changes between the base and head states of the given builder to this store.

Specified by:

merge in interface NodeStore

Parameters:

builder - the builder whose changes to apply

commitHook - the commit hook to apply while merging changes

info - commit info associated with this merge operation

Returns:

the node state resulting from the merge.

Throws:

CommitFailedException - if the merge failed

rebase

@NotNull
public @NotNull NodeState rebase(@NotNull
                                          @NotNull NodeBuilder builder)

Description copied from interface: NodeStore

Rebases the changes between the base and head states of the given builder on top of the current root state. The base state of the given builder becomes the latest root state of the repository, and the head state will contain the rebased changes.

Specified by:

rebase in interface NodeStore

Parameters:

builder - the builder to rebase

Returns:

the node state resulting from the rebase.

reset

public NodeState reset(@NotNull
                       @NotNull NodeBuilder builder)

Description copied from interface: NodeStore

Reset the passed builder by throwing away all its changes and setting its base state to the current root state.

Specified by:

reset in interface NodeStore

Parameters:

builder - the builder to reset

Returns:

the node state resulting from the reset.

createBlob

@NotNull
public @NotNull BlobStoreBlob createBlob(java.io.InputStream inputStream)
                                           throws java.io.IOException

Description copied from interface: NodeStore

Create a Blob from the given input stream. The input stream is closed after this method returns.

Specified by:

createBlob in interface NodeStore

Parameters:

inputStream - The input stream for the Blob

Returns:

The Blob representing inputStream

Throws:

java.io.IOException - If an error occurs while reading from the stream

getBlob

public Blob getBlob(@NotNull
                    @NotNull java.lang.String reference)

Returns the Blob with the given reference. Note that this method is meant to be used with secure reference obtained from Blob#reference which is different from blobId

Specified by:

getBlob in interface NodeStore

Parameters:

reference - the reference of the blob.

Returns:

the blob.

See Also:

Blob.getReference()

getBlobFromBlobId

public Blob getBlobFromBlobId(java.lang.String blobId)

Returns the Blob with the given blobId.

Parameters:

blobId - the blobId of the blob.

Returns:

the blob.

checkpoint

@NotNull
public @NotNull java.lang.String checkpoint(long lifetime,
                                                     @NotNull
                                                     @NotNull java.util.Map<java.lang.String,java.lang.String> properties)

Description copied from interface: NodeStore

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 NodeStore

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

checkpoint

@NotNull
public @NotNull java.lang.String checkpoint(long lifetime)

Description copied from interface: NodeStore

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.

This method is a shortcut for NodeStore.checkpoint(long, Map) passing an empty map for its 2nd argument.

Specified by:

checkpoint in interface NodeStore

Parameters:

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

Returns:

string reference of this checkpoint

checkpointInfo

@NotNull
public @NotNull java.util.Map<java.lang.String,java.lang.String> checkpointInfo(@NotNull
                                                                                         @NotNull java.lang.String checkpoint)

Description copied from interface: NodeStore

Retrieve the properties associated with a checkpoint.

Specified by:

checkpointInfo in interface NodeStore

Parameters:

checkpoint - string reference of a checkpoint

Returns:

the properties associated with the checkpoint referenced by checkpoint or an empty map when there is no such checkpoint.

checkpoints

@NotNull
public @NotNull java.lang.Iterable<java.lang.String> checkpoints()

Description copied from interface: NodeStore

Returns all valid checkpoints. The returned Iterable provides a snapshot of valid checkpoints at the time this method is called. That is, the Iterable will not reflect checkpoints created after this method was called.

See NodeStore.checkpoint(long, Map) for a definition of a valid checkpoint.

Specified by:

checkpoints in interface NodeStore

Returns:

valid checkpoints.

retrieve

@Nullable
public @Nullable NodeState retrieve(@NotNull
                                              @NotNull java.lang.String checkpoint)

Description copied from interface: NodeStore

Retrieves the root node from a previously created repository checkpoint.

Specified by:

retrieve in interface NodeStore

Parameters:

checkpoint - string reference of a checkpoint

Returns:

the root node of the checkpoint, or null if the checkpoint is no longer available

release

public boolean release(@NotNull
                       @NotNull java.lang.String checkpoint)

Description copied from interface: NodeStore

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

Specified by:

release in interface NodeStore

Parameters:

checkpoint - string reference of a checkpoint

Returns:

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

getBranches

public org.apache.jackrabbit.oak.plugins.document.UnmergedBranches getBranches()

Specified by:

getBranches in interface RevisionContext

Returns:

the branches of the local DocumentMK instance, which are not yet merged.

getPendingModifications

public org.apache.jackrabbit.oak.plugins.document.UnsavedModifications getPendingModifications()

Specified by:

getPendingModifications in interface RevisionContext

Returns:

the pending modifications.

getClusterId

public int getClusterId()

Specified by:

getClusterId in interface RevisionContext

Returns:

the cluster id of the local DocumentMK instance.

getHeadRevision

@NotNull
public @NotNull RevisionVector getHeadRevision()

Specified by:

getHeadRevision in interface RevisionContext

Returns:

the current head revision.

newRevision

@NotNull
public @NotNull Revision newRevision()

Specified by:

newRevision in interface RevisionContext

Returns:

a new revision for the local document node store instance.

getClock

@NotNull
public @NotNull Clock getClock()

Specified by:

getClock in interface RevisionContext

Returns:

the clock in use when a new revision is created.

getCommitValue

public java.lang.String getCommitValue(@NotNull
                                       @NotNull Revision changeRevision,
                                       @NotNull
                                       @NotNull NodeDocument doc)

Description copied from interface: RevisionContext

Retrieves the commit value for a given change. This method returns the following types of commit values:

• "c" : the change revision is committed as is.
• "c-rX-Y-Z" : the change revision is a branch commit merged in revision "rX-Y-Z".
• "brX-Y-Z" : the change revision is a branch commit done at "rX-Y-Z" but not yet merged.
• null : the change revision does not have an entry on the commit root document and is not committed.

Specified by:

getCommitValue in interface RevisionContext

Parameters:

changeRevision - the revision a change was made.

doc - the document where the change was made.

Returns:

the commit value or null if the change does not have a commit value (yet).

runBackgroundOperations

public void runBackgroundOperations()

Used for testing only

createBlobGarbageCollector

@Nullable
public @Nullable MarkSweepGarbageCollector createBlobGarbageCollector(long blobGcMaxAgeInSecs,
                                                                                java.lang.String repositoryId,
                                                                                Whiteboard whiteboard,
                                                                                StatisticsProvider statisticsProvider)

Creates and returns a MarkSweepGarbageCollector if the current BlobStore supports garbage collection

Parameters:

blobGcMaxAgeInSecs -

repositoryId -

whiteboard -

statisticsProvider -

Returns:

garbage collector of the BlobStore supports GC otherwise null

getMBean

public DocumentNodeStoreMBean getMBean()

getBlobStore

public BlobStore getBlobStore()

getReferencedBlobsIterator

public java.util.Iterator<ReferencedBlob> getReferencedBlobsIterator()

Returns an iterator for all the blob present in the store.

In some cases the iterator might implement Closeable. So callers should check for such iterator and close them.

Returns:

an iterator for all the blobs

getDiffCache

public org.apache.jackrabbit.oak.plugins.document.DiffCache getDiffCache()

getCheckpoints

public org.apache.jackrabbit.oak.plugins.document.Checkpoints getCheckpoints()

getVersionGarbageCollector

@NotNull
public @NotNull VersionGarbageCollector getVersionGarbageCollector()

getJournalGarbageCollector

@NotNull
public @NotNull JournalGarbageCollector getJournalGarbageCollector()

getLastRevRecoveryAgent

@NotNull
public @NotNull LastRevRecoveryAgent getLastRevRecoveryAgent()

getInstanceId

public java.lang.String getInstanceId()

Description copied from interface: Clusterable

Will return a unique number per instance across the cluster. It will only make its best effort to preserve the same number across restarts but it must be unique across the cluster.

Specified by:

getInstanceId in interface Clusterable

Returns:

Cannot be null or empty.

getVisibilityToken

public java.lang.String getVisibilityToken()

Description copied from interface: Clusterable

Returns the visibility token of the underlying NodeStore. A 'visibility token' is an opaque String that can be used to verify if changes done on one NodeStore are visible on another NodeStore of the same cluster. This can be achieved by generating such a visibility token on the source NodeStore, passing it on to the target NodeStore (by whatever means) and checking for visibility on that target NodeStore.

The visibility check returns true if the target NodeStore sees at least all the changes that the source NodeStore saw at time of visibility token generation. Once a visibility token is visible on a particular NodeStore it will always return true ever after. This also implies that the visibility check can only state whether at least all source changes are visible on the target and that it is independent of any further modifications.

When source and target NodeStore are identical, the visibility check is expected to return true, immediately. This is based on the assumption that with a session.refresh() on that NodeStore you'll always get the latest changes applied by any other session locally.

Visibility tokens are meant to be lightweight and are not expected to be persisted by the implementor. Nevertheless they should survive their validity in the case of crashes of the source and/or the target instance.

Specified by:

getVisibilityToken in interface Clusterable

isVisible

public boolean isVisible(@NotNull
                         @NotNull java.lang.String visibilityToken,
                         long maxWaitMillis)
                  throws java.lang.InterruptedException

Description copied from interface: Clusterable

Checks if the underlying NodeStore sees at least the changes that were visible at the time the visibility token was created on potentially another instance if in a clustered NodeStore setup.

If the visibility token was created on the underlying NodeStore this check always returns true, immediately.

Specified by:

isVisible in interface Clusterable

Parameters:

visibilityToken - the visibility token that was created on another instance in a clustered NodeStore setup. Providing null is not supported and might throw a RuntimeException

maxWaitMillis - if >-1 waits (at max this many milliseconds if >0, forever if ==0) until the underlying NodeStore sees at least the changes represented by the provided visibility token. if < 0 the method does not wait

Returns:

true if the underlying NodeStore sees at least the changes that were visible at the time the visibility token was created

Throws:

java.lang.InterruptedException - (optionally) thrown if interrupted while waiting

getStatsCollector

public DocumentNodeStoreStatsCollector getStatsCollector()

getNodeStateCache

public DocumentNodeStateCache getNodeStateCache()

setNodeStateCache

public void setNodeStateCache(DocumentNodeStateCache nodeStateCache)

getJournalPropertyHandlerFactory

public JournalPropertyHandlerFactory getJournalPropertyHandlerFactory()