info.aduna.infosource.query
Class StreamingQueryEvaluator

java.lang.Object
  info.aduna.infosource.query.StreamingQueryEvaluator

public class StreamingQueryEvaluator
extends Object

StreamingQueryEvaluator evaluates a query on the Repositories contained in an InfoSourceManager and passes the results back to a specified ResultListener.

A StreamingQueryEvaluator merges the results in the simplest way possible. Therefore, the results are not exactly the same as what would be returned by a distributed Sail. For example, a SELECT query using the DISTINCT keyword may still return duplicates, when two or more InfoSources return the same results.

Currently, a StreamingQueryEvaluator can only be used once, it cannot be reused later on to re-evaluate the query.

Constructor Summary

StreamingQueryEvaluator(Query query, org.openrdf.repository.manager.LocalRepositoryManager repositoryManager, Executor localExecutor, Executor remoteExecutor, ResultListener listener)

Method Summary

Query	getQuery()
boolean	isActive()
void	start() Starts the StreamingQueryEvaluator.

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamingQueryEvaluator

public StreamingQueryEvaluator(Query query,
                               org.openrdf.repository.manager.LocalRepositoryManager repositoryManager,
                               Executor localExecutor,
                               Executor remoteExecutor,
                               ResultListener listener)

Method Detail

getQuery

public Query getQuery()

start

public void start()

Starts the StreamingQueryEvaluator. All results are passed to the ResultListener specified in the constructor. Currently, a StreamingQueryEvaluator can only be used once, results are undefined when this method is invoked twice.

isActive

public boolean isActive()