Class ParallelTreeStore
- java.lang.Object
-
- org.apache.jackrabbit.oak.index.indexer.document.tree.ParallelTreeStore
-
- All Implemented Interfaces:
Closeable
,AutoCloseable
,Iterable<NodeStateEntry>
,IndexStore
public class ParallelTreeStore extends Object implements IndexStore
A wrapper around the tree store that only iterates over a subset of the nodes. Each parallel tree store reads the next block (a block is a tiny subset of the nodes). Once it has finished iterating over the block, it asks the backend for the next block. The result is that the whole range is covered, but it doesn't matter much which thread is how fast.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
long
getEntryCount()
String
getIndexStoreType()
String
getStorePath()
boolean
isIncremental()
Iterator<NodeStateEntry>
iterator()
void
setEntryCount(long entryCount)
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface java.lang.Iterable
forEach, spliterator
-
-
-
-
Method Detail
-
iterator
public Iterator<NodeStateEntry> iterator()
- Specified by:
iterator
in interfaceIndexStore
- Specified by:
iterator
in interfaceIterable<NodeStateEntry>
-
getStorePath
public String getStorePath()
- Specified by:
getStorePath
in interfaceIndexStore
-
getEntryCount
public long getEntryCount()
- Specified by:
getEntryCount
in interfaceIndexStore
-
setEntryCount
public void setEntryCount(long entryCount)
- Specified by:
setEntryCount
in interfaceIndexStore
-
close
public void close() throws IOException
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Specified by:
close
in interfaceIndexStore
- Throws:
IOException
-
getIndexStoreType
public String getIndexStoreType()
- Specified by:
getIndexStoreType
in interfaceIndexStore
-
isIncremental
public boolean isIncremental()
- Specified by:
isIncremental
in interfaceIndexStore
-
-