ivory.cascade.retrieval

Class CascadeThreadedQueryRunner

java.lang.Object

ivory.cascade.retrieval.CascadeThreadedQueryRunner

All Implemented Interfaces:

CascadeQueryRunner, QueryRunner

public class CascadeThreadedQueryRunner
extends Object
implements CascadeQueryRunner

Author:

Lidan Wang

Constructor Summary

Constructors

Constructor and Description
CascadeThreadedQueryRunner(MRFBuilder builder, MRFExpander expander, int numThreads, int numHits, Map<Integer,Float[][]> savedResults, int K)

Method Summary

Methods

Modifier and Type	Method and Description
void	clearResults() Clears all stored results.
float[]	getCascadeCostAllQueries_lastStage()
float[]	getCascadeCostAllQueries()
Map<String,Accumulator[]>	getResults() Returns results of all queries executed.
Accumulator[]	getResults(String qid) Fetches the results of a query.
Accumulator[]	runQuery(String[] query) Runs a query synchronously, waiting until completion.
void	runQuery(String qid, String[] query) Runs a query asynchronously.

Methods inherited from class java.lang.Object

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

Constructor Detail

CascadeThreadedQueryRunner

public CascadeThreadedQueryRunner(MRFBuilder builder,
                          MRFExpander expander,
                          int numThreads,
                          int numHits,
                          Map<Integer,Float[][]> savedResults,
                          int K)

Method Detail

clearResults

public void clearResults()

Clears all stored results.

Specified by:

clearResults in interface CascadeQueryRunner

Specified by:

clearResults in interface QueryRunner

getCascadeCostAllQueries_lastStage

public float[] getCascadeCostAllQueries_lastStage()

Specified by:

getCascadeCostAllQueries_lastStage in interface CascadeQueryRunner

getCascadeCostAllQueries

public float[] getCascadeCostAllQueries()

Specified by:

getCascadeCostAllQueries in interface CascadeQueryRunner

getResults

public Map<String,Accumulator[]> getResults()

Returns results of all queries executed.

Specified by:

getResults in interface CascadeQueryRunner

Specified by:

getResults in interface QueryRunner

getResults

public Accumulator[] getResults(String qid)

Fetches the results of a query. If necessary, waits until completion of the query.

Specified by:

getResults in interface CascadeQueryRunner

Specified by:

getResults in interface QueryRunner

Parameters:

qid - query id

runQuery

public Accumulator[] runQuery(String[] query)

Runs a query synchronously, waiting until completion.

Specified by:

runQuery in interface CascadeQueryRunner

Specified by:

runQuery in interface QueryRunner

runQuery

public void runQuery(String qid,
            String[] query)

Runs a query asynchronously. Results can be fetched using getResults(java.lang.String).

Specified by:

runQuery in interface CascadeQueryRunner

Specified by:

runQuery in interface QueryRunner