Package org.apache.jackrabbit.oak.index.indexer.document.flatfile.pipelined

Class PipelinedTreeStoreTask

java.lang.Object

org.apache.jackrabbit.oak.index.indexer.document.flatfile.pipelined.PipelinedTreeStoreTask

All Implemented Interfaces:

Callable<org.apache.jackrabbit.oak.index.indexer.document.flatfile.pipelined.PipelinedSortBatchTask.Result>

public class PipelinedTreeStoreTask
extends Object
implements Callable<org.apache.jackrabbit.oak.index.indexer.document.flatfile.pipelined.PipelinedSortBatchTask.Result>

Receives batches of node state entries, sorts then in memory, and finally writes them to a tree store.

Constructor Summary

Constructors

Constructor	Description
PipelinedTreeStoreTask(TreeStore treeStore, ArrayBlockingQueue<NodeStateEntryBatch> emptyBuffersQueue, ArrayBlockingQueue<NodeStateEntryBatch> nonEmptyBuffersQueue, StatisticsProvider statisticsProvider, IndexingReporter reporter)

Method Summary

Modifier and Type	Method	Description
org.apache.jackrabbit.oak.index.indexer.document.flatfile.pipelined.PipelinedSortBatchTask.Result	call()
static String	removePropertiesOfBundledNodes(String path, String value)	If there are any, remove properties of bundled nodes (jcr:content/...) from the JSON-encoded node.

Methods inherited from class java.lang.Object

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

Constructor Detail

PipelinedTreeStoreTask

public PipelinedTreeStoreTask(TreeStore treeStore,
                              ArrayBlockingQueue<NodeStateEntryBatch> emptyBuffersQueue,
                              ArrayBlockingQueue<NodeStateEntryBatch> nonEmptyBuffersQueue,
                              StatisticsProvider statisticsProvider,
                              IndexingReporter reporter)

Method Detail

call

public org.apache.jackrabbit.oak.index.indexer.document.flatfile.pipelined.PipelinedSortBatchTask.Result call()
                                                                                                       throws Exception

Specified by:

call in interface Callable<org.apache.jackrabbit.oak.index.indexer.document.flatfile.pipelined.PipelinedSortBatchTask.Result>

Throws:

Exception

removePropertiesOfBundledNodes

public static String removePropertiesOfBundledNodes(String path,
                                                    String value)

If there are any, remove properties of bundled nodes (jcr:content/...) from the JSON-encoded node.

Parameters:

path - the path

value - the JSON-encoded node

Returns:

the cleaned JSON