Modifier and Type | Field and Description |
---|---|
protected TupleBatch |
AbstractTupleSource.batch |
Modifier and Type | Method and Description |
---|---|
TupleBatch |
TupleBuffer.getBatch(long row)
Get the batch containing the given row.
|
protected TupleBatch |
TupleBuffer.TupleBufferTupleSource.getBatch(long row) |
protected abstract TupleBatch |
AbstractTupleSource.getBatch(long row) |
Modifier and Type | Method and Description |
---|---|
void |
TupleBuffer.addTupleBatch(TupleBatch batch,
boolean save)
Adds the given batch preserving row offsets.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
RequestWorkItem.sendResultsIfNeeded(TupleBatch batch)
Send results if they have been requested.
|
Modifier and Type | Method and Description |
---|---|
TupleBatch |
SourceTriggerActionPlanner.CompositeProcessorPlan.nextBatch() |
Modifier and Type | Method and Description |
---|---|
protected TupleBatch |
BatchIterator.getBatch(long row) |
TupleBatch |
QueryProcessor.nextBatch() |
abstract TupleBatch |
ProcessorPlan.nextBatch()
Get a batch of results or possibly an Exception.
|
TupleBatch |
DdlPlan.nextBatch() |
TupleBatch |
BatchedUpdatePlan.nextBatch() |
TupleBatch |
BatchCollector.BatchProducer.nextBatch()
Get a batch of results or possibly an Exception.
|
Modifier and Type | Method and Description |
---|---|
protected void |
BatchCollector.flushBatchDirect(TupleBatch batch,
boolean add) |
Modifier and Type | Method and Description |
---|---|
TupleBatch |
ProcedurePlan.nextBatch() |
TupleBatch |
ForEachRowPlan.nextBatch() |
TupleBatch |
ProcedurePlan.nextBatchDirect() |
protected TupleBatch |
ProcedurePlan.pullBatch() |
Modifier and Type | Method and Description |
---|---|
TupleBatch |
RelationalNode.nextBatch()
Wrapper for nextBatchDirect that does performance timing - callers
should always call this rather than nextBatchDirect().
|
TupleBatch |
RelationalPlan.nextBatch() |
protected abstract TupleBatch |
RelationalNode.nextBatchDirect()
Template method for subclasses to implement.
|
TupleBatch |
ProjectNode.nextBatchDirect() |
TupleBatch |
ProjectIntoNode.nextBatchDirect()
Get batch from child node
Walk through each row of child batch
Bind values to insertCommand
Execute insertCommand
Update insertCount
When no more data is available, output batch with single row containing insertCount
|
TupleBatch |
PlanExecutionNode.nextBatchDirect() |
protected TupleBatch |
ObjectTableNode.nextBatchDirect() |
TupleBatch |
NullNode.nextBatchDirect() |
protected TupleBatch |
LimitNode.nextBatchDirect() |
TupleBatch |
JoinNode.nextBatchDirect() |
TupleBatch |
GroupingNode.nextBatchDirect() |
TupleBatch |
DupRemoveNode.nextBatchDirect() |
TupleBatch |
BatchedUpdateNode.nextBatchDirect() |
protected TupleBatch |
ArrayTableNode.nextBatchDirect() |
TupleBatch |
AccessNode.nextBatchDirect() |
protected TupleBatch |
WindowFunctionProjectNode.nextBatchDirect() |
TupleBatch |
UnionAllNode.nextBatchDirect() |
protected TupleBatch |
TextTableNode.nextBatchDirect() |
TupleBatch |
SortNode.nextBatchDirect() |
TupleBatch |
SelectNode.nextBatchDirect() |
protected TupleBatch |
JoinNode.nextBatchDirectInternal() |
TupleBatch |
UnionAllNode.nextBatchDirectInternal() |
protected TupleBatch |
RelationalNode.pullBatch() |
protected TupleBatch |
InsertPlanExecutionNode.pullBatch() |
Copyright © 2019. All rights reserved.