|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of BlockedException in com.metamatrix.common.buffer |
---|
Subclasses of BlockedException in com.metamatrix.common.buffer | |
---|---|
class |
BlockedOnMemoryException
This exception is thrown by the plan if it receives a MemoryNotAvailableException while attempting to pin a batch in the BufferManager. |
Fields in com.metamatrix.common.buffer declared as BlockedException | |
---|---|
static BlockedException |
BlockedException.INSTANCE
|
Uses of BlockedException in com.metamatrix.query.eval |
---|
Methods in com.metamatrix.query.eval that throw BlockedException | |
---|---|
java.lang.Boolean |
Evaluator.evaluate(AbstractSetCriteria criteria,
java.util.List tuple)
|
java.lang.Boolean |
Evaluator.evaluate(CompareCriteria criteria,
java.util.List tuple)
|
java.lang.Boolean |
Evaluator.evaluate(CompoundCriteria criteria,
java.util.List tuple)
|
static boolean |
Evaluator.evaluate(Criteria criteria)
|
boolean |
Evaluator.evaluate(Criteria criteria,
java.util.List tuple)
|
boolean |
Evaluator.evaluate(ExistsCriteria criteria,
java.util.List tuple)
|
static java.lang.Object |
Evaluator.evaluate(Expression expression)
|
java.lang.Object |
Evaluator.evaluate(Expression expression,
java.util.List tuple)
|
boolean |
Evaluator.evaluate(IsNullCriteria criteria,
java.util.List tuple)
|
java.lang.Boolean |
Evaluator.evaluate(MatchCriteria criteria,
java.util.List tuple)
|
java.lang.Boolean |
Evaluator.evaluate(NotCriteria criteria,
java.util.List tuple)
|
java.lang.Boolean |
Evaluator.evaluate(SubqueryCompareCriteria criteria,
java.util.List tuple)
|
java.lang.Boolean |
Evaluator.evaluateTVL(Criteria criteria,
java.util.List tuple)
|
java.lang.Object |
LookupEvaluator.lookupCodeValue(CommandContext context,
java.lang.String codeTableName,
java.lang.String returnElementName,
java.lang.String keyElementName,
java.lang.Object keyValue)
Lookup a value from a cached code table. |
Uses of BlockedException in com.metamatrix.query.processor |
---|
Methods in com.metamatrix.query.processor that throw BlockedException | |
---|---|
java.lang.Object |
TempTableDataManager.lookupCodeValue(CommandContext context,
java.lang.String codeTableName,
java.lang.String returnElementName,
java.lang.String keyElementName,
java.lang.Object keyValue)
|
TupleBatch |
ProcessorPlan.nextBatch()
Get a batch of results or possibly an Exception. |
void |
QueryProcessor.process()
Process fully blocking |
boolean |
QueryProcessor.process(long time)
Process until time expires or a BlockedException occurs |
Uses of BlockedException in com.metamatrix.query.processor.batch |
---|
Methods in com.metamatrix.query.processor.batch that throw BlockedException | |
---|---|
TupleBatch |
PreparedBatchUpdatePlan.nextBatch()
|
TupleBatch |
BatchedUpdatePlan.nextBatch()
|
Uses of BlockedException in com.metamatrix.query.processor.proc |
---|
Methods in com.metamatrix.query.processor.proc that throw BlockedException | |
---|---|
void |
ProcedurePlan.evaluateParams()
|
TupleSource |
ProcedurePlan.getResults(TupleSourceID tupleID)
|
TupleBatch |
ProcedurePlan.nextBatch()
|
void |
IfInstruction.process(ProgramEnvironment env)
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 |
ExecSqlInstruction.process(ProgramEnvironment env)
Processing this instruction executes the ProcessorPlan for the command on the CommandStatement of the update procedure language. |
void |
ExecDynamicSqlInstruction.process(ProgramEnvironment env)
Processing this instruction executes the ProcessorPlan for the command on the CommandStatement of the update procedure language. |
void |
CreateCursorResultSetInstruction.process(ProgramEnvironment env)
If the result set named rsName does not exist yet in the ProcessorEnvironment , then
this instruction will define that result set. |
void |
AbstractAssignmentInstruction.process(ProgramEnvironment env)
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). |
Uses of BlockedException in com.metamatrix.query.processor.relational |
---|
Methods in com.metamatrix.query.processor.relational that throw BlockedException | |
---|---|
protected void |
SortNode.collectionPhase(TupleBatch batch)
|
protected void |
SortUtility.mergePhase()
|
TupleBatch |
RelationalPlan.nextBatch()
|
TupleBatch |
RelationalNode.nextBatch()
Wrapper for nextBatchDirect that does performance timing - callers should always call this rather than nextBatchDirect(). |
TupleBatch |
UnionAllNode.nextBatchDirect()
|
TupleBatch |
SortNode.nextBatchDirect()
1ST PHASE - COLLECTION Collect all batches from child node, save in collected tuple source 2ND PHASE - SORT INITIAL SUBLISTS Repeat until all batches from collection TS have been read Get and pin batches from collection TS until MemoryNotAvailableException Sort batches Write batches into new sorted TS Unpin all batches Remove collection TS 3RD PHASE - MERGE SORTED SUBLISTS Repeat until there is one sublist Repeat until all sorted sublists have been merged For each sorted sublist S Load and pin a batch until memory not available Merge from pinned batches As batch is done, unpin and load next Output merge into new sublist T Remove merged sublists Let sublists = set of T's 4TH PHASE - OUTPUT Return batches from single sublist from T |
TupleBatch |
SelectNode.nextBatchDirect()
|
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 |
LimitNode.nextBatchDirect()
|
protected TupleBatch |
JoinNode.nextBatchDirect()
|
TupleBatch |
GroupingNode.nextBatchDirect()
|
TupleBatch |
BatchedUpdateNode.nextBatchDirect()
|
TupleBatch |
AccessNode.nextBatchDirect()
|
protected boolean |
PlanExecutionNode.prepareNextCommand()
|
protected boolean |
DependentProcedureExecutionNode.prepareNextCommand()
|
protected boolean |
DependentProcedureCriteriaProcessor.prepareNextCommand()
|
protected void |
SelectNode.prepareToProcessTuple(java.util.Map elementMap,
java.util.List currentTuple)
This method is called by RelationalNode.nextBatch() just after the current
tuple is pulled from the child processor node and just before any
processing is done (in this case, before the criteria is evaluated). |
protected void |
ProjectNode.prepareToProcessTuple(java.util.Map elementMap,
java.util.List currentTuple)
This method is called by RelationalNode.nextBatch() just after the current
tuple is pulled from the child processor node and just before any
processing is done (in this case, before the tuple is projected). |
protected void |
DependentSelectNode.prepareToProcessTuple(java.util.Map elementMap,
java.util.List currentTuple)
This subclass will execute any subqueries which the criteria is dependent on; if any subqueries are correlated, this class will use the current tuple to execute correlated subqueries |
protected void |
DependentProjectNode.prepareToProcessTuple(java.util.Map elementMap,
java.util.List currentTuple)
This subclass will execute any subqueries which the projection is dependent on; if any subqueries are correlated, this class will use the current tuple to execute correlated subqueries |
TupleSourceID |
SortUtility.sort()
|
protected void |
SortUtility.sortPhase()
|
Uses of BlockedException in com.metamatrix.query.processor.xml |
---|
Methods in com.metamatrix.query.processor.xml that throw BlockedException | |
---|---|
void |
PlanExecutor.execute(java.util.Map referenceValues)
Execute the plan |
TupleBatch |
XMLPlan.nextBatch()
|
com.metamatrix.query.processor.xml.XMLContext |
WhileInstruction.process(XMLProcessorEnvironment env,
com.metamatrix.query.processor.xml.XMLContext context)
|
abstract com.metamatrix.query.processor.xml.XMLContext |
ProcessorInstruction.process(XMLProcessorEnvironment env,
com.metamatrix.query.processor.xml.XMLContext context)
Allow this ProcessorInstruction to do whatever processing it needs, and to in turn manipulate the running program, (via the ProcessorEnvironment getProgramStack method.)
A typical instruction should simply increment
the program counter of the current program, but specialized instructions may add
sub programs to the stack or not increment the counter (so that they are
executed again.) |
com.metamatrix.query.processor.xml.XMLContext |
MoveDocInstruction.process(XMLProcessorEnvironment env,
com.metamatrix.query.processor.xml.XMLContext context)
|
com.metamatrix.query.processor.xml.XMLContext |
MoveCursorInstruction.process(XMLProcessorEnvironment env,
com.metamatrix.query.processor.xml.XMLContext context)
|
com.metamatrix.query.processor.xml.XMLContext |
JoinedWhileInstruction.process(XMLProcessorEnvironment env,
com.metamatrix.query.processor.xml.XMLContext context)
|
com.metamatrix.query.processor.xml.XMLContext |
InitializeDocumentInstruction.process(XMLProcessorEnvironment env,
com.metamatrix.query.processor.xml.XMLContext context)
|
com.metamatrix.query.processor.xml.XMLContext |
IfInstruction.process(XMLProcessorEnvironment env,
com.metamatrix.query.processor.xml.XMLContext context)
This instruction will evaluate it's criteria, one by one. |
com.metamatrix.query.processor.xml.XMLContext |
ExecStagingTableInstruction.process(XMLProcessorEnvironment env,
com.metamatrix.query.processor.xml.XMLContext context)
|
com.metamatrix.query.processor.xml.XMLContext |
ExecSqlInstruction.process(XMLProcessorEnvironment env,
com.metamatrix.query.processor.xml.XMLContext context)
|
com.metamatrix.query.processor.xml.XMLContext |
EndDocumentInstruction.process(XMLProcessorEnvironment env,
com.metamatrix.query.processor.xml.XMLContext context)
|
com.metamatrix.query.processor.xml.XMLContext |
EndBlockInstruction.process(XMLProcessorEnvironment env,
com.metamatrix.query.processor.xml.XMLContext context)
|
com.metamatrix.query.processor.xml.XMLContext |
BlockInstruction.process(XMLProcessorEnvironment env,
com.metamatrix.query.processor.xml.XMLContext context)
|
com.metamatrix.query.processor.xml.XMLContext |
AddNodeInstruction.process(XMLProcessorEnvironment env,
com.metamatrix.query.processor.xml.XMLContext context)
Outputs an element or an attribute, or nothing, based on the state of the instruction. |
com.metamatrix.query.processor.xml.XMLContext |
AddCommentInstruction.process(XMLProcessorEnvironment env,
com.metamatrix.query.processor.xml.XMLContext context)
outputs comment for an XML element (comment node is actually child of XML element node) |
com.metamatrix.query.processor.xml.XMLContext |
AbortProcessingInstruction.process(XMLProcessorEnvironment env,
com.metamatrix.query.processor.xml.XMLContext context)
|
Uses of BlockedException in com.metamatrix.query.processor.xquery |
---|
Methods in com.metamatrix.query.processor.xquery that throw BlockedException | |
---|---|
TupleBatch |
XQueryPlan.nextBatch()
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |