Modifier and Type | Method and Description |
---|---|
TupleBuffer |
BufferManager.createTupleBuffer(List elements,
String groupName,
BufferManager.TupleSourceType tupleSourceType) |
TupleBuffer |
TupleBufferCache.getTupleBuffer(String id) |
Modifier and Type | Method and Description |
---|---|
void |
BufferManager.addTupleBuffer(TupleBuffer tb) |
void |
TupleBufferCache.distributeTupleBuffer(String uuid,
TupleBuffer tb) |
Modifier and Type | Method and Description |
---|---|
TupleBuffer |
BufferManagerImpl.createTupleBuffer(List elements,
String groupName,
BufferManager.TupleSourceType tupleSourceType) |
TupleBuffer |
BufferManagerImpl.getTupleBuffer(String id) |
Modifier and Type | Method and Description |
---|---|
void |
BufferManagerImpl.addTupleBuffer(TupleBuffer tb) |
void |
BufferManagerImpl.distributeTupleBuffer(String uuid,
TupleBuffer tb) |
Modifier and Type | Method and Description |
---|---|
TupleBuffer |
CachedResults.getResults() |
Modifier and Type | Method and Description |
---|---|
void |
CachedResults.setResults(TupleBuffer results,
ProcessorPlan plan) |
Constructor and Description |
---|
CopyOnReadTupleSource(TupleBuffer tb,
TupleSource ts) |
Modifier and Type | Method and Description |
---|---|
void |
NthValue.addInput(List<?> tuple,
CommandContext commandContext,
long startFrame,
long endFrame,
TupleBuffer frame) |
Modifier and Type | Method and Description |
---|---|
TupleBuffer |
BatchCollector.collectTuples() |
TupleBuffer |
BatchCollector.collectTuples(boolean singleBatch) |
TupleBuffer |
BatchIterator.getBuffer() |
TupleBuffer |
QueryProcessor.getBuffer(int maxRows) |
TupleBuffer |
ProcessorPlan.getBuffer(int maxRows)
return the final tuple buffer or null if not available
|
TupleBuffer |
BatchCollector.BatchProducer.getBuffer(int maxRows)
return the final tuple buffer or null if not available
|
TupleBuffer |
BatchCollector.getTupleBuffer() |
Modifier and Type | Method and Description |
---|---|
void |
BatchIterator.setBuffer(TupleBuffer buffer,
boolean saveOnMark) |
Modifier and Type | Method and Description |
---|---|
TupleBuffer |
RelationalNode.getBuffer(int maxRows)
return the final tuple buffer or null if not available
|
TupleBuffer |
RelationalPlan.getBuffer(int maxRows) |
protected TupleBuffer |
RelationalNode.getBufferDirect(int maxRows)
For subclasses to override if they wish to return a buffer rather than batches.
|
TupleBuffer |
ProjectNode.getBufferDirect(int maxRows) |
TupleBuffer |
LimitNode.getBufferDirect(int maxRows) |
TupleBuffer |
SortNode.getBufferDirect(int maxRows) |
TupleBuffer |
DependentValueSource.getTupleBuffer() |
TupleBuffer |
SortUtility.sort() |
TupleBuffer |
SortUtility.sort(int rowLimit) |
Modifier and Type | Method and Description |
---|---|
List<TupleBuffer> |
SortUtility.onePassSort(boolean lowLatency) |
Modifier and Type | Method and Description |
---|---|
void |
SortUtility.setWorkingBuffer(TupleBuffer workingBuffer) |
Constructor and Description |
---|
DependentValueSource(TupleBuffer tb) |
DependentValueSource(TupleBuffer tb,
List<? extends Expression> schema) |
Modifier and Type | Method and Description |
---|---|
TupleBuffer |
WithQueryCommand.getTupleBuffer() |
Modifier and Type | Method and Description |
---|---|
void |
WithQueryCommand.setTupleBuffer(TupleBuffer tupleBuffer) |
Copyright © 2020. All rights reserved.