Class AsyncSelectQueryResult

    • Constructor Detail

      • AsyncSelectQueryResult

        public AsyncSelectQueryResult​(java.io.InputStream input,
                                      QueryResultParser<SelectQueryResultHandler> parser,
                                      java.util.concurrent.ExecutorService execService,
                                      int batchSize,
                                      CancelCheck cancelCheck,
                                      java.lang.Runnable onClose,
                                      java.util.function.Function<java.lang.Exception,​java.lang.RuntimeException> onError)
    • Method Detail

      • 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 java.lang.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 java.util.List<java.lang.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