Class BasePartitions<R extends BaseRowIterator<?>,I extends BasePartitionIterator<? extends BaseRowIterator<?>>>

java.lang.Object
org.apache.cassandra.db.transform.BasePartitions<R,I>
All Implemented Interfaces:
AutoCloseable, Iterator<R>, BasePartitionIterator<R>, CloseableIterator<R>
Direct Known Subclasses:
FilteredPartitions

public abstract class BasePartitions<R extends BaseRowIterator<?>,I extends BasePartitionIterator<? extends BaseRowIterator<?>>> extends Object implements BasePartitionIterator<R>
  • Field Details

    • EMPTY_TRANSFORMATIONS

      public static final Transformation[] EMPTY_TRANSFORMATIONS
    • EMPTY_MORE_CONTENTS_HOLDERS

      public static final org.apache.cassandra.db.transform.Stack.MoreContentsHolder[] EMPTY_MORE_CONTENTS_HOLDERS
  • Constructor Details

    • BasePartitions

      public BasePartitions(I input)
  • Method Details

    • applyOne

      protected BaseRowIterator<?> applyOne(BaseRowIterator<?> value, Transformation transformation)
      apply the relevant method from the transformation to the value. used in hasMoreContents to apply the functions that follow the MoreContents
    • runOnClose

      protected Throwable runOnClose(int length)
      run the corresponding runOnClose method for the first length transformations. used in hasMoreContents to close the methods preceding the MoreContents
    • hasNext

      public final boolean hasNext()
      Specified by:
      hasNext in interface Iterator<R extends BaseRowIterator<?>>
    • close

      public final void close()
      Specified by:
      close in interface AutoCloseable
    • next

      public final R next()
      Specified by:
      next in interface Iterator<V>
    • hasMoreContents

      protected final boolean hasMoreContents()