Package org.apache.cassandra.db.transform

Class BaseRows<R extends Unfiltered,I extends BaseRowIterator<? extends Unfiltered>>

java.lang.Object
org.apache.cassandra.db.transform.BaseRows<R,I>
All Implemented Interfaces:
AutoCloseable, Iterator<R>, BaseRowIterator<R>, CloseableIterator<R>
Direct Known Subclasses:
FilteredRows
public abstract class BaseRows<R extends Unfiltered,I extends BaseRowIterator<? extends Unfiltered>> extends Object implements BaseRowIterator<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

    • BaseRows

      public BaseRows(I input)

  • Method Details

    • metadata

      public TableMetadata metadata()
      Description copied from interface: BaseRowIterator
      The metadata for the table this iterator on.
      Specified by:
      metadata in interface BaseRowIterator<R extends Unfiltered>

    • isReverseOrder

      public boolean isReverseOrder()
      Description copied from interface: BaseRowIterator
      Whether or not the rows returned by this iterator are in reversed clustering order.
      Specified by:
      isReverseOrder in interface BaseRowIterator<R extends Unfiltered>

    • columns

      public RegularAndStaticColumns columns()
      Description copied from interface: BaseRowIterator
      A subset of the columns for the (static and regular) rows returned by this iterator. Every row returned by this iterator must guarantee that it has only those columns.
      Specified by:
      columns in interface BaseRowIterator<R extends Unfiltered>

    • partitionKey

      public DecoratedKey partitionKey()
      Description copied from interface: BaseRowIterator
      The partition key of the partition this in an iterator over.
      Specified by:
      partitionKey in interface BaseRowIterator<R extends Unfiltered>

    • staticRow

      public Row staticRow()
      Description copied from interface: BaseRowIterator
      The static part corresponding to this partition (this can be an empty row but cannot be null).
      Specified by:
      staticRow in interface BaseRowIterator<R extends Unfiltered>

    • 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

    • applyOne

      protected Unfiltered applyOne(Unfiltered value, Transformation transformation)
      apply the relevant method from the transformation to the value. used in hasMoreContents to apply the functions that follow the MoreContents

    • hasNext

      public final boolean hasNext()
      Specified by:
      hasNext in interface Iterator<R extends Unfiltered>

    • 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()