org.apache.cassandra/cassandra-all/3.11.5 : org/apache/cassandra/service/pager/QueryPagers.class

QueryPagers
- <init>(): void
- countPaged(CFMetaData, DecoratedKey, ColumnFilter, ClusteringIndexFilter, DataLimits, ConsistencyLevel, ClientState, int, int, boolean, long): int

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.

The Apache Software License, Version 2.0

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.QueryPagers
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.cassandra.service.pager.QueryPagers
  super_class: java.lang.Object
{
  private void <init>();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.service.pager.QueryPagers this
         0: .line 34
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // org.apache.cassandra.service.pager.QueryPagers this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/service/pager/QueryPagers;

  public static int countPaged(org.apache.cassandra.config.CFMetaData, org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.db.filter.ColumnFilter, org.apache.cassandra.db.filter.ClusteringIndexFilter, org.apache.cassandra.db.filter.DataLimits, org.apache.cassandra.db.ConsistencyLevel, org.apache.cassandra.service.ClientState, int, int, boolean, long);
    descriptor: (Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/ConsistencyLevel;Lorg/apache/cassandra/service/ClientState;IIZJ)I
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=8, locals=19, args_size=11
        start local 0 // org.apache.cassandra.config.CFMetaData metadata
        start local 1 // org.apache.cassandra.db.DecoratedKey key
        start local 2 // org.apache.cassandra.db.filter.ColumnFilter columnFilter
        start local 3 // org.apache.cassandra.db.filter.ClusteringIndexFilter filter
        start local 4 // org.apache.cassandra.db.filter.DataLimits limits
        start local 5 // org.apache.cassandra.db.ConsistencyLevel consistencyLevel
        start local 6 // org.apache.cassandra.service.ClientState state
        start local 7 // int pageSize
        start local 8 // int nowInSec
        start local 9 // boolean isForThrift
        start local 10 // long queryStartNanoTime
         0: .line 51
            iload 9 /* isForThrift */
            aload 0 /* metadata */
            iload 8 /* nowInSec */
            aload 2 /* columnFilter */
            getstatic org.apache.cassandra.db.filter.RowFilter.NONE:Lorg/apache/cassandra/db/filter/RowFilter;
            aload 4 /* limits */
            aload 1 /* key */
            aload 3 /* filter */
            invokestatic org.apache.cassandra.db.SinglePartitionReadCommand.create:(ZLorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/RowFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
            astore 12 /* command */
        start local 12 // org.apache.cassandra.db.SinglePartitionReadCommand command
         1: .line 52
            new org.apache.cassandra.service.pager.SinglePartitionPager
            dup
            aload 12 /* command */
            aconst_null
            getstatic org.apache.cassandra.transport.ProtocolVersion.CURRENT:Lorg/apache/cassandra/transport/ProtocolVersion;
            invokespecial org.apache.cassandra.service.pager.SinglePartitionPager.<init>:(Lorg/apache/cassandra/db/SinglePartitionReadCommand;Lorg/apache/cassandra/service/pager/PagingState;Lorg/apache/cassandra/transport/ProtocolVersion;)V
            astore 13 /* pager */
        start local 13 // org.apache.cassandra.service.pager.SinglePartitionPager pager
         2: .line 54
            iconst_0
            istore 14 /* count */
        start local 14 // int count
         3: .line 55
            goto 15
         4: .line 57
      StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.service.pager.SinglePartitionPager int
      StackMap stack:
            aconst_null
            astore 15
            aconst_null
            astore 16
         5: aload 13 /* pager */
            iload 7 /* pageSize */
            aload 5 /* consistencyLevel */
            aload 6 /* state */
            lload 10 /* queryStartNanoTime */
            invokevirtual org.apache.cassandra.service.pager.SinglePartitionPager.fetchPage:(ILorg/apache/cassandra/db/ConsistencyLevel;Lorg/apache/cassandra/service/ClientState;J)Lorg/apache/cassandra/db/partitions/PartitionIterator;
            astore 17 /* iter */
        start local 17 // org.apache.cassandra.db.partitions.PartitionIterator iter
         6: .line 59
            aload 4 /* limits */
            iload 8 /* nowInSec */
            iconst_1
            aload 12 /* command */
            invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.selectsFullPartition:()Z
            aload 0 /* metadata */
            invokevirtual org.apache.cassandra.config.CFMetaData.enforceStrictLiveness:()Z
            invokevirtual org.apache.cassandra.db.filter.DataLimits.newCounter:(IZZZ)Lorg/apache/cassandra/db/filter/DataLimits$Counter;
            astore 18 /* counter */
        start local 18 // org.apache.cassandra.db.filter.DataLimits$Counter counter
         7: .line 60
            aload 18 /* counter */
            aload 17 /* iter */
            invokevirtual org.apache.cassandra.db.filter.DataLimits$Counter.applyTo:(Lorg/apache/cassandra/db/partitions/PartitionIterator;)Lorg/apache/cassandra/db/partitions/PartitionIterator;
            invokestatic org.apache.cassandra.db.partitions.PartitionIterators.consume:(Lorg/apache/cassandra/db/partitions/PartitionIterator;)V
         8: .line 61
            iload 14 /* count */
            aload 18 /* counter */
            invokevirtual org.apache.cassandra.db.filter.DataLimits$Counter.counted:()I
            iadd
            istore 14 /* count */
        end local 18 // org.apache.cassandra.db.filter.DataLimits$Counter counter
         9: .line 62
            aload 17 /* iter */
            ifnull 15
            aload 17 /* iter */
            invokeinterface org.apache.cassandra.db.partitions.PartitionIterator.close:()V
            goto 15
      StackMap locals: org.apache.cassandra.config.CFMetaData org.apache.cassandra.db.DecoratedKey org.apache.cassandra.db.filter.ColumnFilter org.apache.cassandra.db.filter.ClusteringIndexFilter org.apache.cassandra.db.filter.DataLimits org.apache.cassandra.db.ConsistencyLevel org.apache.cassandra.service.ClientState int int int long org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.service.pager.SinglePartitionPager int java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.partitions.PartitionIterator
      StackMap stack: java.lang.Throwable
        10: astore 15
            aload 17 /* iter */
            ifnull 11
            aload 17 /* iter */
            invokeinterface org.apache.cassandra.db.partitions.PartitionIterator.close:()V
        end local 17 // org.apache.cassandra.db.partitions.PartitionIterator iter
      StackMap locals:
      StackMap stack:
        11: aload 15
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        12: astore 16
            aload 15
            ifnonnull 13
            aload 16
            astore 15
            goto 14
      StackMap locals:
      StackMap stack:
        13: aload 15
            aload 16
            if_acmpeq 14
            aload 15
            aload 16
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        14: aload 15
            athrow
        15: .line 55
      StackMap locals:
      StackMap stack:
            aload 13 /* pager */
            invokevirtual org.apache.cassandra.service.pager.SinglePartitionPager.isExhausted:()Z
            ifeq 4
        16: .line 64
            iload 14 /* count */
            ireturn
        end local 14 // int count
        end local 13 // org.apache.cassandra.service.pager.SinglePartitionPager pager
        end local 12 // org.apache.cassandra.db.SinglePartitionReadCommand command
        end local 10 // long queryStartNanoTime
        end local 9 // boolean isForThrift
        end local 8 // int nowInSec
        end local 7 // int pageSize
        end local 6 // org.apache.cassandra.service.ClientState state
        end local 5 // org.apache.cassandra.db.ConsistencyLevel consistencyLevel
        end local 4 // org.apache.cassandra.db.filter.DataLimits limits
        end local 3 // org.apache.cassandra.db.filter.ClusteringIndexFilter filter
        end local 2 // org.apache.cassandra.db.filter.ColumnFilter columnFilter
        end local 1 // org.apache.cassandra.db.DecoratedKey key
        end local 0 // org.apache.cassandra.config.CFMetaData metadata
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0   17     0            metadata  Lorg/apache/cassandra/config/CFMetaData;
            0   17     1                 key  Lorg/apache/cassandra/db/DecoratedKey;
            0   17     2        columnFilter  Lorg/apache/cassandra/db/filter/ColumnFilter;
            0   17     3              filter  Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
            0   17     4              limits  Lorg/apache/cassandra/db/filter/DataLimits;
            0   17     5    consistencyLevel  Lorg/apache/cassandra/db/ConsistencyLevel;
            0   17     6               state  Lorg/apache/cassandra/service/ClientState;
            0   17     7            pageSize  I
            0   17     8            nowInSec  I
            0   17     9         isForThrift  Z
            0   17    10  queryStartNanoTime  J
            1   17    12             command  Lorg/apache/cassandra/db/SinglePartitionReadCommand;
            2   17    13               pager  Lorg/apache/cassandra/service/pager/SinglePartitionPager;
            3   17    14               count  I
            6   11    17                iter  Lorg/apache/cassandra/db/partitions/PartitionIterator;
            7    9    18             counter  Lorg/apache/cassandra/db/filter/DataLimits$Counter;
      Exception table:
        from    to  target  type
           6     9      10  any
           5    12      12  any
    Exceptions:
      throws org.apache.cassandra.exceptions.RequestValidationException, org.apache.cassandra.exceptions.RequestExecutionException
    MethodParameters:
                    Name  Flags
      metadata            
      key                 
      columnFilter        
      filter              
      limits              
      consistencyLevel    
      state               
      pageSize            final
      nowInSec            
      isForThrift         
      queryStartNanoTime  
}
SourceFile: "QueryPagers.java"
InnerClasses:
  public abstract Counter = org.apache.cassandra.db.filter.DataLimits$Counter of org.apache.cassandra.db.filter.DataLimits

/

org.apache.cassandra/ cassandra-all/ 3.11.5/ org/apache/cassandra/service/pager/QueryPagers.class