Modifier and Type | Field and Description |
---|---|
static BlockedException |
BlockedException.BLOCKED_ON_MEMORY_EXCEPTION |
static BlockedException |
BlockedException.INSTANCE |
Modifier and Type | Method and Description |
---|---|
static BlockedException |
BlockedException.block(Object... msg) |
static BlockedException |
BlockedException.blockWithTrace(Object... msg) |
Modifier and Type | Method and Description |
---|---|
protected abstract List<?> |
AbstractTupleSource.finalRow() |
protected List<?> |
AbstractTupleSource.getCurrentTuple() |
int |
BufferManager.reserveBuffersBlocking(int count,
long[] attempts,
boolean force) |
Modifier and Type | Method and Description |
---|---|
int |
BufferManagerImpl.reserveBuffersBlocking(int count,
long[] val,
boolean force) |
Modifier and Type | Method and Description |
---|---|
void |
ConnectorWork.execute() |
AtomicResultsMessage |
ConnectorWork.more() |
Modifier and Type | Method and Description |
---|---|
Object |
DataTierManagerImpl.lookupCodeValue(CommandContext context,
String codeTableName,
String returnElementName,
String keyElementName,
Object keyValue) |
protected void |
RequestWorkItem.processMore() |
Modifier and Type | Method and Description |
---|---|
static boolean |
Evaluator.evaluate(Criteria criteria) |
boolean |
Evaluator.evaluate(Criteria criteria,
List<?> tuple) |
static Object |
Evaluator.evaluate(Expression expression) |
Object |
Evaluator.evaluate(Expression expression,
List<?> tuple) |
void |
Evaluator.evaluateParameters(List<DerivedColumn> cols,
List<?> tuple,
Map<String,Object> parameters)
Evaluate the parameters and return the context item if it exists
|
protected ValueIterator |
Evaluator.evaluateSubquery(SubqueryContainer<?> container,
List<?> tuple) |
Boolean |
Evaluator.evaluateTVL(Criteria criteria,
List<?> tuple) |
protected Object |
Evaluator.internalEvaluate(Expression expression,
List<?> tuple) |
static JsonType |
Evaluator.jsonArray(CommandContext context,
Function f,
Object[] vals,
JSONFunctionMethods.JSONBuilder builder,
Evaluator eval,
List<?> tuple) |
Modifier and Type | Method and Description |
---|---|
Object |
FunctionDescriptor.invokeFunction(Object[] values,
CommandContext context,
Object functionTarget)
Invoke the function described in the function descriptor, using the
values provided.
|
static JsonType |
JSONFunctionMethods.jsonArray(CommandContext context,
Object... vals) |
Modifier and Type | Method and Description |
---|---|
TupleBatch |
SourceTriggerActionPlanner.CompositeProcessorPlan.nextBatch() |
Modifier and Type | Method and Description |
---|---|
static void |
RowBasedSecurityHelper.checkConstraints(Command atomicCommand,
Evaluator eval) |
Modifier and Type | Class and Description |
---|---|
static class |
QueryProcessor.ExpiredTimeSliceException |
Modifier and Type | Method and Description |
---|---|
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
|
protected List<?> |
BatchIterator.getCurrentTuple() |
Object |
ProcessorDataManager.lookupCodeValue(CommandContext context,
String codeTableName,
String returnElementName,
String keyElementName,
Object keyValue)
Lookup a value from a cached code table.
|
TupleBatch |
DdlPlan.nextBatch() |
TupleBatch |
QueryProcessor.nextBatch() |
abstract TupleBatch |
ProcessorPlan.nextBatch()
Get a batch of results or possibly an Exception.
|
TupleBatch |
BatchedUpdatePlan.nextBatch() |
TupleBatch |
BatchCollector.BatchProducer.nextBatch()
Get a batch of results or possibly an Exception.
|
protected List<?> |
BatchCollector.BatchProducerTupleSource.updateTuple(List<?> tuple) |
Modifier and Type | Method and Description |
---|---|
Object |
ProcedurePlan.lookupCodeValue(CommandContext context,
String codeTableName,
String returnElementName,
String keyElementName,
Object keyValue) |
TupleBatch |
ForEachRowPlan.nextBatch() |
TupleBatch |
ProcedurePlan.nextBatch() |
TupleBatch |
ProcedurePlan.nextBatchDirect() |
void |
AssignmentInstruction.process(ProcedurePlan procEnv)
Updates the current variable context with a value for the Variable
defined using a DeclareInstruction, the variable value is obtained by either processing
a expression or a command(stored as a processplan).
|
void |
BlockInstruction.process(ProcedurePlan procEnv) |
void |
IfInstruction.process(ProcedurePlan procEnv)
This instruction will evaluate it's criteria, if it evaluates
to true, it will push the corresponding sub Program on to the top of the
program stack, and break from the loop.
|
void |
ExecDynamicSqlInstruction.process(ProcedurePlan procEnv)
Processing this instruction executes the ProcessorPlan for the command on
the CommandStatement of the update procedure language.
|
void |
CreateCursorResultSetInstruction.process(ProcedurePlan procEnv) |
Modifier and Type | Method and Description |
---|---|
protected ValueIterator |
SubqueryAwareEvaluator.evaluateSubquery(SubqueryContainer<?> container,
List<?> tuple) |
TupleBuffer |
RelationalPlan.getBuffer(int maxRows) |
TupleBuffer |
RelationalNode.getBuffer(int maxRows)
return the final tuple buffer or null if not available
|
TupleBuffer |
SortNode.getBufferDirect(int maxRows) |
TupleBuffer |
LimitNode.getBufferDirect(int maxRows) |
TupleBuffer |
ProjectNode.getBufferDirect(int maxRows) |
protected TupleBuffer |
RelationalNode.getBufferDirect(int maxRows)
For subclasses to override if they wish to return a buffer rather than batches.
|
TupleBatch |
RelationalPlan.nextBatch() |
TupleBatch |
RelationalNode.nextBatch()
Wrapper for nextBatchDirect that does performance timing - callers
should always call this rather than nextBatchDirect().
|
TupleBatch |
AccessNode.nextBatchDirect() |
TupleBatch |
GroupingNode.nextBatchDirect() |
TupleBatch |
DupRemoveNode.nextBatchDirect() |
TupleBatch |
PlanExecutionNode.nextBatchDirect() |
TupleBatch |
UnionAllNode.nextBatchDirect() |
TupleBatch |
SortNode.nextBatchDirect() |
protected TupleBatch |
TextTableNode.nextBatchDirect() |
TupleBatch |
SelectNode.nextBatchDirect() |
protected TupleBatch |
ArrayTableNode.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
|
protected TupleBatch |
LimitNode.nextBatchDirect() |
protected TupleBatch |
WindowFunctionProjectNode.nextBatchDirect() |
protected TupleBatch |
ObjectTableNode.nextBatchDirect() |
protected TupleBatch |
XMLTableNode.nextBatchDirect() |
TupleBatch |
ProjectNode.nextBatchDirect() |
protected abstract TupleBatch |
RelationalNode.nextBatchDirect()
Template method for subclasses to implement.
|
TupleBatch |
BatchedUpdateNode.nextBatchDirect() |
TupleBatch |
UnionAllNode.nextBatchDirectInternal() |
protected TupleBatch |
JoinNode.nextBatchDirectInternal() |
protected boolean |
PlanExecutionNode.prepareNextCommand() |
protected boolean |
DependentProcedureExecutionNode.prepareNextCommand() |
protected boolean |
InsertPlanExecutionNode.prepareNextCommand() |
protected boolean |
DependentProcedureCriteriaProcessor.prepareNextCommand(VariableContext context) |
protected void |
SubqueryAwareRelationalNode.setReferenceValues(TableFunctionReference ref) |
Modifier and Type | Method and Description |
---|---|
Object |
TempTableDataManager.lookupCodeValue(CommandContext context,
String codeTableName,
String returnElementName,
String keyElementName,
Object keyValue) |
Modifier and Type | Method and Description |
---|---|
static Object |
XQueryEvaluator.evaluateXMLQuery(List<?> tuple,
XMLQuery xmlQuery,
boolean exists,
Map<String,Object> parameters,
CommandContext context) |
Copyright © 2019. All rights reserved.