|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object com.metamatrix.query.processor.QueryProcessor
public class QueryProcessor
TODO: combine overlapping responsibilities with RequestWorkItem
Nested Class Summary | |
---|---|
static interface |
QueryProcessor.BatchHandler
|
static interface |
QueryProcessor.ProcessorFactory
|
Constructor Summary | |
---|---|
QueryProcessor(ProcessorPlan plan,
CommandContext context,
BufferManager bufferMgr,
ProcessorDataManager dataMgr)
Construct a processor with all necessary information to process. |
Method Summary | |
---|---|
void |
closeProcessing()
Close processing and clean everything up. |
java.util.List<java.lang.Exception> |
getAndClearWarnings()
|
CommandContext |
getContext()
|
int |
getHighestRow()
|
java.lang.Object |
getProcessID()
|
ProcessorPlan |
getProcessorPlan()
|
TupleSourceID |
getResultsID()
|
void |
process()
Process fully blocking |
boolean |
process(long time)
Process until time expires or a BlockedException occurs |
void |
requestCanceled()
Asynch shutdown of the QueryProcessor, which may trigger exceptions in the processing thread |
void |
requestClosed()
Asynch graceful shutdown of the QueryProcessor |
void |
setBatchHandler(QueryProcessor.BatchHandler batchHandler)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public QueryProcessor(ProcessorPlan plan, CommandContext context, BufferManager bufferMgr, ProcessorDataManager dataMgr) throws MetaMatrixComponentException
plan
- The plan to processcontext
- The context that this plan is being processed inbufferMgr
- The buffer manager that provides access to tuple sourcesdataMgr
- The data manager that provides access to get data
MetaMatrixComponentException
Method Detail |
---|
public CommandContext getContext()
public java.lang.Object getProcessID()
public TupleSourceID getResultsID()
public ProcessorPlan getProcessorPlan()
public void process() throws BlockedException, MetaMatrixCoreException
MetaMatrixCoreException
BlockedException
public boolean process(long time) throws BlockedException, MetaMatrixCoreException
BlockedException
occurs
time
-
BlockedException
MetaMatrixCoreException
public void closeProcessing() throws TupleSourceNotFoundException, MetaMatrixComponentException
MetaMatrixComponentException
TupleSourceNotFoundException
public java.util.List<java.lang.Exception> getAndClearWarnings()
public void requestCanceled()
public void requestClosed()
public void setBatchHandler(QueryProcessor.BatchHandler batchHandler)
public int getHighestRow()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |