public class AsyncSelectQueryResult extends CloseableIterator.AbstractCloseableIterator<BindingSet> implements SelectQueryResult
SelectQueryResult
which asynchronously parses the result set from an input stream.CloseableIterator.AbstractCloseableIterator<T>, CloseableIterator.DelegatingCloseableIterator<T>, CloseableIterator.EmptyCloseableIterator<T>
Constructor and Description |
---|
AsyncSelectQueryResult(InputStream input,
QueryResultParser<SelectQueryResultHandler> parser,
ExecutorService execService,
int batchSize,
CancelCheck cancelCheck,
Runnable onClose,
Function<Exception,RuntimeException> onError) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the query results and return any resources in use back to the system.
|
protected BindingSet |
computeNext() |
List<String> |
variables()
Return the list of projected variables from the query
|
endOfData, hasNext, next, peek
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
hasNext, metadata, next, stream
closeAfterLast, closeQuietly, collect, concat, concat, concat, empty, filter, first, isEmpty, limit, map, offset, onClose, singleton, size, toCloseable, toCloseable, toCloseable, toList, toSet, transform
forEachRemaining, remove
public AsyncSelectQueryResult(InputStream input, QueryResultParser<SelectQueryResultHandler> parser, ExecutorService execService, int batchSize, CancelCheck cancelCheck, Runnable onClose, Function<Exception,RuntimeException> onError)
public void close()
QueryResult
close
in interface CloseableIterator<BindingSet>
close
in interface QueryResult<BindingSet>
close
in interface AutoCloseable
protected BindingSet computeNext()
computeNext
in class com.google.common.collect.AbstractIterator<BindingSet>
@Nonnull public List<String> variables()
SelectQueryResult
variables
in interface SelectQueryResult
Copyright © 2010-2016 Stardog Union. All Rights Reserved.