Package | Description |
---|---|
org.modeshape.jcr.query.engine.process |
When executing a query, the processing phase involves "running" each branch in the optimized query plan, determining
the set of nodes that satisfies each branch, and then joining each branch into a single result.
|
Modifier and Type | Interface and Description |
---|---|
static interface |
BufferedRows.BufferedRowFactory<T extends BufferedRows.BufferedRow> |
Modifier and Type | Class and Description |
---|---|
static class |
BufferedRows.DoubleNodeRow |
static class |
BufferedRows.MultiNodeRow |
static class |
BufferedRows.QuadNodeRow |
static class |
BufferedRows.SingleNodeRow |
static class |
BufferedRows.TripleNodeRow |
Modifier and Type | Field and Description |
---|---|
protected BufferManager.SortingBuffer<Object,BufferedRows.BufferedRow> |
BufferingSequence.buffer |
protected BufferManager.DistinctBuffer<BufferedRows.BufferedRow> |
HashJoinSequence.rightRowsWithNullKey |
protected BufferedRows.BufferedRowFactory<? extends BufferedRows.BufferedRow> |
BufferingSequence.rowFactory |
protected org.mapdb.Serializer<BufferedRows.BufferedRow> |
RestartableSequence.rowSerializer |
Modifier and Type | Method and Description |
---|---|
protected BufferedRows.BufferedRow |
RestartableSequence.createRow(NodeSequence.Batch currentRow) |
protected BufferedRows.BufferedRow |
CountableSequence.createRow(NodeSequence.Batch currentRow) |
protected BufferedRows.BufferedRow |
BufferingSequence.createRow(NodeSequence.Batch currentRow) |
Modifier and Type | Method and Description |
---|---|
protected Iterator<BufferedRows.BufferedRow> |
HashJoinSequence.allRightRows() |
BufferManager.QueueBuffer<BufferedRows.BufferedRow> |
RestartableSequence.QueueBufferSupplier.get() |
protected Iterator<BufferedRows.BufferedRow> |
HashJoinSequence.HashJoinBatch.getRightRowsFor(Object leftValue) |
protected Iterator<BufferedRows.BufferedRow> |
HashJoinSequence.HashJoinRangeBatch.getRightRowsFor(Object leftValue) |
protected Iterator<BufferedRows.BufferedRow> |
HashJoinSequence.HashCrossJoinBatch.getRightRowsFor(Object leftValue) |
protected Iterator<BufferedRows.BufferedRow> |
SortingSequence.initialize()
Initialize this node sequence only the first time that
SortingSequence.nextBatch() is called. |
Iterator<BufferedRows.BufferedRow> |
RestartableSequence.QueueBufferSupplier.iterator() |
protected Iterator<BufferedRows.BufferedRow> |
AbstractNodeKeysSequence.matchingRightRows(Object keyInLeft) |
static BufferedRows.BufferedRowFactory<? extends BufferedRows.BufferedRow> |
BufferedRows.serializer(CachedNodeSupplier nodeCache,
int width) |
Modifier and Type | Method and Description |
---|---|
protected NodeSequence.Batch |
RestartableSequence.batchFrom(Iterator<BufferedRows.BufferedRow> rows,
long maxBatchSize) |
protected NodeSequence.Batch |
CountableSequence.batchFrom(Iterator<BufferedRows.BufferedRow> rows,
long maxBatchSize) |
protected NodeSequence.Batch |
BufferingSequence.batchFrom(Iterator<BufferedRows.BufferedRow> rows,
long maxBatchSize) |
protected long |
PartialMemoryCountableSequence.loadAll(NodeSequence sequence,
BufferManager.QueueBuffer<BufferedRows.BufferedRow> buffer,
AtomicLong batchSize) |
protected long |
CountableSequence.loadAll(NodeSequence sequence,
BufferManager.QueueBuffer<BufferedRows.BufferedRow> buffer,
AtomicLong batchSize)
Load all of the rows from the supplied sequence into the buffer.
|
protected long |
CountableSequence.loadAll(NodeSequence sequence,
BufferManager.QueueBuffer<BufferedRows.BufferedRow> buffer,
AtomicLong batchSize,
Queue<NodeSequence.Batch> inMemoryBatches,
int numRowsInMemory)
Load all of the rows from the supplied sequence into the buffer.
|
protected int |
BufferingSequence.loadAll(NodeSequence sequence,
RowExtractors.ExtractFromRow extractor,
BufferManager.DistinctBuffer<BufferedRows.BufferedRow> rowsWithNullKey)
Load all of the rows from the supplied sequence into the buffer.
|
Constructor and Description |
---|
HashJoinSequence.RightRowsBatch(Iterator<BufferedRows.BufferedRow> rightRows,
int maxSize) |
Copyright © 2008-2014 JBoss, a division of Red Hat. All Rights Reserved.