Package com.stardog.stark.query.io

Class AsyncSelectQueryResult

java.lang.Object

com.google.common.collect.UnmodifiableIterator<BindingSet>

com.google.common.collect.AbstractIterator<BindingSet>

com.complexible.common.base.CloseableIterator.AbstractCloseableIterator<BindingSet>

com.stardog.stark.query.io.AsyncSelectQueryResult

All Implemented Interfaces:

CloseableIterator<BindingSet>, QueryResult<BindingSet>, SelectQueryResult, AutoCloseable, Iterator<BindingSet>

public class AsyncSelectQueryResult
extends CloseableIterator.AbstractCloseableIterator<BindingSet>
implements SelectQueryResult

A SelectQueryResult which asynchronously parses the result set from an input stream.

Since:

7.4.6

Author:

Pavel Klinov

Nested Class Summary

Nested classes/interfaces inherited from interface com.complexible.common.base.CloseableIterator

CloseableIterator.AbstractCloseableIterator<T>, CloseableIterator.DelegatingCloseableIterator<T>, CloseableIterator.EmptyCloseableIterator<T>

Constructor Summary

Constructors

Constructor	Description
AsyncSelectQueryResult(InputStream input, QueryResultParser<SelectQueryResultHandler> parser, ExecutorService execService, int batchSize, CancelCheck cancelCheck, Consumer<Boolean> onClose, Function<Exception,RuntimeException> onError)

Method Summary

Modifier and Type	Method	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

Methods inherited from class com.google.common.collect.AbstractIterator

endOfData, hasNext, next, peek

Methods inherited from class com.google.common.collect.UnmodifiableIterator

remove

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Methods inherited from interface com.stardog.stark.query.QueryResult

hasNext, metadata, next, stream

Constructor Details

AsyncSelectQueryResult

public AsyncSelectQueryResult(InputStream input,
 QueryResultParser<SelectQueryResultHandler> parser,
 ExecutorService execService,
 int batchSize,
 CancelCheck cancelCheck,
 Consumer<Boolean> onClose,
 Function<Exception,RuntimeException> onError)

Method Details

close

public void close()

Description copied from interface: QueryResult

Close the query results and return any resources in use back to the system. This *must* be called on all result sets to avoid resource leaks.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface CloseableIterator<BindingSet>

Specified by:

close in interface QueryResult<BindingSet>

computeNext

protected BindingSet computeNext()

Specified by:

computeNext in class com.google.common.collect.AbstractIterator<BindingSet>

variables

@Nonnull
public List<String> variables()

Description copied from interface: SelectQueryResult

Return the list of projected variables from the query

Specified by:

variables in interface SelectQueryResult

Returns:

the projection