https://cassandra.apache.org: The Apache Cassandra Project develops a highly scalable second-generation distributed database, bringing together Dynamo's fully distributed design and Bigtable's ColumnFamily-based data model.
  • Andres de la Peña
  • Avinash Lakshman
  • Aleksey Yeschenko
  • Aaron Morton
  • Ariel Weisberg
  • Blake Eggleston
  • Benedict Elliott Smith
  • Benjamin Lerer
  • Branimir Lambov
  • Brandon Williams
  • Carl Yeksigian
  • David Brosiusd
  • Dikang Gu
  • Eric Evans
  • Gary Dusbabek
  • Chris Goffinet
  • Alex Petrov
  • Laine Jaakko Olavi
  • T Jake Luciani
  • Jason Brown
  • Jonathan Ellis
  • Jake Farrell
  • Jeff Jirsa
  • Joel Knighton
  • Josh McKenzie
  • Johan Oskarsson
  • Jun Rao
  • Jay Zhuang
  • Sankalp Kohli
  • Marcus Eriksson
  • Michael Semb Wever
  • Mikhail Stepura
  • Michael Shuler
  • Paulo Motta
  • Prashant Malik
  • Robert Stupp
  • Peter Schuller
  • Sam Tunnicliffe
  • Sylvain Lebresne
  • Stefania Alborghetti
  • Tyler Hobbs
  • Vijay Parthasarathy
  • Pavel Yaskevich
  • Yuki Morishita
  • Nate McCall 
public class org.apache.cassandra.service.pager.PartitionRangeQueryPager extends org.apache.cassandra.service.pager.AbstractQueryPager
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.cassandra.service.pager.PartitionRangeQueryPager
  super_class: org.apache.cassandra.service.pager.AbstractQueryPager
{
  private volatile org.apache.cassandra.db.DecoratedKey lastReturnedKey;
    descriptor: Lorg/apache/cassandra/db/DecoratedKey;
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  private volatile org.apache.cassandra.service.pager.PagingState$RowMark lastReturnedRow;
    descriptor: Lorg/apache/cassandra/service/pager/PagingState$RowMark;
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  public void <init>(org.apache.cassandra.db.PartitionRangeReadCommand, org.apache.cassandra.service.pager.PagingState, org.apache.cassandra.transport.ProtocolVersion);
    descriptor: (Lorg/apache/cassandra/db/PartitionRangeReadCommand;Lorg/apache/cassandra/service/pager/PagingState;Lorg/apache/cassandra/transport/ProtocolVersion;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=4, args_size=4
        start local 0 // org.apache.cassandra.service.pager.PartitionRangeQueryPager this
        start local 1 // org.apache.cassandra.db.PartitionRangeReadCommand command
        start local 2 // org.apache.cassandra.service.pager.PagingState state
        start local 3 // org.apache.cassandra.transport.ProtocolVersion protocolVersion
         0: .line 40
            aload 0 /* this */
            aload 1 /* command */
            aload 3 /* protocolVersion */
            invokespecial org.apache.cassandra.service.pager.AbstractQueryPager.<init>:(Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/transport/ProtocolVersion;)V
         1: .line 42
            aload 2 /* state */
            ifnull 5
         2: .line 44
            aload 0 /* this */
            aload 1 /* command */
            invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
            aload 2 /* state */
            getfield org.apache.cassandra.service.pager.PagingState.partitionKey:Ljava/nio/ByteBuffer;
            invokevirtual org.apache.cassandra.config.CFMetaData.decorateKey:(Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/db/DecoratedKey;
            putfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.lastReturnedKey:Lorg/apache/cassandra/db/DecoratedKey;
         3: .line 45
            aload 0 /* this */
            aload 2 /* state */
            getfield org.apache.cassandra.service.pager.PagingState.rowMark:Lorg/apache/cassandra/service/pager/PagingState$RowMark;
            putfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.lastReturnedRow:Lorg/apache/cassandra/service/pager/PagingState$RowMark;
         4: .line 46
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.lastReturnedKey:Lorg/apache/cassandra/db/DecoratedKey;
            aload 2 /* state */
            getfield org.apache.cassandra.service.pager.PagingState.remaining:I
            aload 2 /* state */
            getfield org.apache.cassandra.service.pager.PagingState.remainingInPartition:I
            invokevirtual org.apache.cassandra.service.pager.PartitionRangeQueryPager.restoreState:(Lorg/apache/cassandra/db/DecoratedKey;II)V
         5: .line 48
      StackMap locals: org.apache.cassandra.service.pager.PartitionRangeQueryPager org.apache.cassandra.db.PartitionRangeReadCommand org.apache.cassandra.service.pager.PagingState org.apache.cassandra.transport.ProtocolVersion
      StackMap stack:
            return
        end local 3 // org.apache.cassandra.transport.ProtocolVersion protocolVersion
        end local 2 // org.apache.cassandra.service.pager.PagingState state
        end local 1 // org.apache.cassandra.db.PartitionRangeReadCommand command
        end local 0 // org.apache.cassandra.service.pager.PartitionRangeQueryPager this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    6     0             this  Lorg/apache/cassandra/service/pager/PartitionRangeQueryPager;
            0    6     1          command  Lorg/apache/cassandra/db/PartitionRangeReadCommand;
            0    6     2            state  Lorg/apache/cassandra/service/pager/PagingState;
            0    6     3  protocolVersion  Lorg/apache/cassandra/transport/ProtocolVersion;
    MethodParameters:
                 Name  Flags
      command          
      state            
      protocolVersion  

  public void <init>(org.apache.cassandra.db.ReadCommand, org.apache.cassandra.transport.ProtocolVersion, org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.service.pager.PagingState$RowMark, int, int);
    descriptor: (Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/transport/ProtocolVersion;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/service/pager/PagingState$RowMark;II)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=7, args_size=7
        start local 0 // org.apache.cassandra.service.pager.PartitionRangeQueryPager this
        start local 1 // org.apache.cassandra.db.ReadCommand command
        start local 2 // org.apache.cassandra.transport.ProtocolVersion protocolVersion
        start local 3 // org.apache.cassandra.db.DecoratedKey lastReturnedKey
        start local 4 // org.apache.cassandra.service.pager.PagingState$RowMark lastReturnedRow
        start local 5 // int remaining
        start local 6 // int remainingInPartition
         0: .line 57
            aload 0 /* this */
            aload 1 /* command */
            aload 2 /* protocolVersion */
            invokespecial org.apache.cassandra.service.pager.AbstractQueryPager.<init>:(Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/transport/ProtocolVersion;)V
         1: .line 58
            aload 0 /* this */
            aload 3 /* lastReturnedKey */
            putfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.lastReturnedKey:Lorg/apache/cassandra/db/DecoratedKey;
         2: .line 59
            aload 0 /* this */
            aload 4 /* lastReturnedRow */
            putfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.lastReturnedRow:Lorg/apache/cassandra/service/pager/PagingState$RowMark;
         3: .line 60
            aload 0 /* this */
            aload 3 /* lastReturnedKey */
            iload 5 /* remaining */
            iload 6 /* remainingInPartition */
            invokevirtual org.apache.cassandra.service.pager.PartitionRangeQueryPager.restoreState:(Lorg/apache/cassandra/db/DecoratedKey;II)V
         4: .line 61
            return
        end local 6 // int remainingInPartition
        end local 5 // int remaining
        end local 4 // org.apache.cassandra.service.pager.PagingState$RowMark lastReturnedRow
        end local 3 // org.apache.cassandra.db.DecoratedKey lastReturnedKey
        end local 2 // org.apache.cassandra.transport.ProtocolVersion protocolVersion
        end local 1 // org.apache.cassandra.db.ReadCommand command
        end local 0 // org.apache.cassandra.service.pager.PartitionRangeQueryPager this
      LocalVariableTable:
        Start  End  Slot                  Name  Signature
            0    5     0                  this  Lorg/apache/cassandra/service/pager/PartitionRangeQueryPager;
            0    5     1               command  Lorg/apache/cassandra/db/ReadCommand;
            0    5     2       protocolVersion  Lorg/apache/cassandra/transport/ProtocolVersion;
            0    5     3       lastReturnedKey  Lorg/apache/cassandra/db/DecoratedKey;
            0    5     4       lastReturnedRow  Lorg/apache/cassandra/service/pager/PagingState$RowMark;
            0    5     5             remaining  I
            0    5     6  remainingInPartition  I
    MethodParameters:
                      Name  Flags
      command               
      protocolVersion       
      lastReturnedKey       
      lastReturnedRow       
      remaining             
      remainingInPartition  

  public org.apache.cassandra.service.pager.PartitionRangeQueryPager withUpdatedLimit(org.apache.cassandra.db.filter.DataLimits);
    descriptor: (Lorg/apache/cassandra/db/filter/DataLimits;)Lorg/apache/cassandra/service/pager/PartitionRangeQueryPager;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=8, locals=2, args_size=2
        start local 0 // org.apache.cassandra.service.pager.PartitionRangeQueryPager this
        start local 1 // org.apache.cassandra.db.filter.DataLimits newLimits
         0: .line 65
            new org.apache.cassandra.service.pager.PartitionRangeQueryPager
            dup
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.command:Lorg/apache/cassandra/db/ReadCommand;
            aload 1 /* newLimits */
            invokevirtual org.apache.cassandra.db.ReadCommand.withUpdatedLimit:(Lorg/apache/cassandra/db/filter/DataLimits;)Lorg/apache/cassandra/db/ReadCommand;
         1: .line 66
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.protocolVersion:Lorg/apache/cassandra/transport/ProtocolVersion;
         2: .line 67
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.lastReturnedKey:Lorg/apache/cassandra/db/DecoratedKey;
         3: .line 68
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.lastReturnedRow:Lorg/apache/cassandra/service/pager/PagingState$RowMark;
         4: .line 69
            aload 0 /* this */
            invokevirtual org.apache.cassandra.service.pager.PartitionRangeQueryPager.maxRemaining:()I
         5: .line 70
            aload 0 /* this */
            invokevirtual org.apache.cassandra.service.pager.PartitionRangeQueryPager.remainingInPartition:()I
         6: .line 65
            invokespecial org.apache.cassandra.service.pager.PartitionRangeQueryPager.<init>:(Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/transport/ProtocolVersion;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/service/pager/PagingState$RowMark;II)V
            areturn
        end local 1 // org.apache.cassandra.db.filter.DataLimits newLimits
        end local 0 // org.apache.cassandra.service.pager.PartitionRangeQueryPager this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    7     0       this  Lorg/apache/cassandra/service/pager/PartitionRangeQueryPager;
            0    7     1  newLimits  Lorg/apache/cassandra/db/filter/DataLimits;
    MethodParameters:
           Name  Flags
      newLimits  

  public org.apache.cassandra.service.pager.PagingState state();
    descriptor: ()Lorg/apache/cassandra/service/pager/PagingState;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=1, args_size=1
        start local 0 // org.apache.cassandra.service.pager.PartitionRangeQueryPager this
         0: .line 75
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.lastReturnedKey:Lorg/apache/cassandra/db/DecoratedKey;
            ifnonnull 2
         1: .line 76
            aconst_null
            goto 3
         2: .line 77
      StackMap locals:
      StackMap stack:
            new org.apache.cassandra.service.pager.PagingState
            dup
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.lastReturnedKey:Lorg/apache/cassandra/db/DecoratedKey;
            invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.lastReturnedRow:Lorg/apache/cassandra/service/pager/PagingState$RowMark;
            aload 0 /* this */
            invokevirtual org.apache.cassandra.service.pager.PartitionRangeQueryPager.maxRemaining:()I
            aload 0 /* this */
            invokevirtual org.apache.cassandra.service.pager.PartitionRangeQueryPager.remainingInPartition:()I
            invokespecial org.apache.cassandra.service.pager.PagingState.<init>:(Ljava/nio/ByteBuffer;Lorg/apache/cassandra/service/pager/PagingState$RowMark;II)V
         3: .line 75
      StackMap locals:
      StackMap stack: org.apache.cassandra.service.pager.PagingState
            areturn
        end local 0 // org.apache.cassandra.service.pager.PartitionRangeQueryPager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lorg/apache/cassandra/service/pager/PartitionRangeQueryPager;

  protected org.apache.cassandra.db.ReadCommand nextPageReadCommand(int);
    descriptor: (I)Lorg/apache/cassandra/db/ReadCommand;
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=5, locals=7, args_size=2
        start local 0 // org.apache.cassandra.service.pager.PartitionRangeQueryPager this
        start local 1 // int pageSize
         0: .line 84
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.command:Lorg/apache/cassandra/db/ReadCommand;
            checkcast org.apache.cassandra.db.PartitionRangeReadCommand
            invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.dataRange:()Lorg/apache/cassandra/db/DataRange;
            astore 3 /* fullRange */
        start local 3 // org.apache.cassandra.db.DataRange fullRange
         1: .line 86
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.lastReturnedKey:Lorg/apache/cassandra/db/DecoratedKey;
            ifnonnull 5
         2: .line 88
            aload 3 /* fullRange */
            astore 4 /* pageRange */
        start local 4 // org.apache.cassandra.db.DataRange pageRange
         3: .line 89
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
            iload 1 /* pageSize */
            invokevirtual org.apache.cassandra.db.filter.DataLimits.forPaging:(I)Lorg/apache/cassandra/db/filter/DataLimits;
            astore 2 /* limits */
        start local 2 // org.apache.cassandra.db.filter.DataLimits limits
         4: .line 90
            goto 15
        end local 4 // org.apache.cassandra.db.DataRange pageRange
        end local 2 // org.apache.cassandra.db.filter.DataLimits limits
         5: .line 94
      StackMap locals: org.apache.cassandra.service.pager.PartitionRangeQueryPager int top org.apache.cassandra.db.DataRange
      StackMap stack:
            aload 0 /* this */
            invokevirtual org.apache.cassandra.service.pager.PartitionRangeQueryPager.remainingInPartition:()I
            ifle 6
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.lastReturnedRow:Lorg/apache/cassandra/service/pager/PagingState$RowMark;
            ifnull 6
            iconst_1
            goto 7
      StackMap locals:
      StackMap stack:
         6: iconst_0
      StackMap locals:
      StackMap stack: int
         7: istore 5 /* includeLastKey */
        start local 5 // boolean includeLastKey
         8: .line 95
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.lastReturnedKey:Lorg/apache/cassandra/db/DecoratedKey;
            iload 5 /* includeLastKey */
            invokevirtual org.apache.cassandra.service.pager.PartitionRangeQueryPager.makeKeyBounds:(Lorg/apache/cassandra/db/PartitionPosition;Z)Lorg/apache/cassandra/dht/AbstractBounds;
            astore 6 /* bounds */
        start local 6 // org.apache.cassandra.dht.AbstractBounds bounds
         9: .line 96
            iload 5 /* includeLastKey */
            ifeq 13
        10: .line 98
            aload 3 /* fullRange */
            aload 6 /* bounds */
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
            getfield org.apache.cassandra.config.CFMetaData.comparator:Lorg/apache/cassandra/db/ClusteringComparator;
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.lastReturnedRow:Lorg/apache/cassandra/service/pager/PagingState$RowMark;
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
            invokevirtual org.apache.cassandra.service.pager.PagingState$RowMark.clustering:(Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/db/Clustering;
            iconst_0
            invokevirtual org.apache.cassandra.db.DataRange.forPaging:(Lorg/apache/cassandra/dht/AbstractBounds;Lorg/apache/cassandra/db/ClusteringComparator;Lorg/apache/cassandra/db/Clustering;Z)Lorg/apache/cassandra/db/DataRange;
            astore 4 /* pageRange */
        start local 4 // org.apache.cassandra.db.DataRange pageRange
        11: .line 99
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
            iload 1 /* pageSize */
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.lastReturnedKey:Lorg/apache/cassandra/db/DecoratedKey;
            invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
            aload 0 /* this */
            invokevirtual org.apache.cassandra.service.pager.PartitionRangeQueryPager.remainingInPartition:()I
            invokevirtual org.apache.cassandra.db.filter.DataLimits.forPaging:(ILjava/nio/ByteBuffer;I)Lorg/apache/cassandra/db/filter/DataLimits;
            astore 2 /* limits */
        start local 2 // org.apache.cassandra.db.filter.DataLimits limits
        12: .line 100
            goto 15
        end local 4 // org.apache.cassandra.db.DataRange pageRange
        end local 2 // org.apache.cassandra.db.filter.DataLimits limits
        13: .line 103
      StackMap locals: org.apache.cassandra.service.pager.PartitionRangeQueryPager int top org.apache.cassandra.db.DataRange top int org.apache.cassandra.dht.AbstractBounds
      StackMap stack:
            aload 3 /* fullRange */
            aload 6 /* bounds */
            invokevirtual org.apache.cassandra.db.DataRange.forSubRange:(Lorg/apache/cassandra/dht/AbstractBounds;)Lorg/apache/cassandra/db/DataRange;
            astore 4 /* pageRange */
        start local 4 // org.apache.cassandra.db.DataRange pageRange
        14: .line 104
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
            iload 1 /* pageSize */
            invokevirtual org.apache.cassandra.db.filter.DataLimits.forPaging:(I)Lorg/apache/cassandra/db/filter/DataLimits;
            astore 2 /* limits */
        end local 6 // org.apache.cassandra.dht.AbstractBounds bounds
        end local 5 // boolean includeLastKey
        start local 2 // org.apache.cassandra.db.filter.DataLimits limits
        15: .line 108
      StackMap locals: org.apache.cassandra.service.pager.PartitionRangeQueryPager int org.apache.cassandra.db.filter.DataLimits org.apache.cassandra.db.DataRange org.apache.cassandra.db.DataRange
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.command:Lorg/apache/cassandra/db/ReadCommand;
            checkcast org.apache.cassandra.db.PartitionRangeReadCommand
            aload 2 /* limits */
            aload 4 /* pageRange */
            invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.withUpdatedLimitsAndDataRange:(Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/DataRange;)Lorg/apache/cassandra/db/PartitionRangeReadCommand;
            areturn
        end local 4 // org.apache.cassandra.db.DataRange pageRange
        end local 3 // org.apache.cassandra.db.DataRange fullRange
        end local 2 // org.apache.cassandra.db.filter.DataLimits limits
        end local 1 // int pageSize
        end local 0 // org.apache.cassandra.service.pager.PartitionRangeQueryPager this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0   16     0            this  Lorg/apache/cassandra/service/pager/PartitionRangeQueryPager;
            0   16     1        pageSize  I
            4    5     2          limits  Lorg/apache/cassandra/db/filter/DataLimits;
           12   13     2          limits  Lorg/apache/cassandra/db/filter/DataLimits;
           15   16     2          limits  Lorg/apache/cassandra/db/filter/DataLimits;
            1   16     3       fullRange  Lorg/apache/cassandra/db/DataRange;
            3    5     4       pageRange  Lorg/apache/cassandra/db/DataRange;
           11   13     4       pageRange  Lorg/apache/cassandra/db/DataRange;
           14   16     4       pageRange  Lorg/apache/cassandra/db/DataRange;
            8   15     5  includeLastKey  Z
            9   15     6          bounds  Lorg/apache/cassandra/dht/AbstractBounds<Lorg/apache/cassandra/db/PartitionPosition;>;
    Exceptions:
      throws org.apache.cassandra.exceptions.RequestExecutionException
    MethodParameters:
          Name  Flags
      pageSize  

  protected void recordLast(org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.db.rows.Row);
    descriptor: (Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/rows/Row;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=4, locals=3, args_size=3
        start local 0 // org.apache.cassandra.service.pager.PartitionRangeQueryPager this
        start local 1 // org.apache.cassandra.db.DecoratedKey key
        start local 2 // org.apache.cassandra.db.rows.Row last
         0: .line 113
            aload 2 /* last */
            ifnull 4
         1: .line 115
            aload 0 /* this */
            aload 1 /* key */
            putfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.lastReturnedKey:Lorg/apache/cassandra/db/DecoratedKey;
         2: .line 116
            aload 2 /* last */
            invokeinterface org.apache.cassandra.db.rows.Row.clustering:()Lorg/apache/cassandra/db/Clustering;
            getstatic org.apache.cassandra.db.Clustering.STATIC_CLUSTERING:Lorg/apache/cassandra/db/Clustering;
            if_acmpeq 4
         3: .line 117
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
            aload 2 /* last */
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.protocolVersion:Lorg/apache/cassandra/transport/ProtocolVersion;
            invokestatic org.apache.cassandra.service.pager.PagingState$RowMark.create:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/rows/Row;Lorg/apache/cassandra/transport/ProtocolVersion;)Lorg/apache/cassandra/service/pager/PagingState$RowMark;
            putfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.lastReturnedRow:Lorg/apache/cassandra/service/pager/PagingState$RowMark;
         4: .line 119
      StackMap locals:
      StackMap stack:
            return
        end local 2 // org.apache.cassandra.db.rows.Row last
        end local 1 // org.apache.cassandra.db.DecoratedKey key
        end local 0 // org.apache.cassandra.service.pager.PartitionRangeQueryPager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lorg/apache/cassandra/service/pager/PartitionRangeQueryPager;
            0    5     1   key  Lorg/apache/cassandra/db/DecoratedKey;
            0    5     2  last  Lorg/apache/cassandra/db/rows/Row;
    MethodParameters:
      Name  Flags
      key   
      last  

  protected boolean isPreviouslyReturnedPartition(org.apache.cassandra.db.DecoratedKey);
    descriptor: (Lorg/apache/cassandra/db/DecoratedKey;)Z
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.apache.cassandra.service.pager.PartitionRangeQueryPager this
        start local 1 // org.apache.cassandra.db.DecoratedKey key
         0: .line 124
            aload 1 /* key */
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.lastReturnedKey:Lorg/apache/cassandra/db/DecoratedKey;
            invokevirtual org.apache.cassandra.db.DecoratedKey.equals:(Ljava/lang/Object;)Z
            ireturn
        end local 1 // org.apache.cassandra.db.DecoratedKey key
        end local 0 // org.apache.cassandra.service.pager.PartitionRangeQueryPager this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/service/pager/PartitionRangeQueryPager;
            0    1     1   key  Lorg/apache/cassandra/db/DecoratedKey;
    MethodParameters:
      Name  Flags
      key   

  private org.apache.cassandra.dht.AbstractBounds<org.apache.cassandra.db.PartitionPosition> makeKeyBounds(org.apache.cassandra.db.PartitionPosition, boolean);
    descriptor: (Lorg/apache/cassandra/db/PartitionPosition;Z)Lorg/apache/cassandra/dht/AbstractBounds;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=4, args_size=3
        start local 0 // org.apache.cassandra.service.pager.PartitionRangeQueryPager this
        start local 1 // org.apache.cassandra.db.PartitionPosition lastReturnedKey
        start local 2 // boolean includeLastKey
         0: .line 129
            aload 0 /* this */
            getfield org.apache.cassandra.service.pager.PartitionRangeQueryPager.command:Lorg/apache/cassandra/db/ReadCommand;
            checkcast org.apache.cassandra.db.PartitionRangeReadCommand
            invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.dataRange:()Lorg/apache/cassandra/db/DataRange;
            invokevirtual org.apache.cassandra.db.DataRange.keyRange:()Lorg/apache/cassandra/dht/AbstractBounds;
            astore 3 /* bounds */
        start local 3 // org.apache.cassandra.dht.AbstractBounds bounds
         1: .line 130
            aload 3 /* bounds */
            instanceof org.apache.cassandra.dht.Range
            ifne 2
            aload 3 /* bounds */
            instanceof org.apache.cassandra.dht.Bounds
            ifeq 6
         2: .line 132
      StackMap locals: org.apache.cassandra.dht.AbstractBounds
      StackMap stack:
            iload 2 /* includeLastKey */
            ifeq 4
         3: .line 133
            new org.apache.cassandra.dht.Bounds
            dup
            aload 1 /* lastReturnedKey */
            aload 3 /* bounds */
            getfield org.apache.cassandra.dht.AbstractBounds.right:Lorg/apache/cassandra/dht/RingPosition;
            checkcast org.apache.cassandra.db.PartitionPosition
            invokespecial org.apache.cassandra.dht.Bounds.<init>:(Lorg/apache/cassandra/dht/RingPosition;Lorg/apache/cassandra/dht/RingPosition;)V
            goto 5
         4: .line 134
      StackMap locals:
      StackMap stack:
            new org.apache.cassandra.dht.Range
            dup
            aload 1 /* lastReturnedKey */
            aload 3 /* bounds */
            getfield org.apache.cassandra.dht.AbstractBounds.right:Lorg/apache/cassandra/dht/RingPosition;
            checkcast org.apache.cassandra.db.PartitionPosition
            invokespecial org.apache.cassandra.dht.Range.<init>:(Lorg/apache/cassandra/dht/RingPosition;Lorg/apache/cassandra/dht/RingPosition;)V
         5: .line 132
      StackMap locals:
      StackMap stack: org.apache.cassandra.dht.AbstractBounds
            areturn
         6: .line 138
      StackMap locals:
      StackMap stack:
            iload 2 /* includeLastKey */
            ifeq 8
         7: .line 139
            new org.apache.cassandra.dht.IncludingExcludingBounds
            dup
            aload 1 /* lastReturnedKey */
            aload 3 /* bounds */
            getfield org.apache.cassandra.dht.AbstractBounds.right:Lorg/apache/cassandra/dht/RingPosition;
            checkcast org.apache.cassandra.db.PartitionPosition
            invokespecial org.apache.cassandra.dht.IncludingExcludingBounds.<init>:(Lorg/apache/cassandra/dht/RingPosition;Lorg/apache/cassandra/dht/RingPosition;)V
            goto 9
         8: .line 140
      StackMap locals:
      StackMap stack:
            new org.apache.cassandra.dht.ExcludingBounds
            dup
            aload 1 /* lastReturnedKey */
            aload 3 /* bounds */
            getfield org.apache.cassandra.dht.AbstractBounds.right:Lorg/apache/cassandra/dht/RingPosition;
            checkcast org.apache.cassandra.db.PartitionPosition
            invokespecial org.apache.cassandra.dht.ExcludingBounds.<init>:(Lorg/apache/cassandra/dht/RingPosition;Lorg/apache/cassandra/dht/RingPosition;)V
         9: .line 138
      StackMap locals:
      StackMap stack: org.apache.cassandra.dht.AbstractBounds
            areturn
        end local 3 // org.apache.cassandra.dht.AbstractBounds bounds
        end local 2 // boolean includeLastKey
        end local 1 // org.apache.cassandra.db.PartitionPosition lastReturnedKey
        end local 0 // org.apache.cassandra.service.pager.PartitionRangeQueryPager this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   10     0             this  Lorg/apache/cassandra/service/pager/PartitionRangeQueryPager;
            0   10     1  lastReturnedKey  Lorg/apache/cassandra/db/PartitionPosition;
            0   10     2   includeLastKey  Z
            1   10     3           bounds  Lorg/apache/cassandra/dht/AbstractBounds<Lorg/apache/cassandra/db/PartitionPosition;>;
    Signature: (Lorg/apache/cassandra/db/PartitionPosition;Z)Lorg/apache/cassandra/dht/AbstractBounds<Lorg/apache/cassandra/db/PartitionPosition;>;
    MethodParameters:
                 Name  Flags
      lastReturnedKey  
      includeLastKey   

  public org.apache.cassandra.db.partitions.PartitionIterator fetchPageInternal(int, org.apache.cassandra.db.ReadExecutionController);
    descriptor: (ILorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/db/partitions/PartitionIterator;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
         0: .line 1
            aload 0
            iload 1
            aload 2
            invokespecial org.apache.cassandra.service.pager.AbstractQueryPager.fetchPageInternal:(ILorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/db/partitions/PartitionIterator;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public org.apache.cassandra.db.partitions.PartitionIterator fetchPage(int, org.apache.cassandra.db.ConsistencyLevel, org.apache.cassandra.service.ClientState, long);
    descriptor: (ILorg/apache/cassandra/db/ConsistencyLevel;Lorg/apache/cassandra/service/ClientState;J)Lorg/apache/cassandra/db/partitions/PartitionIterator;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=6, locals=6, args_size=5
         0: .line 1
            aload 0
            iload 1
            aload 2
            aload 3
            lload 4
            invokespecial org.apache.cassandra.service.pager.AbstractQueryPager.fetchPage:(ILorg/apache/cassandra/db/ConsistencyLevel;Lorg/apache/cassandra/service/ClientState;J)Lorg/apache/cassandra/db/partitions/PartitionIterator;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public org.apache.cassandra.db.ReadExecutionController executionController();
    descriptor: ()Lorg/apache/cassandra/db/ReadExecutionController;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 1
            aload 0
            invokespecial org.apache.cassandra.service.pager.AbstractQueryPager.executionController:()Lorg/apache/cassandra/db/ReadExecutionController;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public org.apache.cassandra.service.pager.QueryPager withUpdatedLimit(org.apache.cassandra.db.filter.DataLimits);
    descriptor: (Lorg/apache/cassandra/db/filter/DataLimits;)Lorg/apache/cassandra/service/pager/QueryPager;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual org.apache.cassandra.service.pager.PartitionRangeQueryPager.withUpdatedLimit:(Lorg/apache/cassandra/db/filter/DataLimits;)Lorg/apache/cassandra/service/pager/PartitionRangeQueryPager;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public boolean isExhausted();
    descriptor: ()Z
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 1
            aload 0
            invokespecial org.apache.cassandra.service.pager.AbstractQueryPager.isExhausted:()Z
            ireturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public org.apache.cassandra.db.partitions.UnfilteredPartitionIterator fetchPageUnfiltered(org.apache.cassandra.config.CFMetaData, int, org.apache.cassandra.db.ReadExecutionController);
    descriptor: (Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=4, locals=4, args_size=4
         0: .line 1
            aload 0
            aload 1
            iload 2
            aload 3
            invokespecial org.apache.cassandra.service.pager.AbstractQueryPager.fetchPageUnfiltered:(Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public int maxRemaining();
    descriptor: ()I
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 1
            aload 0
            invokespecial org.apache.cassandra.service.pager.AbstractQueryPager.maxRemaining:()I
            ireturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
}
SourceFile: "PartitionRangeQueryPager.java"
InnerClasses:
  public RowMark = org.apache.cassandra.service.pager.PagingState$RowMark of org.apache.cassandra.service.pager.PagingState