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.

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
ExecutionEngine	getExecutionEngine()
QueryPlanCompiler	getPlanCompiler()
QueryPlanner	getPlanner()
Pair<QueryProcStats,List<Exception>>	processQuery(Query query, QueryResultSink resultSink)
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

ctxt

protected final QueryProcContext ctxt

Constructor Details

QueryProcessorImpl

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

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 Pair<QueryProcStats,List<Exception>> processQuery(Query query,
 QueryResultSink resultSink)
                                                  throws QueryProcException

Specified by:

processQuery in interface QueryProcessor

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