|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.amentra.metamatrix.solr.SyncQueryExecution
public class SyncQueryExecution
Supports read-only, synchronious queries that are translated to Solr searches and executed.
Constructor Summary | |
---|---|
SyncQueryExecution(com.metamatrix.data.metadata.runtime.RuntimeMetadata md,
org.apache.solr.client.solrj.impl.CommonsHttpSolrServer server,
com.metamatrix.data.api.ConnectorLogger logger,
boolean useLowerCase)
|
Method Summary | |
---|---|
void |
cancel()
Does nothing, since we call the query synchronously. |
void |
close()
Does nothing, since there is no matching close() method for the QueryResponse. |
void |
execute(com.metamatrix.data.language.IQuery query,
int maxBatchSize)
Uses a visitor to process the IQuery and extract the parameters for a SolrQuery search, and then executes the search, retrieving a list of Documents that match the criteria. |
com.metamatrix.data.api.Batch |
nextBatch()
Pull the field values from the list of documents until a batch is fulfilled or the end of the document list is reached. |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public SyncQueryExecution(com.metamatrix.data.metadata.runtime.RuntimeMetadata md, org.apache.solr.client.solrj.impl.CommonsHttpSolrServer server, com.metamatrix.data.api.ConnectorLogger logger, boolean useLowerCase)
Method Detail |
---|
public void execute(com.metamatrix.data.language.IQuery query, int maxBatchSize) throws com.metamatrix.data.exception.ConnectorException
execute
in interface com.metamatrix.data.api.SynchQueryExecution
com.metamatrix.data.exception.ConnectorException
SynchQueryExecution.execute(com.metamatrix.data.language.IQuery, int)
public com.metamatrix.data.api.Batch nextBatch() throws com.metamatrix.data.exception.ConnectorException
nextBatch
in interface com.metamatrix.data.api.BatchedExecution
com.metamatrix.data.exception.ConnectorException
BatchedExecution.nextBatch()
public void cancel() throws com.metamatrix.data.exception.ConnectorException
cancel
in interface com.metamatrix.data.api.Execution
com.metamatrix.data.exception.ConnectorException
Execution.cancel()
public void close() throws com.metamatrix.data.exception.ConnectorException
close
in interface com.metamatrix.data.api.Execution
com.metamatrix.data.exception.ConnectorException
Execution.close()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |