Class QueryProcessorImpl

java.lang.Object

se.liu.ida.hefquin.engine.queryproc.impl.QueryProcessorImpl

All Implemented Interfaces:

QueryProcessor

public class QueryProcessorImpl
extends Object
implements QueryProcessor

Simple implementation of QueryProcessor.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	QueryProcessorImpl.MyQueryProcContextExt

Field Summary

Fields

Modifier and Type	Field	Description
protected final ExecutionEngine	execEngine
protected final QueryPlanCompiler	planCompiler
protected final QueryPlanner	planner

Constructor Summary

Constructors

Constructor	Description
QueryProcessorImpl(QueryPlanner planner, QueryPlanCompiler planCompiler, ExecutionEngine execEngine)

Method Summary

Modifier and Type	Method	Description
ExecutionEngine	getExecutionEngine()
QueryPlanCompiler	getPlanCompiler()
QueryPlanner	getPlanner()
QueryProcessingStatsAndExceptions	processQuery(Query query, QueryResultSink resultSink, QueryProcContext ctx)
protected QueryProcessingStatsAndExceptions	processQuery(Query query, QueryResultSink resultSink, QueryProcContextExt ctx)
void	shutdown()	Shuts down all thread pools associated with this query processor.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

planner

protected final QueryPlanner planner

planCompiler

protected final QueryPlanCompiler planCompiler

execEngine

protected final ExecutionEngine execEngine

Constructor Details

QueryProcessorImpl

public QueryProcessorImpl(QueryPlanner planner,
 QueryPlanCompiler planCompiler,
 ExecutionEngine execEngine)

Method Details

getPlanner

public QueryPlanner getPlanner()

Specified by:

getPlanner in interface QueryProcessor

getPlanCompiler

public QueryPlanCompiler getPlanCompiler()

Specified by:

getPlanCompiler in interface QueryProcessor

getExecutionEngine

public ExecutionEngine getExecutionEngine()

Specified by:

getExecutionEngine in interface QueryProcessor

processQuery

public QueryProcessingStatsAndExceptions processQuery(Query query,
 QueryResultSink resultSink,
 QueryProcContext ctx)
                                               throws QueryProcException

Specified by:

processQuery in interface QueryProcessor

Throws:

QueryProcException

processQuery

protected QueryProcessingStatsAndExceptions processQuery(Query query,
 QueryResultSink resultSink,
 QueryProcContextExt ctx)
                                                  throws QueryProcException

Throws:

QueryProcException

shutdown

public void shutdown()

Description copied from interface: QueryProcessor

Shuts down all thread pools associated with this query processor.

Specified by:

shutdown in interface QueryProcessor