Class RowSetBuffered<T extends RowSet>

All Implemented Interfaces:
Iterator<Binding>, org.apache.jena.atlas.iterator.IteratorCloseable<Binding>, org.apache.jena.atlas.lib.Closeable, RowSet

public class RowSetBuffered<T extends RowSet> extends org.apache.jena.atlas.iterator.IteratorSlotted<Binding> implements RowSet
A buffering RowSet wrapper for stream-backed RowSets whose getResultVars() returns null as long as the header has not been seen on the stream. Calling getResultVars() buffers bindings from the delegate RowSet until it returns a non-null value for its result vars. The buffered bindings are replayed on this instance in their appropriate order.
  • Constructor Details

  • Method Details

    • getDelegate

      public T getDelegate()
    • getResultVars

      public List<Var> getResultVars()
      Reads and buffers bindings until the delegate's header no longer returns null
      Specified by:
      getResultVars in interface RowSet
    • getRowNumber

      public long getRowNumber()
      Description copied from interface: RowSet
      Return the row number. The first row is row 1.
      Specified by:
      getRowNumber in interface RowSet
    • closeIterator

      public void closeIterator()