public class AGStreamTupleQuery extends AGTupleQuery implements TupleQuery
AGTupleQuery.evaluate() does not return until the
entire stream is parsed.
AGStreamTupleQuery uses XMLStreamReader, so the result is
pulled from the http response stream as methods such as
TupleQueryResult.hasNext()
are called.
Usage:
AGTupleQuery query = conn.prepareTupleQuery(QueryLanguage.SPARQL, "SELECT ...");
query = new AGStreamTupleQuery(query);
TupleQueryResult results = query.evaluate();
...
AGRepositoryConnection.prepareTupleQuery(org.eclipse.rdf4j.query.QueryLanguage, String)RDFS_PLUS_PLUS, RESTRICTION, SPARQL_COVERAGE_PLANNER, SPARQL_IDENTITY_PLANNER| Constructor and Description |
|---|
AGStreamTupleQuery(AGTupleQuery query)
Wraps a query with this object that will stream the response.
|
| Modifier and Type | Method and Description |
|---|---|
TupleQueryResult |
evaluate()
Returns a result object that will read from the http response as
results are requested, by
TupleQueryResult.hasNext(). |
void |
evaluate(TupleQueryResultHandler handler) |
count, download, download, streamanalyze, download, download, download, download, getBaseURI, getBindingsArray, getEngine, getEntailmentRegime, getFranzOptionPrefixString, getLanguage, getLimit, getName, getOffset, getPlanner, getQueryString, isCheckVariables, isLoggingEnabled, isPrepared, setCheckVariables, setEngine, setEntailmentRegime, setIncludeInferred, setLimit, setLoggingEnabled, setOffset, setPlanner, setPrepared, setSaveName, stream, stream, toStringgetMaxQueryTime, setMaxQueryTimeclearBindings, getBindings, getDataset, getIncludeInferred, getMaxExecutionTime, removeBinding, setBinding, setDataset, setMaxExecutionTimeequals, getClass, hashCode, notify, notifyAll, wait, wait, waitgetMaxQueryTime, setMaxQueryTimeclearBindings, getBindings, getDataset, getIncludeInferred, getMaxExecutionTime, removeBinding, setBinding, setDataset, setIncludeInferred, setMaxExecutionTimepublic AGStreamTupleQuery(AGTupleQuery query)
query - to wrappublic TupleQueryResult evaluate() throws QueryEvaluationException
TupleQueryResult.hasNext().
(Note that TupleQueryResult.next()
does not actually do the work if hasNext() is called first.)evaluate in interface TupleQueryevaluate in class AGTupleQueryQueryEvaluationExceptionpublic void evaluate(TupleQueryResultHandler handler) throws QueryEvaluationException, TupleQueryResultHandlerException
evaluate in interface TupleQueryevaluate in class AGTupleQueryQueryEvaluationExceptionTupleQueryResultHandlerExceptionCopyright © 2021 Franz Inc.. All rights reserved.