Class ResultSet

  • All Implemented Interfaces:
    Iterable<Result>

    public final class ResultSet
    extends Object
    implements Iterable<Result>
    A ResultSet is returned from the submission of a Gremlin script to the server and represents the results provided by the server. The results from the server are streamed into the ResultSet and therefore may not be available immediately. As such, ResultSet provides access to a a number of functions that help to work with the asynchronous nature of the data streaming back. Data from results is stored in an Result which can be used to retrieve the item once it is on the client side.

    Note that a ResultSet is a forward-only stream only so depending on how the methods are called and interacted with, it is possible to return partial bits of the total response (e.g. calling one() followed by all() will make it so that the List of results returned from all() have one Result missing from the total set as it was already retrieved by one().

    This class is not thread-safe.

    Author:
    Stephen Mallette (http://stephen.genoprime.com)
    • Constructor Detail

      • ResultSet

        public ResultSet​(org.apache.tinkerpop.gremlin.driver.ResultQueue resultQueue,
                         ExecutorService executor,
                         CompletableFuture<Void> readCompleted,
                         org.apache.tinkerpop.gremlin.util.message.RequestMessage originalRequestMessage,
                         Host host)
    • Method Detail

      • getOriginalRequestMessage

        public org.apache.tinkerpop.gremlin.util.message.RequestMessage getOriginalRequestMessage()
      • getHost

        public Host getHost()
      • allItemsAvailable

        public boolean allItemsAvailable()
        Determines if all items have been returned to the client.
      • allItemsAvailableAsync

        public CompletableFuture<Void> allItemsAvailableAsync()
        Returns a future that will complete when all items have been returned from the server.
      • getAvailableItemCount

        public int getAvailableItemCount()
        Gets the number of items available on the client.
      • one

        public Result one()
        Get the next Result from the stream, blocking until one is available.
      • some

        public CompletableFuture<List<Result>> some​(int items)
        The returned CompletableFuture completes when the number of items specified are available. The number returned will be equal to or less than that number. They will only be less if the stream is completed and there are less than that number specified available.
      • all

        public CompletableFuture<List<Result>> all()
        The returned CompletableFuture completes when all reads are complete for this request and the entire result has been accounted for on the client. While this method is named "all" it really refers to retrieving all remaining items in the set. For large result sets it is preferred to use Iterator or Stream options, as the results will be held in memory at once.
      • stream

        public Stream<Result> stream()
        Stream items with a blocking iterator.
      • iterator

        public Iterator<Result> iterator()
        Returns a blocking iterator of the items streaming from the server to the client. This Iterator will consume results as they arrive and leaving the ResultSet empty when complete.

        The returned Iterator does not support the Iterator.remove() method.

        Specified by:
        iterator in interface Iterable<Result>