public class PartialMemoryCountableSequence extends CountableSequence
CountableSequence
NodeSequence.AlternateSizeBatch, NodeSequence.Batch, NodeSequence.LimitBatch, NodeSequence.MultiWidthBatch, NodeSequence.Restartable, NodeSequence.RowAccessor, NodeSequence.RowFilter, NodeSequence.SingleWidthBatch
remainingRowCount, width, workspaceName
LOGGER, NO_PASS_ROW_FILTER, PASS_ROW_FILTER
Constructor and Description |
---|
PartialMemoryCountableSequence(String workspaceName,
NodeSequence original,
BufferManager bufferMgr,
CachedNodeSupplier nodeCache,
int numRowsInMemory) |
Modifier and Type | Method and Description |
---|---|
protected NodeSequence.Batch |
doNextBatch() |
protected long |
loadAll(NodeSequence sequence,
BufferManager.QueueBuffer<BufferedRows.BufferedRow> buffer,
AtomicLong batchSize)
Load all of the rows from the supplied sequence into the buffer.
|
batchFrom, close, createRow, doInitialize, getRowCount, initialize, isEmpty, loadAll, nextBatch, width
append, batchFilteredWith, batchOf, batchOf, batchOf, batchOfKeys, batchOfKeys, batchOfKeys, batchOfKeys, batchWithCount, copy, emptyBatch, emptySequence, filter, keyFor, limit, limit, merging, requireBoth, requireEither, skip, slice, slicingBatch, withBatch, withBatches, withBatches, withNode, withNodeKeys, withNodeKeys, withNodeKeys, withNodeKeys, withNodes, withNodes
public PartialMemoryCountableSequence(String workspaceName, NodeSequence original, BufferManager bufferMgr, CachedNodeSupplier nodeCache, int numRowsInMemory)
protected NodeSequence.Batch doNextBatch()
doNextBatch
in class CountableSequence
protected long loadAll(NodeSequence sequence, BufferManager.QueueBuffer<BufferedRows.BufferedRow> buffer, AtomicLong batchSize)
CountableSequence
loadAll
in class CountableSequence
sequence
- the node sequence; may not be nullbuffer
- the buffer into which all rows should be loaded; may not be nullbatchSize
- the atomic that should be set with the size of the first batchCopyright © 2008–2016 JBoss, a division of Red Hat. All rights reserved.