public class SortingSequence extends BufferingSequence
NodeSequence.AlternateSizeBatch, NodeSequence.Batch, NodeSequence.LimitBatch, NodeSequence.MultiWidthBatch, NodeSequence.Restartable, NodeSequence.RowAccessor, NodeSequence.RowFilter, NodeSequence.SingleWidthBatch
buffer, cache, extractor, logger, remainingRowCount, rowFactory, rowsLeftInBatch, trace, width, workspaceName
delegate
LOGGER, NO_PASS_ROW_FILTER, PASS_ROW_FILTER
Constructor and Description |
---|
SortingSequence(String workspaceName,
NodeSequence delegate,
RowExtractors.ExtractFromRow extractor,
BufferManager bufferMgr,
CachedNodeSupplier nodeCache,
boolean pack,
boolean useHeap,
boolean allowDuplicates,
NullOrder nullOrder) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Signal that this node sequence is no longer needed.
|
long |
getRowCount()
Get the number of rows in this sequence.
|
protected Iterator<BufferedRows.BufferedRow> |
initialize()
Initialize this node sequence only the first time that
nextBatch() is called. |
NodeSequence.Batch |
nextBatch()
Get the next batch of
NodeKey instances. |
String |
toString() |
batchFrom, createRow, isEmpty, loadAll, rowCount
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 SortingSequence(String workspaceName, NodeSequence delegate, RowExtractors.ExtractFromRow extractor, BufferManager bufferMgr, CachedNodeSupplier nodeCache, boolean pack, boolean useHeap, boolean allowDuplicates, NullOrder nullOrder)
public long getRowCount()
NodeSequence
getRowCount
in class DelegatingSequence
public NodeSequence.Batch nextBatch()
NodeSequence
NodeKey
instances.nextBatch
in class DelegatingSequence
protected Iterator<BufferedRows.BufferedRow> initialize()
nextBatch()
is called.public void close()
NodeSequence
close
in class BufferingSequence
Copyright © 2008–2016 JBoss, a division of Red Hat. All rights reserved.