public class org.apache.cassandra.cql3.statements.SelectStatement implements org.apache.cassandra.cql3.CQLStatement
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.cql3.statements.SelectStatement
super_class: java.lang.Object
{
private static final org.slf4j.Logger logger;
descriptor: Lorg/slf4j/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
public static final int DEFAULT_PAGE_SIZE;
descriptor: I
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: 10000
private final int boundTerms;
descriptor: I
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
public final org.apache.cassandra.config.CFMetaData cfm;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
public final org.apache.cassandra.cql3.statements.SelectStatement$Parameters parameters;
descriptor: Lorg/apache/cassandra/cql3/statements/SelectStatement$Parameters;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
private final org.apache.cassandra.cql3.selection.Selection selection;
descriptor: Lorg/apache/cassandra/cql3/selection/Selection;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.cassandra.cql3.Term limit;
descriptor: Lorg/apache/cassandra/cql3/Term;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.cassandra.cql3.Term perPartitionLimit;
descriptor: Lorg/apache/cassandra/cql3/Term;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.cassandra.cql3.restrictions.StatementRestrictions restrictions;
descriptor: Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final boolean isReversed;
descriptor: Z
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.cassandra.db.aggregation.AggregationSpecification aggregationSpec;
descriptor: Lorg/apache/cassandra/db/aggregation/AggregationSpecification;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.Comparator<java.util.List<java.nio.ByteBuffer>> orderingComparator;
descriptor: Ljava/util/Comparator;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Comparator<Ljava/util/List<Ljava/nio/ByteBuffer;>;>;
private final org.apache.cassandra.db.filter.ColumnFilter queriedColumns;
descriptor: Lorg/apache/cassandra/db/filter/ColumnFilter;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private static final org.apache.cassandra.cql3.statements.SelectStatement$Parameters defaultParameters;
descriptor: Lorg/apache/cassandra/cql3/statements/SelectStatement$Parameters;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
static final boolean $assertionsDisabled;
descriptor: Z
flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC
private static volatile int[] $SWITCH_TABLE$org$apache$cassandra$config$ColumnDefinition$Kind;
descriptor: [I
flags: (0x104a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=7, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/cql3/statements/SelectStatement;
invokevirtual java.lang.Class.desiredAssertionStatus:()Z
ifne 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: putstatic org.apache.cassandra.cql3.statements.SelectStatement.$assertionsDisabled:Z
3: ldc Lorg/apache/cassandra/cql3/statements/SelectStatement;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic org.apache.cassandra.cql3.statements.SelectStatement.logger:Lorg/slf4j/Logger;
4: new org.apache.cassandra.cql3.statements.SelectStatement$Parameters
dup
invokestatic java.util.Collections.emptyMap:()Ljava/util/Map;
5: invokestatic java.util.Collections.emptyList:()Ljava/util/List;
6: iconst_0
7: iconst_0
8: iconst_0
9: invokespecial org.apache.cassandra.cql3.statements.SelectStatement$Parameters.<init>:(Ljava/util/Map;Ljava/util/List;ZZZ)V
putstatic org.apache.cassandra.cql3.statements.SelectStatement.defaultParameters:Lorg/apache/cassandra/cql3/statements/SelectStatement$Parameters;
10: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(org.apache.cassandra.config.CFMetaData, int, org.apache.cassandra.cql3.statements.SelectStatement$Parameters, org.apache.cassandra.cql3.selection.Selection, org.apache.cassandra.cql3.restrictions.StatementRestrictions, boolean, org.apache.cassandra.db.aggregation.AggregationSpecification, java.util.Comparator<java.util.List<java.nio.ByteBuffer>>, org.apache.cassandra.cql3.Term, org.apache.cassandra.cql3.Term);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/cql3/statements/SelectStatement$Parameters;Lorg/apache/cassandra/cql3/selection/Selection;Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;ZLorg/apache/cassandra/db/aggregation/AggregationSpecification;Ljava/util/Comparator;Lorg/apache/cassandra/cql3/Term;Lorg/apache/cassandra/cql3/Term;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=11, args_size=11
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 start local 8 start local 9 start local 10 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
2: aload 0
iload 2
putfield org.apache.cassandra.cql3.statements.SelectStatement.boundTerms:I
3: aload 0
aload 4
putfield org.apache.cassandra.cql3.statements.SelectStatement.selection:Lorg/apache/cassandra/cql3/selection/Selection;
4: aload 0
aload 5
putfield org.apache.cassandra.cql3.statements.SelectStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
5: aload 0
iload 6
putfield org.apache.cassandra.cql3.statements.SelectStatement.isReversed:Z
6: aload 0
aload 7
putfield org.apache.cassandra.cql3.statements.SelectStatement.aggregationSpec:Lorg/apache/cassandra/db/aggregation/AggregationSpecification;
7: aload 0
aload 8
putfield org.apache.cassandra.cql3.statements.SelectStatement.orderingComparator:Ljava/util/Comparator;
8: aload 0
aload 3
putfield org.apache.cassandra.cql3.statements.SelectStatement.parameters:Lorg/apache/cassandra/cql3/statements/SelectStatement$Parameters;
9: aload 0
aload 9
putfield org.apache.cassandra.cql3.statements.SelectStatement.limit:Lorg/apache/cassandra/cql3/Term;
10: aload 0
aload 10
putfield org.apache.cassandra.cql3.statements.SelectStatement.perPartitionLimit:Lorg/apache/cassandra/cql3/Term;
11: aload 0
aload 0
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.gatherQueriedColumns:()Lorg/apache/cassandra/db/filter/ColumnFilter;
putfield org.apache.cassandra.cql3.statements.SelectStatement.queriedColumns:Lorg/apache/cassandra/db/filter/ColumnFilter;
12: return
end local 10 end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 13 1 cfm Lorg/apache/cassandra/config/CFMetaData;
0 13 2 boundTerms I
0 13 3 parameters Lorg/apache/cassandra/cql3/statements/SelectStatement$Parameters;
0 13 4 selection Lorg/apache/cassandra/cql3/selection/Selection;
0 13 5 restrictions Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
0 13 6 isReversed Z
0 13 7 aggregationSpec Lorg/apache/cassandra/db/aggregation/AggregationSpecification;
0 13 8 orderingComparator Ljava/util/Comparator<Ljava/util/List<Ljava/nio/ByteBuffer;>;>;
0 13 9 limit Lorg/apache/cassandra/cql3/Term;
0 13 10 perPartitionLimit Lorg/apache/cassandra/cql3/Term;
Signature: (Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/cql3/statements/SelectStatement$Parameters;Lorg/apache/cassandra/cql3/selection/Selection;Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;ZLorg/apache/cassandra/db/aggregation/AggregationSpecification;Ljava/util/Comparator<Ljava/util/List<Ljava/nio/ByteBuffer;>;>;Lorg/apache/cassandra/cql3/Term;Lorg/apache/cassandra/cql3/Term;)V
MethodParameters:
Name Flags
cfm
boundTerms
parameters
selection
restrictions
isReversed
aggregationSpec
orderingComparator
limit
perPartitionLimit
public java.lang.Iterable<org.apache.cassandra.cql3.functions.Function> getFunctions();
descriptor: ()Ljava/lang/Iterable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 1
start local 1 1: aload 0
aload 1
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.addFunctionsTo:(Ljava/util/List;)V
2: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
1 3 1 functions Ljava/util/List<Lorg/apache/cassandra/cql3/functions/Function;>;
Signature: ()Ljava/lang/Iterable<Lorg/apache/cassandra/cql3/functions/Function;>;
private void addFunctionsTo(java.util.List<org.apache.cassandra.cql3.functions.Function>);
descriptor: (Ljava/util/List;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.selection:Lorg/apache/cassandra/cql3/selection/Selection;
aload 1
invokevirtual org.apache.cassandra.cql3.selection.Selection.addFunctionsTo:(Ljava/util/List;)V
1: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
aload 1
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.addFunctionsTo:(Ljava/util/List;)V
2: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.limit:Lorg/apache/cassandra/cql3/Term;
ifnull 4
3: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.limit:Lorg/apache/cassandra/cql3/Term;
aload 1
invokeinterface org.apache.cassandra.cql3.Term.addFunctionsTo:(Ljava/util/List;)V
4: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.perPartitionLimit:Lorg/apache/cassandra/cql3/Term;
ifnull 6
5: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.perPartitionLimit:Lorg/apache/cassandra/cql3/Term;
aload 1
invokeinterface org.apache.cassandra.cql3.Term.addFunctionsTo:(Ljava/util/List;)V
6: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 7 1 functions Ljava/util/List<Lorg/apache/cassandra/cql3/functions/Function;>;
Signature: (Ljava/util/List<Lorg/apache/cassandra/cql3/functions/Function;>;)V
MethodParameters:
Name Flags
functions
private org.apache.cassandra.db.filter.ColumnFilter gatherQueriedColumns();
descriptor: ()Lorg/apache/cassandra/db/filter/ColumnFilter;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.selection:Lorg/apache/cassandra/cql3/selection/Selection;
invokevirtual org.apache.cassandra.cql3.selection.Selection.isWildcard:()Z
ifeq 2
1: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
invokestatic org.apache.cassandra.db.filter.ColumnFilter.all:(Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/db/filter/ColumnFilter;
areturn
2: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
invokestatic org.apache.cassandra.db.filter.ColumnFilter.allColumnsBuilder:(Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/db/filter/ColumnFilter$Builder;
astore 1
start local 1 3: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.selection:Lorg/apache/cassandra/cql3/selection/Selection;
invokevirtual org.apache.cassandra.cql3.selection.Selection.getColumns:()Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 3
goto 7
StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.db.filter.ColumnFilter$Builder top java.util.Iterator
StackMap stack:
4: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.config.ColumnDefinition
astore 2
start local 2 5: aload 2
invokevirtual org.apache.cassandra.config.ColumnDefinition.isPrimaryKeyColumn:()Z
ifne 7
6: aload 1
aload 2
invokevirtual org.apache.cassandra.db.filter.ColumnFilter$Builder.add:(Lorg/apache/cassandra/config/ColumnDefinition;)Lorg/apache/cassandra/db/filter/ColumnFilter$Builder;
pop
end local 2 7: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
8: aload 1
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
iconst_1
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.nonPKRestrictedColumns:(Z)Ljava/util/Set;
invokevirtual org.apache.cassandra.db.filter.ColumnFilter$Builder.addAll:(Ljava/lang/Iterable;)Lorg/apache/cassandra/db/filter/ColumnFilter$Builder;
pop
9: aload 1
invokevirtual org.apache.cassandra.db.filter.ColumnFilter$Builder.build:()Lorg/apache/cassandra/db/filter/ColumnFilter;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
3 10 1 builder Lorg/apache/cassandra/db/filter/ColumnFilter$Builder;
5 7 2 def Lorg/apache/cassandra/config/ColumnDefinition;
public org.apache.cassandra.db.filter.ColumnFilter queriedColumns();
descriptor: ()Lorg/apache/cassandra/db/filter/ColumnFilter;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.queriedColumns:Lorg/apache/cassandra/db/filter/ColumnFilter;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
static org.apache.cassandra.cql3.statements.SelectStatement forSelection(org.apache.cassandra.config.CFMetaData, org.apache.cassandra.cql3.selection.Selection);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/cql3/selection/Selection;)Lorg/apache/cassandra/cql3/statements/SelectStatement;
flags: (0x0008) ACC_STATIC
Code:
stack=12, locals=2, args_size=2
start local 0 start local 1 0: new org.apache.cassandra.cql3.statements.SelectStatement
dup
aload 0
1: iconst_0
2: getstatic org.apache.cassandra.cql3.statements.SelectStatement.defaultParameters:Lorg/apache/cassandra/cql3/statements/SelectStatement$Parameters;
3: aload 1
4: getstatic org.apache.cassandra.cql3.statements.StatementType.SELECT:Lorg/apache/cassandra/cql3/statements/StatementType;
aload 0
invokestatic org.apache.cassandra.cql3.restrictions.StatementRestrictions.empty:(Lorg/apache/cassandra/cql3/statements/StatementType;Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
5: iconst_0
6: aconst_null
7: aconst_null
8: aconst_null
9: aconst_null
10: invokespecial org.apache.cassandra.cql3.statements.SelectStatement.<init>:(Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/cql3/statements/SelectStatement$Parameters;Lorg/apache/cassandra/cql3/selection/Selection;Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;ZLorg/apache/cassandra/db/aggregation/AggregationSpecification;Ljava/util/Comparator;Lorg/apache/cassandra/cql3/Term;Lorg/apache/cassandra/cql3/Term;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 cfm Lorg/apache/cassandra/config/CFMetaData;
0 11 1 selection Lorg/apache/cassandra/cql3/selection/Selection;
MethodParameters:
Name Flags
cfm
selection
public org.apache.cassandra.cql3.ResultSet$ResultMetadata getResultMetadata();
descriptor: ()Lorg/apache/cassandra/cql3/ResultSet$ResultMetadata;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.selection:Lorg/apache/cassandra/cql3/selection/Selection;
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.parameters:Lorg/apache/cassandra/cql3/statements/SelectStatement$Parameters;
getfield org.apache.cassandra.cql3.statements.SelectStatement$Parameters.isJson:Z
invokevirtual org.apache.cassandra.cql3.selection.Selection.getResultMetadata:(Z)Lorg/apache/cassandra/cql3/ResultSet$ResultMetadata;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
public int getBoundTerms();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.boundTerms:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
public void checkAccess(org.apache.cassandra.service.ClientState);
descriptor: (Lorg/apache/cassandra/service/ClientState;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.isView:()Z
ifeq 5
1: aload 0
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.keyspace:()Ljava/lang/String;
aload 0
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.columnFamily:()Ljava/lang/String;
invokestatic org.apache.cassandra.db.view.View.findBaseTable:(Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
astore 2
start local 2 2: aload 2
ifnull 6
3: aload 1
aload 2
getstatic org.apache.cassandra.auth.Permission.SELECT:Lorg/apache/cassandra/auth/Permission;
invokevirtual org.apache.cassandra.service.ClientState.hasColumnFamilyAccess:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/auth/Permission;)V
end local 2 4: goto 6
5: StackMap locals:
StackMap stack:
aload 1
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
getstatic org.apache.cassandra.auth.Permission.SELECT:Lorg/apache/cassandra/auth/Permission;
invokevirtual org.apache.cassandra.service.ClientState.hasColumnFamilyAccess:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/auth/Permission;)V
6: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getFunctions:()Ljava/lang/Iterable;
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 3
goto 9
StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.service.ClientState top java.util.Iterator
StackMap stack:
7: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.cql3.functions.Function
astore 2
start local 2 8: aload 1
getstatic org.apache.cassandra.auth.Permission.EXECUTE:Lorg/apache/cassandra/auth/Permission;
aload 2
invokevirtual org.apache.cassandra.service.ClientState.ensureHasPermission:(Lorg/apache/cassandra/auth/Permission;Lorg/apache/cassandra/cql3/functions/Function;)V
end local 2 9: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 7
10: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 11 1 state Lorg/apache/cassandra/service/ClientState;
2 4 2 baseTable Lorg/apache/cassandra/config/CFMetaData;
8 9 2 function Lorg/apache/cassandra/cql3/functions/Function;
Exceptions:
throws org.apache.cassandra.exceptions.InvalidRequestException, org.apache.cassandra.exceptions.UnauthorizedException
MethodParameters:
Name Flags
state
public void validate(org.apache.cassandra.service.ClientState);
descriptor: (Lorg/apache/cassandra/service/ClientState;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=0, locals=2, args_size=2
start local 0 start local 1 0: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 1 1 state Lorg/apache/cassandra/service/ClientState;
Exceptions:
throws org.apache.cassandra.exceptions.InvalidRequestException
MethodParameters:
Name Flags
state
public org.apache.cassandra.transport.messages.ResultMessage$Rows execute(org.apache.cassandra.service.QueryState, org.apache.cassandra.cql3.QueryOptions, long);
descriptor: (Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/QueryOptions;J)Lorg/apache/cassandra/transport/messages/ResultMessage$Rows;
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=12, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 2
invokevirtual org.apache.cassandra.cql3.QueryOptions.getConsistency:()Lorg/apache/cassandra/db/ConsistencyLevel;
astore 5
start local 5 1: aload 5
ldc "Invalid empty consistency level"
iconst_0
anewarray java.lang.Object
invokestatic org.apache.cassandra.cql3.statements.RequestValidations.checkNotNull:(Ljava/lang/Object;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 5
aload 0
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.keyspace:()Ljava/lang/String;
invokevirtual org.apache.cassandra.db.ConsistencyLevel.validateForRead:(Ljava/lang/String;)V
3: invokestatic org.apache.cassandra.utils.FBUtilities.nowInSeconds:()I
istore 6
start local 6 4: aload 0
aload 2
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getLimit:(Lorg/apache/cassandra/cql3/QueryOptions;)I
istore 7
start local 7 5: aload 0
aload 2
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getPerPartitionLimit:(Lorg/apache/cassandra/cql3/QueryOptions;)I
istore 8
start local 8 6: aload 2
invokevirtual org.apache.cassandra.cql3.QueryOptions.getPageSize:()I
istore 9
start local 9 7: aload 0
aload 2
iload 6
iload 7
iload 8
iload 9
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getQuery:(Lorg/apache/cassandra/cql3/QueryOptions;IIII)Lorg/apache/cassandra/db/ReadQuery;
astore 10
start local 10 8: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.aggregationSpec:Lorg/apache/cassandra/db/aggregation/AggregationSpecification;
ifnonnull 10
iload 9
ifle 9
aload 10
invokeinterface org.apache.cassandra.db.ReadQuery.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
invokevirtual org.apache.cassandra.db.filter.DataLimits.count:()I
iload 9
if_icmpgt 10
9: StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.service.QueryState org.apache.cassandra.cql3.QueryOptions long org.apache.cassandra.db.ConsistencyLevel int int int int org.apache.cassandra.db.ReadQuery
StackMap stack:
aload 0
aload 10
aload 2
aload 1
iload 6
iload 7
lload 3
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.execute:(Lorg/apache/cassandra/db/ReadQuery;Lorg/apache/cassandra/cql3/QueryOptions;Lorg/apache/cassandra/service/QueryState;IIJ)Lorg/apache/cassandra/transport/messages/ResultMessage$Rows;
areturn
10: StackMap locals:
StackMap stack:
aload 0
aload 10
aload 2
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getPager:(Lorg/apache/cassandra/db/ReadQuery;Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/service/pager/QueryPager;
astore 11
start local 11 11: aload 0
aload 11
aload 5
aload 1
invokevirtual org.apache.cassandra.service.QueryState.getClientState:()Lorg/apache/cassandra/service/ClientState;
invokestatic org.apache.cassandra.cql3.statements.SelectStatement$Pager.forDistributedQuery:(Lorg/apache/cassandra/service/pager/QueryPager;Lorg/apache/cassandra/db/ConsistencyLevel;Lorg/apache/cassandra/service/ClientState;)Lorg/apache/cassandra/cql3/statements/SelectStatement$Pager;
aload 2
iload 9
iload 6
iload 7
lload 3
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.execute:(Lorg/apache/cassandra/cql3/statements/SelectStatement$Pager;Lorg/apache/cassandra/cql3/QueryOptions;IIIJ)Lorg/apache/cassandra/transport/messages/ResultMessage$Rows;
areturn
end local 11 end local 10 end local 9 end local 8 end local 7 end local 6 end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 12 1 state Lorg/apache/cassandra/service/QueryState;
0 12 2 options Lorg/apache/cassandra/cql3/QueryOptions;
0 12 3 queryStartNanoTime J
1 12 5 cl Lorg/apache/cassandra/db/ConsistencyLevel;
4 12 6 nowInSec I
5 12 7 userLimit I
6 12 8 userPerPartitionLimit I
7 12 9 pageSize I
8 12 10 query Lorg/apache/cassandra/db/ReadQuery;
11 12 11 pager Lorg/apache/cassandra/service/pager/QueryPager;
Exceptions:
throws org.apache.cassandra.exceptions.RequestExecutionException, org.apache.cassandra.exceptions.RequestValidationException
MethodParameters:
Name Flags
state
options
queryStartNanoTime
public org.apache.cassandra.db.ReadQuery getQuery(org.apache.cassandra.cql3.QueryOptions, int);
descriptor: (Lorg/apache/cassandra/cql3/QueryOptions;I)Lorg/apache/cassandra/db/ReadQuery;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
iload 2
aload 0
aload 1
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getLimit:(Lorg/apache/cassandra/cql3/QueryOptions;)I
aload 0
aload 1
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getPerPartitionLimit:(Lorg/apache/cassandra/cql3/QueryOptions;)I
aload 1
invokevirtual org.apache.cassandra.cql3.QueryOptions.getPageSize:()I
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getQuery:(Lorg/apache/cassandra/cql3/QueryOptions;IIII)Lorg/apache/cassandra/db/ReadQuery;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 1 1 options Lorg/apache/cassandra/cql3/QueryOptions;
0 1 2 nowInSec I
Exceptions:
throws org.apache.cassandra.exceptions.RequestValidationException
MethodParameters:
Name Flags
options
nowInSec
public org.apache.cassandra.db.ReadQuery getQuery(org.apache.cassandra.cql3.QueryOptions, int, int, int, int);
descriptor: (Lorg/apache/cassandra/cql3/QueryOptions;IIII)Lorg/apache/cassandra/db/ReadQuery;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=8, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.isKeyRange:()Z
ifne 1
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.usesSecondaryIndexing:()Z
ifne 1
iconst_0
goto 2
StackMap locals:
StackMap stack:
1: iconst_1
StackMap locals:
StackMap stack: int
2: istore 6
start local 6 3: aload 0
iload 3
iload 4
iload 5
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getDataLimits:(III)Lorg/apache/cassandra/db/filter/DataLimits;
astore 7
start local 7 4: iload 6
ifeq 6
5: aload 0
aload 1
aload 7
iload 2
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getRangeCommand:(Lorg/apache/cassandra/cql3/QueryOptions;Lorg/apache/cassandra/db/filter/DataLimits;I)Lorg/apache/cassandra/db/ReadQuery;
areturn
6: StackMap locals: int org.apache.cassandra.db.filter.DataLimits
StackMap stack:
aload 0
aload 1
aload 7
iload 2
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getSliceCommands:(Lorg/apache/cassandra/cql3/QueryOptions;Lorg/apache/cassandra/db/filter/DataLimits;I)Lorg/apache/cassandra/db/ReadQuery;
areturn
end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 7 1 options Lorg/apache/cassandra/cql3/QueryOptions;
0 7 2 nowInSec I
0 7 3 userLimit I
0 7 4 perPartitionLimit I
0 7 5 pageSize I
3 7 6 isPartitionRangeQuery Z
4 7 7 limit Lorg/apache/cassandra/db/filter/DataLimits;
MethodParameters:
Name Flags
options
nowInSec
userLimit
perPartitionLimit
pageSize
private org.apache.cassandra.transport.messages.ResultMessage$Rows execute(org.apache.cassandra.db.ReadQuery, org.apache.cassandra.cql3.QueryOptions, org.apache.cassandra.service.QueryState, int, int, long);
descriptor: (Lorg/apache/cassandra/db/ReadQuery;Lorg/apache/cassandra/cql3/QueryOptions;Lorg/apache/cassandra/service/QueryState;IIJ)Lorg/apache/cassandra/transport/messages/ResultMessage$Rows;
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=11, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aconst_null
astore 8
aconst_null
astore 9
1: aload 1
aload 2
invokevirtual org.apache.cassandra.cql3.QueryOptions.getConsistency:()Lorg/apache/cassandra/db/ConsistencyLevel;
aload 3
invokevirtual org.apache.cassandra.service.QueryState.getClientState:()Lorg/apache/cassandra/service/ClientState;
lload 6
invokeinterface org.apache.cassandra.db.ReadQuery.execute:(Lorg/apache/cassandra/db/ConsistencyLevel;Lorg/apache/cassandra/service/ClientState;J)Lorg/apache/cassandra/db/partitions/PartitionIterator;
astore 10
start local 10 2: aload 0
aload 10
aload 2
iload 4
iload 5
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.processResults:(Lorg/apache/cassandra/db/partitions/PartitionIterator;Lorg/apache/cassandra/cql3/QueryOptions;II)Lorg/apache/cassandra/transport/messages/ResultMessage$Rows;
3: aload 10
ifnull 4
aload 10
invokeinterface org.apache.cassandra.db.partitions.PartitionIterator.close:()V
4: StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.db.ReadQuery org.apache.cassandra.cql3.QueryOptions org.apache.cassandra.service.QueryState int int long java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.partitions.PartitionIterator
StackMap stack: org.apache.cassandra.transport.messages.ResultMessage$Rows
areturn
StackMap locals:
StackMap stack: java.lang.Throwable
5: astore 8
6: aload 10
ifnull 7
aload 10
invokeinterface org.apache.cassandra.db.partitions.PartitionIterator.close:()V
end local 10 StackMap locals:
StackMap stack:
7: aload 8
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
8: astore 9
aload 8
ifnonnull 9
aload 9
astore 8
goto 10
StackMap locals:
StackMap stack:
9: aload 8
aload 9
if_acmpeq 10
aload 8
aload 9
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
10: aload 8
athrow
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 11 1 query Lorg/apache/cassandra/db/ReadQuery;
0 11 2 options Lorg/apache/cassandra/cql3/QueryOptions;
0 11 3 state Lorg/apache/cassandra/service/QueryState;
0 11 4 nowInSec I
0 11 5 userLimit I
0 11 6 queryStartNanoTime J
2 7 10 data Lorg/apache/cassandra/db/partitions/PartitionIterator;
Exception table:
from to target type
2 3 5 any
1 4 8 any
5 8 8 any
Exceptions:
throws org.apache.cassandra.exceptions.RequestValidationException, org.apache.cassandra.exceptions.RequestExecutionException
MethodParameters:
Name Flags
query
options
state
nowInSec
userLimit
queryStartNanoTime
private org.apache.cassandra.transport.messages.ResultMessage$Rows execute(org.apache.cassandra.cql3.statements.SelectStatement$Pager, org.apache.cassandra.cql3.QueryOptions, int, int, int, long);
descriptor: (Lorg/apache/cassandra/cql3/statements/SelectStatement$Pager;Lorg/apache/cassandra/cql3/QueryOptions;IIIJ)Lorg/apache/cassandra/transport/messages/ResultMessage$Rows;
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=12, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.aggregationSpec:Lorg/apache/cassandra/db/aggregation/AggregationSpecification;
ifnull 6
1: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.hasPartitionKeyRestrictions:()Z
ifne 4
2: aload 0
ldc "Aggregation query used without partition key"
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.warn:(Ljava/lang/String;)V
3: goto 6
4: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.keyIsInRelation:()Z
ifeq 6
5: aload 0
ldc "Aggregation query used on multiple partition keys (IN restriction)"
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.warn:(Ljava/lang/String;)V
6: StackMap locals:
StackMap stack:
iload 3
ifle 7
aload 0
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.needsPostQueryOrdering:()Z
ifeq 7
iconst_1
goto 8
StackMap locals:
StackMap stack:
7: iconst_0
8: StackMap locals:
StackMap stack: int
ldc "Cannot page queries with both ORDER BY and a IN restriction on the partition key; you must either remove the ORDER BY or the IN and sort client side, or disable paging for this query"
9: invokestatic org.apache.cassandra.cql3.statements.RequestValidations.checkFalse:(ZLjava/lang/String;)V
10: aconst_null
astore 9
aconst_null
astore 10
11: aload 1
iload 3
lload 6
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement$Pager.fetchPage:(IJ)Lorg/apache/cassandra/db/partitions/PartitionIterator;
astore 11
start local 11 12: aload 0
aload 11
aload 2
iload 4
iload 5
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.processResults:(Lorg/apache/cassandra/db/partitions/PartitionIterator;Lorg/apache/cassandra/cql3/QueryOptions;II)Lorg/apache/cassandra/transport/messages/ResultMessage$Rows;
astore 8
start local 8 13: aload 11
ifnull 19
aload 11
invokeinterface org.apache.cassandra.db.partitions.PartitionIterator.close:()V
goto 19
end local 8 StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.cql3.statements.SelectStatement$Pager org.apache.cassandra.cql3.QueryOptions int int int long top java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.partitions.PartitionIterator
StackMap stack: java.lang.Throwable
14: astore 9
aload 11
ifnull 15
aload 11
invokeinterface org.apache.cassandra.db.partitions.PartitionIterator.close:()V
end local 11 StackMap locals:
StackMap stack:
15: aload 9
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
16: astore 10
aload 9
ifnonnull 17
aload 10
astore 9
goto 18
StackMap locals:
StackMap stack:
17: aload 9
aload 10
if_acmpeq 18
aload 9
aload 10
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
18: aload 9
athrow
start local 8 19: StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.cql3.statements.SelectStatement$Pager org.apache.cassandra.cql3.QueryOptions int int int long org.apache.cassandra.transport.messages.ResultMessage$Rows
StackMap stack:
aload 1
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement$Pager.isExhausted:()Z
ifne 21
20: aload 8
getfield org.apache.cassandra.transport.messages.ResultMessage$Rows.result:Lorg/apache/cassandra/cql3/ResultSet;
getfield org.apache.cassandra.cql3.ResultSet.metadata:Lorg/apache/cassandra/cql3/ResultSet$ResultMetadata;
aload 1
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement$Pager.state:()Lorg/apache/cassandra/service/pager/PagingState;
invokevirtual org.apache.cassandra.cql3.ResultSet$ResultMetadata.setHasMorePages:(Lorg/apache/cassandra/service/pager/PagingState;)V
21: StackMap locals:
StackMap stack:
aload 8
areturn
end local 8 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 22 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 22 1 pager Lorg/apache/cassandra/cql3/statements/SelectStatement$Pager;
0 22 2 options Lorg/apache/cassandra/cql3/QueryOptions;
0 22 3 pageSize I
0 22 4 nowInSec I
0 22 5 userLimit I
0 22 6 queryStartNanoTime J
13 14 8 msg Lorg/apache/cassandra/transport/messages/ResultMessage$Rows;
19 22 8 msg Lorg/apache/cassandra/transport/messages/ResultMessage$Rows;
12 15 11 page Lorg/apache/cassandra/db/partitions/PartitionIterator;
Exception table:
from to target type
12 13 14 any
11 16 16 any
Exceptions:
throws org.apache.cassandra.exceptions.RequestValidationException, org.apache.cassandra.exceptions.RequestExecutionException
MethodParameters:
Name Flags
pager
options
pageSize
nowInSec
userLimit
queryStartNanoTime
private void warn(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.cql3.statements.SelectStatement.logger:Lorg/slf4j/Logger;
aload 1
invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;)V
1: getstatic org.apache.cassandra.service.ClientWarn.instance:Lorg/apache/cassandra/service/ClientWarn;
aload 1
invokevirtual org.apache.cassandra.service.ClientWarn.warn:(Ljava/lang/String;)V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 3 1 msg Ljava/lang/String;
MethodParameters:
Name Flags
msg
private org.apache.cassandra.transport.messages.ResultMessage$Rows processResults(org.apache.cassandra.db.partitions.PartitionIterator, org.apache.cassandra.cql3.QueryOptions, int, int);
descriptor: (Lorg/apache/cassandra/db/partitions/PartitionIterator;Lorg/apache/cassandra/cql3/QueryOptions;II)Lorg/apache/cassandra/transport/messages/ResultMessage$Rows;
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
iload 3
iload 4
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.process:(Lorg/apache/cassandra/db/partitions/PartitionIterator;Lorg/apache/cassandra/cql3/QueryOptions;II)Lorg/apache/cassandra/cql3/ResultSet;
astore 5
start local 5 1: new org.apache.cassandra.transport.messages.ResultMessage$Rows
dup
aload 5
invokespecial org.apache.cassandra.transport.messages.ResultMessage$Rows.<init>:(Lorg/apache/cassandra/cql3/ResultSet;)V
areturn
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 2 1 partitions Lorg/apache/cassandra/db/partitions/PartitionIterator;
0 2 2 options Lorg/apache/cassandra/cql3/QueryOptions;
0 2 3 nowInSec I
0 2 4 userLimit I
1 2 5 rset Lorg/apache/cassandra/cql3/ResultSet;
Exceptions:
throws org.apache.cassandra.exceptions.RequestValidationException
MethodParameters:
Name Flags
partitions
options
nowInSec
userLimit
public org.apache.cassandra.transport.messages.ResultMessage$Rows executeInternal(org.apache.cassandra.service.QueryState, org.apache.cassandra.cql3.QueryOptions);
descriptor: (Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/transport/messages/ResultMessage$Rows;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
invokestatic org.apache.cassandra.utils.FBUtilities.nowInSeconds:()I
invokestatic java.lang.System.nanoTime:()J
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.executeInternal:(Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/QueryOptions;IJ)Lorg/apache/cassandra/transport/messages/ResultMessage$Rows;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 1 1 state Lorg/apache/cassandra/service/QueryState;
0 1 2 options Lorg/apache/cassandra/cql3/QueryOptions;
Exceptions:
throws org.apache.cassandra.exceptions.RequestExecutionException, org.apache.cassandra.exceptions.RequestValidationException
MethodParameters:
Name Flags
state
options
public org.apache.cassandra.transport.messages.ResultMessage$Rows executeInternal(org.apache.cassandra.service.QueryState, org.apache.cassandra.cql3.QueryOptions, int, long);
descriptor: (Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/QueryOptions;IJ)Lorg/apache/cassandra/transport/messages/ResultMessage$Rows;
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=16, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 2
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getLimit:(Lorg/apache/cassandra/cql3/QueryOptions;)I
istore 6
start local 6 1: aload 0
aload 2
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getPerPartitionLimit:(Lorg/apache/cassandra/cql3/QueryOptions;)I
istore 7
start local 7 2: aload 2
invokevirtual org.apache.cassandra.cql3.QueryOptions.getPageSize:()I
istore 8
start local 8 3: aload 0
aload 2
iload 3
iload 6
iload 7
iload 8
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getQuery:(Lorg/apache/cassandra/cql3/QueryOptions;IIII)Lorg/apache/cassandra/db/ReadQuery;
astore 9
start local 9 4: aconst_null
astore 10
aconst_null
astore 11
5: aload 9
invokeinterface org.apache.cassandra.db.ReadQuery.executionController:()Lorg/apache/cassandra/db/ReadExecutionController;
astore 12
start local 12 6: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.aggregationSpec:Lorg/apache/cassandra/db/aggregation/AggregationSpecification;
ifnonnull 19
iload 8
ifle 7
aload 9
invokeinterface org.apache.cassandra.db.ReadQuery.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
invokevirtual org.apache.cassandra.db.filter.DataLimits.count:()I
iload 8
if_icmpgt 19
7: StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.service.QueryState org.apache.cassandra.cql3.QueryOptions int long int int int org.apache.cassandra.db.ReadQuery java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.ReadExecutionController
StackMap stack:
aconst_null
astore 13
aconst_null
astore 14
8: aload 9
aload 12
invokeinterface org.apache.cassandra.db.ReadQuery.executeInternal:(Lorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/db/partitions/PartitionIterator;
astore 15
start local 15 9: aload 0
aload 15
aload 2
iload 3
iload 6
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.processResults:(Lorg/apache/cassandra/db/partitions/PartitionIterator;Lorg/apache/cassandra/cql3/QueryOptions;II)Lorg/apache/cassandra/transport/messages/ResultMessage$Rows;
10: aload 15
ifnull 11
aload 15
invokeinterface org.apache.cassandra.db.partitions.PartitionIterator.close:()V
11: StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.service.QueryState org.apache.cassandra.cql3.QueryOptions int long int int int org.apache.cassandra.db.ReadQuery java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.ReadExecutionController java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.partitions.PartitionIterator
StackMap stack: org.apache.cassandra.transport.messages.ResultMessage$Rows
aload 12
ifnull 12
aload 12
invokevirtual org.apache.cassandra.db.ReadExecutionController.close:()V
12: StackMap locals:
StackMap stack: org.apache.cassandra.transport.messages.ResultMessage$Rows
areturn
StackMap locals:
StackMap stack: java.lang.Throwable
13: astore 13
14: aload 15
ifnull 15
aload 15
invokeinterface org.apache.cassandra.db.partitions.PartitionIterator.close:()V
end local 15 StackMap locals:
StackMap stack:
15: aload 13
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
16: astore 14
aload 13
ifnonnull 17
aload 14
astore 13
goto 18
StackMap locals:
StackMap stack:
17: aload 13
aload 14
if_acmpeq 18
aload 13
aload 14
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
18: aload 13
athrow
19: StackMap locals:
StackMap stack:
aload 0
aload 9
aload 2
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getPager:(Lorg/apache/cassandra/db/ReadQuery;Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/service/pager/QueryPager;
astore 13
start local 13 20: aload 0
aload 13
aload 12
invokestatic org.apache.cassandra.cql3.statements.SelectStatement$Pager.forInternalQuery:(Lorg/apache/cassandra/service/pager/QueryPager;Lorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/cql3/statements/SelectStatement$Pager;
aload 2
iload 8
iload 3
iload 6
lload 4
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.execute:(Lorg/apache/cassandra/cql3/statements/SelectStatement$Pager;Lorg/apache/cassandra/cql3/QueryOptions;IIIJ)Lorg/apache/cassandra/transport/messages/ResultMessage$Rows;
21: aload 12
ifnull 22
aload 12
invokevirtual org.apache.cassandra.db.ReadExecutionController.close:()V
22: StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.service.QueryState org.apache.cassandra.cql3.QueryOptions int long int int int org.apache.cassandra.db.ReadQuery java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.ReadExecutionController org.apache.cassandra.service.pager.QueryPager
StackMap stack: org.apache.cassandra.transport.messages.ResultMessage$Rows
areturn
end local 13 StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.service.QueryState org.apache.cassandra.cql3.QueryOptions int long int int int org.apache.cassandra.db.ReadQuery java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.ReadExecutionController
StackMap stack: java.lang.Throwable
23: astore 10
24: aload 12
ifnull 25
aload 12
invokevirtual org.apache.cassandra.db.ReadExecutionController.close:()V
end local 12 StackMap locals:
StackMap stack:
25: aload 10
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
26: astore 11
aload 10
ifnonnull 27
aload 11
astore 10
goto 28
StackMap locals:
StackMap stack:
27: aload 10
aload 11
if_acmpeq 28
aload 10
aload 11
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
28: aload 10
athrow
end local 9 end local 8 end local 7 end local 6 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 29 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 29 1 state Lorg/apache/cassandra/service/QueryState;
0 29 2 options Lorg/apache/cassandra/cql3/QueryOptions;
0 29 3 nowInSec I
0 29 4 queryStartNanoTime J
1 29 6 userLimit I
2 29 7 userPerPartitionLimit I
3 29 8 pageSize I
4 29 9 query Lorg/apache/cassandra/db/ReadQuery;
6 25 12 executionController Lorg/apache/cassandra/db/ReadExecutionController;
9 15 15 data Lorg/apache/cassandra/db/partitions/PartitionIterator;
20 23 13 pager Lorg/apache/cassandra/service/pager/QueryPager;
Exception table:
from to target type
9 10 13 any
8 11 16 any
13 16 16 any
6 11 23 any
13 21 23 any
5 12 26 any
13 22 26 any
23 26 26 any
Exceptions:
throws org.apache.cassandra.exceptions.RequestExecutionException, org.apache.cassandra.exceptions.RequestValidationException
MethodParameters:
Name Flags
state
options
nowInSec
queryStartNanoTime
private org.apache.cassandra.service.pager.QueryPager getPager(org.apache.cassandra.db.ReadQuery, org.apache.cassandra.cql3.QueryOptions);
descriptor: (Lorg/apache/cassandra/db/ReadQuery;Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/service/pager/QueryPager;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 1
aload 2
invokevirtual org.apache.cassandra.cql3.QueryOptions.getPagingState:()Lorg/apache/cassandra/service/pager/PagingState;
aload 2
invokevirtual org.apache.cassandra.cql3.QueryOptions.getProtocolVersion:()Lorg/apache/cassandra/transport/ProtocolVersion;
invokeinterface org.apache.cassandra.db.ReadQuery.getPager:(Lorg/apache/cassandra/service/pager/PagingState;Lorg/apache/cassandra/transport/ProtocolVersion;)Lorg/apache/cassandra/service/pager/QueryPager;
astore 3
start local 3 1: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.aggregationSpec:Lorg/apache/cassandra/db/aggregation/AggregationSpecification;
ifnull 2
aload 1
getstatic org.apache.cassandra.db.ReadQuery.EMPTY:Lorg/apache/cassandra/db/ReadQuery;
if_acmpne 3
2: StackMap locals: org.apache.cassandra.service.pager.QueryPager
StackMap stack:
aload 3
areturn
3: StackMap locals:
StackMap stack:
new org.apache.cassandra.service.pager.AggregationQueryPager
dup
aload 3
aload 1
invokeinterface org.apache.cassandra.db.ReadQuery.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
invokespecial org.apache.cassandra.service.pager.AggregationQueryPager.<init>:(Lorg/apache/cassandra/service/pager/QueryPager;Lorg/apache/cassandra/db/filter/DataLimits;)V
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 4 1 query Lorg/apache/cassandra/db/ReadQuery;
0 4 2 options Lorg/apache/cassandra/cql3/QueryOptions;
1 4 3 pager Lorg/apache/cassandra/service/pager/QueryPager;
MethodParameters:
Name Flags
query
options
public org.apache.cassandra.cql3.ResultSet process(org.apache.cassandra.db.partitions.PartitionIterator, int);
descriptor: (Lorg/apache/cassandra/db/partitions/PartitionIterator;I)Lorg/apache/cassandra/cql3/ResultSet;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
getstatic org.apache.cassandra.cql3.QueryOptions.DEFAULT:Lorg/apache/cassandra/cql3/QueryOptions;
iload 2
aload 0
getstatic org.apache.cassandra.cql3.QueryOptions.DEFAULT:Lorg/apache/cassandra/cql3/QueryOptions;
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getLimit:(Lorg/apache/cassandra/cql3/QueryOptions;)I
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.process:(Lorg/apache/cassandra/db/partitions/PartitionIterator;Lorg/apache/cassandra/cql3/QueryOptions;II)Lorg/apache/cassandra/cql3/ResultSet;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 1 1 partitions Lorg/apache/cassandra/db/partitions/PartitionIterator;
0 1 2 nowInSec I
Exceptions:
throws org.apache.cassandra.exceptions.InvalidRequestException
MethodParameters:
Name Flags
partitions
nowInSec
public java.lang.String keyspace();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.ksName:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
public java.lang.String columnFamily();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfName:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
public org.apache.cassandra.cql3.selection.Selection getSelection();
descriptor: ()Lorg/apache/cassandra/cql3/selection/Selection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.selection:Lorg/apache/cassandra/cql3/selection/Selection;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
public org.apache.cassandra.cql3.restrictions.StatementRestrictions getRestrictions();
descriptor: ()Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
private org.apache.cassandra.db.ReadQuery getSliceCommands(org.apache.cassandra.cql3.QueryOptions, org.apache.cassandra.db.filter.DataLimits, int);
descriptor: (Lorg/apache/cassandra/cql3/QueryOptions;Lorg/apache/cassandra/db/filter/DataLimits;I)Lorg/apache/cassandra/db/ReadQuery;
flags: (0x0002) ACC_PRIVATE
Code:
stack=8, locals=12, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
aload 1
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.getPartitionKeys:(Lorg/apache/cassandra/cql3/QueryOptions;)Ljava/util/List;
astore 4
start local 4 1: aload 4
invokeinterface java.util.Collection.isEmpty:()Z
ifeq 3
2: getstatic org.apache.cassandra.db.ReadQuery.EMPTY:Lorg/apache/cassandra/db/ReadQuery;
areturn
3: StackMap locals: java.util.Collection
StackMap stack:
aload 0
aload 1
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.makeClusteringIndexFilter:(Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
astore 5
start local 5 4: aload 5
ifnonnull 6
5: getstatic org.apache.cassandra.db.ReadQuery.EMPTY:Lorg/apache/cassandra/db/ReadQuery;
areturn
6: StackMap locals: org.apache.cassandra.db.filter.ClusteringIndexFilter
StackMap stack:
aload 0
aload 1
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getRowFilter:(Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/db/filter/RowFilter;
astore 6
start local 6 7: new java.util.ArrayList
dup
aload 4
invokeinterface java.util.Collection.size:()I
invokespecial java.util.ArrayList.<init>:(I)V
astore 7
start local 7 8: aload 4
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 9
goto 16
StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.cql3.QueryOptions org.apache.cassandra.db.filter.DataLimits int java.util.Collection org.apache.cassandra.db.filter.ClusteringIndexFilter org.apache.cassandra.db.filter.RowFilter java.util.List top java.util.Iterator
StackMap stack:
9: aload 9
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.nio.ByteBuffer
astore 8
start local 8 10: aload 8
invokestatic org.apache.cassandra.cql3.QueryProcessor.validateKey:(Ljava/nio/ByteBuffer;)V
11: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
aload 8
invokestatic org.apache.cassandra.utils.ByteBufferUtil.clone:(Ljava/nio/ByteBuffer;)Ljava/nio/ByteBuffer;
invokevirtual org.apache.cassandra.config.CFMetaData.decorateKey:(Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/db/DecoratedKey;
astore 10
start local 10 12: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.isSuper:()Z
ifeq 13
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.isDense:()Z
ifeq 13
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
aload 1
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.getSuperColumnRestrictions:()Lorg/apache/cassandra/cql3/SuperColumnCompatibility$SuperColumnRestrictions;
invokestatic org.apache.cassandra.cql3.SuperColumnCompatibility.getColumnFilter:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/cql3/QueryOptions;Lorg/apache/cassandra/cql3/SuperColumnCompatibility$SuperColumnRestrictions;)Lorg/apache/cassandra/db/filter/ColumnFilter;
goto 14
StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.cql3.QueryOptions org.apache.cassandra.db.filter.DataLimits int java.util.Collection org.apache.cassandra.db.filter.ClusteringIndexFilter org.apache.cassandra.db.filter.RowFilter java.util.List java.nio.ByteBuffer java.util.Iterator org.apache.cassandra.db.DecoratedKey
StackMap stack:
13: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.queriedColumns:Lorg/apache/cassandra/db/filter/ColumnFilter;
StackMap locals:
StackMap stack: org.apache.cassandra.db.filter.ColumnFilter
14: astore 11
start local 11 15: aload 7
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
iload 3
aload 11
aload 6
aload 2
aload 10
aload 5
invokestatic org.apache.cassandra.db.SinglePartitionReadCommand.create:(Lorg/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;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 11 end local 10 end local 8 16: StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.cql3.QueryOptions org.apache.cassandra.db.filter.DataLimits int java.util.Collection org.apache.cassandra.db.filter.ClusteringIndexFilter org.apache.cassandra.db.filter.RowFilter java.util.List top java.util.Iterator
StackMap stack:
aload 9
invokeinterface java.util.Iterator.hasNext:()Z
ifne 9
17: new org.apache.cassandra.db.SinglePartitionReadCommand$Group
dup
aload 7
aload 2
invokespecial org.apache.cassandra.db.SinglePartitionReadCommand$Group.<init>:(Ljava/util/List;Lorg/apache/cassandra/db/filter/DataLimits;)V
areturn
end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 18 1 options Lorg/apache/cassandra/cql3/QueryOptions;
0 18 2 limit Lorg/apache/cassandra/db/filter/DataLimits;
0 18 3 nowInSec I
1 18 4 keys Ljava/util/Collection<Ljava/nio/ByteBuffer;>;
4 18 5 filter Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
7 18 6 rowFilter Lorg/apache/cassandra/db/filter/RowFilter;
8 18 7 commands Ljava/util/List<Lorg/apache/cassandra/db/SinglePartitionReadCommand;>;
10 16 8 key Ljava/nio/ByteBuffer;
12 16 10 dk Lorg/apache/cassandra/db/DecoratedKey;
15 16 11 cf Lorg/apache/cassandra/db/filter/ColumnFilter;
Exceptions:
throws org.apache.cassandra.exceptions.RequestValidationException
MethodParameters:
Name Flags
options
limit
nowInSec
public org.apache.cassandra.db.Slices clusteringIndexFilterAsSlices();
descriptor: ()Lorg/apache/cassandra/db/Slices;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=6, args_size=1
start local 0 0: invokestatic java.util.Collections.emptyList:()Ljava/util/List;
invokestatic org.apache.cassandra.cql3.QueryOptions.forInternalCalls:(Ljava/util/List;)Lorg/apache/cassandra/cql3/QueryOptions;
astore 1
start local 1 1: aload 0
aload 1
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.makeClusteringIndexFilter:(Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
astore 2
start local 2 2: aload 2
instanceof org.apache.cassandra.db.filter.ClusteringIndexSliceFilter
ifeq 4
3: aload 2
checkcast org.apache.cassandra.db.filter.ClusteringIndexSliceFilter
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexSliceFilter.requestedSlices:()Lorg/apache/cassandra/db/Slices;
areturn
4: StackMap locals: org.apache.cassandra.cql3.QueryOptions org.apache.cassandra.db.filter.ClusteringIndexFilter
StackMap stack:
new org.apache.cassandra.db.Slices$Builder
dup
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.comparator:Lorg/apache/cassandra/db/ClusteringComparator;
invokespecial org.apache.cassandra.db.Slices$Builder.<init>:(Lorg/apache/cassandra/db/ClusteringComparator;)V
astore 3
start local 3 5: aload 2
checkcast org.apache.cassandra.db.filter.ClusteringIndexNamesFilter
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexNamesFilter.requestedRows:()Ljava/util/NavigableSet;
invokeinterface java.util.NavigableSet.iterator:()Ljava/util/Iterator;
astore 5
goto 8
StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.cql3.QueryOptions org.apache.cassandra.db.filter.ClusteringIndexFilter org.apache.cassandra.db.Slices$Builder top java.util.Iterator
StackMap stack:
6: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.Clustering
astore 4
start local 4 7: aload 3
aload 4
invokestatic org.apache.cassandra.db.Slice.make:(Lorg/apache/cassandra/db/Clustering;)Lorg/apache/cassandra/db/Slice;
invokevirtual org.apache.cassandra.db.Slices$Builder.add:(Lorg/apache/cassandra/db/Slice;)Lorg/apache/cassandra/db/Slices$Builder;
pop
end local 4 8: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 6
9: aload 3
invokevirtual org.apache.cassandra.db.Slices$Builder.build:()Lorg/apache/cassandra/db/Slices;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
1 10 1 options Lorg/apache/cassandra/cql3/QueryOptions;
2 10 2 filter Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
5 10 3 builder Lorg/apache/cassandra/db/Slices$Builder;
7 8 4 clustering Lorg/apache/cassandra/db/Clustering;
public org.apache.cassandra.db.SinglePartitionReadCommand internalReadForView(org.apache.cassandra.db.DecoratedKey, int);
descriptor: (Lorg/apache/cassandra/db/DecoratedKey;I)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=6, args_size=3
start local 0 start local 1 start local 2 0: invokestatic java.util.Collections.emptyList:()Ljava/util/List;
invokestatic org.apache.cassandra.cql3.QueryOptions.forInternalCalls:(Ljava/util/List;)Lorg/apache/cassandra/cql3/QueryOptions;
astore 3
start local 3 1: aload 0
aload 3
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.makeClusteringIndexFilter:(Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
astore 4
start local 4 2: aload 0
aload 3
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getRowFilter:(Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/db/filter/RowFilter;
astore 5
start local 5 3: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
iload 2
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.queriedColumns:Lorg/apache/cassandra/db/filter/ColumnFilter;
aload 5
getstatic org.apache.cassandra.db.filter.DataLimits.NONE:Lorg/apache/cassandra/db/filter/DataLimits;
aload 1
aload 4
invokestatic org.apache.cassandra.db.SinglePartitionReadCommand.create:(Lorg/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;
areturn
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 4 1 key Lorg/apache/cassandra/db/DecoratedKey;
0 4 2 nowInSec I
1 4 3 options Lorg/apache/cassandra/cql3/QueryOptions;
2 4 4 filter Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
3 4 5 rowFilter Lorg/apache/cassandra/db/filter/RowFilter;
MethodParameters:
Name Flags
key
nowInSec
public org.apache.cassandra.db.filter.RowFilter rowFilterForInternalCalls();
descriptor: ()Lorg/apache/cassandra/db/filter/RowFilter;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokestatic java.util.Collections.emptyList:()Ljava/util/List;
invokestatic org.apache.cassandra.cql3.QueryOptions.forInternalCalls:(Ljava/util/List;)Lorg/apache/cassandra/cql3/QueryOptions;
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getRowFilter:(Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/db/filter/RowFilter;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
private org.apache.cassandra.db.ReadQuery getRangeCommand(org.apache.cassandra.cql3.QueryOptions, org.apache.cassandra.db.filter.DataLimits, int);
descriptor: (Lorg/apache/cassandra/cql3/QueryOptions;Lorg/apache/cassandra/db/filter/DataLimits;I)Lorg/apache/cassandra/db/ReadQuery;
flags: (0x0002) ACC_PRIVATE
Code:
stack=10, locals=8, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.makeClusteringIndexFilter:(Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
astore 4
start local 4 1: aload 4
ifnonnull 3
2: getstatic org.apache.cassandra.db.ReadQuery.EMPTY:Lorg/apache/cassandra/db/ReadQuery;
areturn
3: StackMap locals: org.apache.cassandra.db.filter.ClusteringIndexFilter
StackMap stack:
aload 0
aload 1
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getRowFilter:(Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/db/filter/RowFilter;
astore 5
start local 5 4: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
aload 1
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.getPartitionKeyBounds:(Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/dht/AbstractBounds;
astore 6
start local 6 5: aload 6
ifnonnull 7
6: getstatic org.apache.cassandra.db.ReadQuery.EMPTY:Lorg/apache/cassandra/db/ReadQuery;
areturn
7: StackMap locals: org.apache.cassandra.db.filter.RowFilter org.apache.cassandra.dht.AbstractBounds
StackMap stack:
iconst_0
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
iload 3
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.queriedColumns:Lorg/apache/cassandra/db/filter/ColumnFilter;
aload 5
aload 2
new org.apache.cassandra.db.DataRange
dup
aload 6
aload 4
invokespecial org.apache.cassandra.db.DataRange.<init>:(Lorg/apache/cassandra/dht/AbstractBounds;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;)V
invokestatic org.apache.cassandra.db.PartitionRangeReadCommand.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/DataRange;)Lorg/apache/cassandra/db/PartitionRangeReadCommand;
8: astore 7
start local 7 9: aload 7
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.maybeValidateIndex:()V
10: aload 7
areturn
end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 11 1 options Lorg/apache/cassandra/cql3/QueryOptions;
0 11 2 limit Lorg/apache/cassandra/db/filter/DataLimits;
0 11 3 nowInSec I
1 11 4 clusteringIndexFilter Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
4 11 5 rowFilter Lorg/apache/cassandra/db/filter/RowFilter;
5 11 6 keyBounds Lorg/apache/cassandra/dht/AbstractBounds<Lorg/apache/cassandra/db/PartitionPosition;>;
9 11 7 command Lorg/apache/cassandra/db/PartitionRangeReadCommand;
Exceptions:
throws org.apache.cassandra.exceptions.RequestValidationException
MethodParameters:
Name Flags
options
limit
nowInSec
private org.apache.cassandra.db.filter.ClusteringIndexFilter makeClusteringIndexFilter(org.apache.cassandra.cql3.QueryOptions);
descriptor: (Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.parameters:Lorg/apache/cassandra/cql3/statements/SelectStatement$Parameters;
getfield org.apache.cassandra.cql3.statements.SelectStatement$Parameters.isDistinct:Z
ifeq 2
1: new org.apache.cassandra.db.filter.ClusteringIndexSliceFilter
dup
getstatic org.apache.cassandra.db.Slices.ALL:Lorg/apache/cassandra/db/Slices;
iconst_0
invokespecial org.apache.cassandra.db.filter.ClusteringIndexSliceFilter.<init>:(Lorg/apache/cassandra/db/Slices;Z)V
areturn
2: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.isColumnRange:()Z
ifeq 7
3: aload 0
aload 1
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.makeSlices:(Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/db/Slices;
astore 2
start local 2 4: aload 2
getstatic org.apache.cassandra.db.Slices.NONE:Lorg/apache/cassandra/db/Slices;
if_acmpne 6
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.selection:Lorg/apache/cassandra/cql3/selection/Selection;
invokevirtual org.apache.cassandra.cql3.selection.Selection.containsStaticColumns:()Z
ifne 6
5: aconst_null
areturn
6: StackMap locals: org.apache.cassandra.db.Slices
StackMap stack:
new org.apache.cassandra.db.filter.ClusteringIndexSliceFilter
dup
aload 2
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.isReversed:Z
invokespecial org.apache.cassandra.db.filter.ClusteringIndexSliceFilter.<init>:(Lorg/apache/cassandra/db/Slices;Z)V
areturn
end local 2 7: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getRequestedRows:(Lorg/apache/cassandra/cql3/QueryOptions;)Ljava/util/NavigableSet;
astore 2
start local 2 8: aload 2
invokeinterface java.util.NavigableSet.isEmpty:()Z
ifeq 10
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.queriedColumns:Lorg/apache/cassandra/db/filter/ColumnFilter;
invokevirtual org.apache.cassandra.db.filter.ColumnFilter.fetchedColumns:()Lorg/apache/cassandra/db/PartitionColumns;
getfield org.apache.cassandra.db.PartitionColumns.statics:Lorg/apache/cassandra/db/Columns;
invokevirtual org.apache.cassandra.db.Columns.isEmpty:()Z
ifeq 10
9: aconst_null
areturn
10: StackMap locals: java.util.NavigableSet
StackMap stack:
new org.apache.cassandra.db.filter.ClusteringIndexNamesFilter
dup
aload 2
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.isReversed:Z
invokespecial org.apache.cassandra.db.filter.ClusteringIndexNamesFilter.<init>:(Ljava/util/NavigableSet;Z)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 11 1 options Lorg/apache/cassandra/cql3/QueryOptions;
4 7 2 slices Lorg/apache/cassandra/db/Slices;
8 11 2 clusterings Ljava/util/NavigableSet<Lorg/apache/cassandra/db/Clustering;>;
Exceptions:
throws org.apache.cassandra.exceptions.InvalidRequestException
MethodParameters:
Name Flags
options
private org.apache.cassandra.db.Slices makeSlices(org.apache.cassandra.cql3.QueryOptions);
descriptor: (Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/db/Slices;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=9, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
getstatic org.apache.cassandra.cql3.statements.Bound.START:Lorg/apache/cassandra/cql3/statements/Bound;
aload 1
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.getClusteringColumnsBounds:(Lorg/apache/cassandra/cql3/statements/Bound;Lorg/apache/cassandra/cql3/QueryOptions;)Ljava/util/NavigableSet;
astore 2
start local 2 1: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
getstatic org.apache.cassandra.cql3.statements.Bound.END:Lorg/apache/cassandra/cql3/statements/Bound;
aload 1
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.getClusteringColumnsBounds:(Lorg/apache/cassandra/cql3/statements/Bound;Lorg/apache/cassandra/cql3/QueryOptions;)Ljava/util/NavigableSet;
astore 3
start local 3 2: getstatic org.apache.cassandra.cql3.statements.SelectStatement.$assertionsDisabled:Z
ifne 3
aload 2
invokeinterface java.util.SortedSet.size:()I
aload 3
invokeinterface java.util.SortedSet.size:()I
if_icmpeq 3
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
3: StackMap locals: java.util.SortedSet java.util.SortedSet
StackMap stack:
aload 2
invokeinterface java.util.SortedSet.size:()I
iconst_1
if_icmpne 10
4: aload 2
invokeinterface java.util.SortedSet.first:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.ClusteringBound
astore 4
start local 4 5: aload 3
invokeinterface java.util.SortedSet.first:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.ClusteringBound
astore 5
start local 5 6: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.comparator:Lorg/apache/cassandra/db/ClusteringComparator;
aload 4
aload 5
invokevirtual org.apache.cassandra.db.ClusteringComparator.compare:(Lorg/apache/cassandra/db/ClusteringPrefix;Lorg/apache/cassandra/db/ClusteringPrefix;)I
ifle 8
7: getstatic org.apache.cassandra.db.Slices.NONE:Lorg/apache/cassandra/db/Slices;
goto 9
8: StackMap locals: org.apache.cassandra.db.ClusteringBound org.apache.cassandra.db.ClusteringBound
StackMap stack:
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.comparator:Lorg/apache/cassandra/db/ClusteringComparator;
aload 4
aload 5
invokestatic org.apache.cassandra.db.Slice.make:(Lorg/apache/cassandra/db/ClusteringBound;Lorg/apache/cassandra/db/ClusteringBound;)Lorg/apache/cassandra/db/Slice;
invokestatic org.apache.cassandra.db.Slices.with:(Lorg/apache/cassandra/db/ClusteringComparator;Lorg/apache/cassandra/db/Slice;)Lorg/apache/cassandra/db/Slices;
9: StackMap locals:
StackMap stack: org.apache.cassandra.db.Slices
areturn
end local 5 end local 4 10: StackMap locals:
StackMap stack:
new org.apache.cassandra.db.Slices$Builder
dup
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.comparator:Lorg/apache/cassandra/db/ClusteringComparator;
aload 2
invokeinterface java.util.SortedSet.size:()I
invokespecial org.apache.cassandra.db.Slices$Builder.<init>:(Lorg/apache/cassandra/db/ClusteringComparator;I)V
astore 4
start local 4 11: aload 2
invokeinterface java.util.SortedSet.iterator:()Ljava/util/Iterator;
astore 5
start local 5 12: aload 3
invokeinterface java.util.SortedSet.iterator:()Ljava/util/Iterator;
astore 6
start local 6 13: goto 19
14: StackMap locals: org.apache.cassandra.db.Slices$Builder java.util.Iterator java.util.Iterator
StackMap stack:
aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.ClusteringBound
astore 7
start local 7 15: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.ClusteringBound
astore 8
start local 8 16: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.comparator:Lorg/apache/cassandra/db/ClusteringComparator;
aload 7
aload 8
invokevirtual org.apache.cassandra.db.ClusteringComparator.compare:(Lorg/apache/cassandra/db/ClusteringPrefix;Lorg/apache/cassandra/db/ClusteringPrefix;)I
ifle 18
17: goto 19
18: StackMap locals: org.apache.cassandra.db.ClusteringBound org.apache.cassandra.db.ClusteringBound
StackMap stack:
aload 4
aload 7
aload 8
invokevirtual org.apache.cassandra.db.Slices$Builder.add:(Lorg/apache/cassandra/db/ClusteringBound;Lorg/apache/cassandra/db/ClusteringBound;)Lorg/apache/cassandra/db/Slices$Builder;
pop
end local 8 end local 7 19: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifeq 20
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 14
20: StackMap locals:
StackMap stack:
aload 4
invokevirtual org.apache.cassandra.db.Slices$Builder.build:()Lorg/apache/cassandra/db/Slices;
areturn
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 21 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 21 1 options Lorg/apache/cassandra/cql3/QueryOptions;
1 21 2 startBounds Ljava/util/SortedSet<Lorg/apache/cassandra/db/ClusteringBound;>;
2 21 3 endBounds Ljava/util/SortedSet<Lorg/apache/cassandra/db/ClusteringBound;>;
5 10 4 start Lorg/apache/cassandra/db/ClusteringBound;
6 10 5 end Lorg/apache/cassandra/db/ClusteringBound;
11 21 4 builder Lorg/apache/cassandra/db/Slices$Builder;
12 21 5 startIter Ljava/util/Iterator<Lorg/apache/cassandra/db/ClusteringBound;>;
13 21 6 endIter Ljava/util/Iterator<Lorg/apache/cassandra/db/ClusteringBound;>;
15 19 7 start Lorg/apache/cassandra/db/ClusteringBound;
16 19 8 end Lorg/apache/cassandra/db/ClusteringBound;
Exceptions:
throws org.apache.cassandra.exceptions.InvalidRequestException
MethodParameters:
Name Flags
options
private org.apache.cassandra.db.filter.DataLimits getDataLimits(int, int, int);
descriptor: (III)Lorg/apache/cassandra/db/filter/DataLimits;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 3 0: ldc 2147483647
istore 4
start local 4 1: ldc 2147483647
istore 5
start local 5 2: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.aggregationSpec:Lorg/apache/cassandra/db/aggregation/AggregationSpecification;
getstatic org.apache.cassandra.db.aggregation.AggregationSpecification.AGGREGATE_EVERYTHING:Lorg/apache/cassandra/db/aggregation/AggregationSpecification;
if_acmpeq 6
3: aload 0
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.needsPostQueryOrdering:()Z
ifne 5
4: iload 1
istore 4
5: StackMap locals: int int
StackMap stack:
iload 2
istore 5
6: StackMap locals:
StackMap stack:
iload 3
ifgt 8
7: sipush 10000
istore 3
8: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.aggregationSpec:Lorg/apache/cassandra/db/aggregation/AggregationSpecification;
ifnull 16
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.aggregationSpec:Lorg/apache/cassandra/db/aggregation/AggregationSpecification;
getstatic org.apache.cassandra.db.aggregation.AggregationSpecification.AGGREGATE_EVERYTHING:Lorg/apache/cassandra/db/aggregation/AggregationSpecification;
if_acmpeq 16
9: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.parameters:Lorg/apache/cassandra/cql3/statements/SelectStatement$Parameters;
getfield org.apache.cassandra.cql3.statements.SelectStatement$Parameters.isDistinct:Z
ifeq 11
10: iload 4
invokestatic org.apache.cassandra.db.filter.DataLimits.distinctLimits:(I)Lorg/apache/cassandra/db/filter/DataLimits;
areturn
11: StackMap locals:
StackMap stack:
iload 4
12: iload 5
13: iload 3
14: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.aggregationSpec:Lorg/apache/cassandra/db/aggregation/AggregationSpecification;
15: invokestatic org.apache.cassandra.db.filter.DataLimits.groupByLimits:(IIILorg/apache/cassandra/db/aggregation/AggregationSpecification;)Lorg/apache/cassandra/db/filter/DataLimits;
areturn
16: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.parameters:Lorg/apache/cassandra/cql3/statements/SelectStatement$Parameters;
getfield org.apache.cassandra.cql3.statements.SelectStatement$Parameters.isDistinct:Z
ifeq 20
17: iload 4
ldc 2147483647
if_icmpne 18
getstatic org.apache.cassandra.db.filter.DataLimits.DISTINCT_NONE:Lorg/apache/cassandra/db/filter/DataLimits;
goto 19
StackMap locals:
StackMap stack:
18: iload 4
invokestatic org.apache.cassandra.db.filter.DataLimits.distinctLimits:(I)Lorg/apache/cassandra/db/filter/DataLimits;
StackMap locals:
StackMap stack: org.apache.cassandra.db.filter.DataLimits
19: areturn
20: StackMap locals:
StackMap stack:
iload 4
iload 5
invokestatic org.apache.cassandra.db.filter.DataLimits.cqlLimits:(II)Lorg/apache/cassandra/db/filter/DataLimits;
areturn
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 21 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 21 1 userLimit I
0 21 2 perPartitionLimit I
0 21 3 pageSize I
1 21 4 cqlRowLimit I
2 21 5 cqlPerPartitionLimit I
MethodParameters:
Name Flags
userLimit
perPartitionLimit
pageSize
public int getLimit(org.apache.cassandra.cql3.QueryOptions);
descriptor: (Lorg/apache/cassandra/cql3/QueryOptions;)I
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.limit:Lorg/apache/cassandra/cql3/Term;
aload 1
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getLimit:(Lorg/apache/cassandra/cql3/Term;Lorg/apache/cassandra/cql3/QueryOptions;)I
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 1 1 options Lorg/apache/cassandra/cql3/QueryOptions;
MethodParameters:
Name Flags
options
public int getPerPartitionLimit(org.apache.cassandra.cql3.QueryOptions);
descriptor: (Lorg/apache/cassandra/cql3/QueryOptions;)I
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.perPartitionLimit:Lorg/apache/cassandra/cql3/Term;
aload 1
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.getLimit:(Lorg/apache/cassandra/cql3/Term;Lorg/apache/cassandra/cql3/QueryOptions;)I
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 1 1 options Lorg/apache/cassandra/cql3/QueryOptions;
MethodParameters:
Name Flags
options
private int getLimit(org.apache.cassandra.cql3.Term, org.apache.cassandra.cql3.QueryOptions);
descriptor: (Lorg/apache/cassandra/cql3/Term;Lorg/apache/cassandra/cql3/QueryOptions;)I
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=5, args_size=3
start local 0 start local 1 start local 2 0: ldc 2147483647
istore 3
start local 3 1: aload 1
ifnull 12
2: aload 1
aload 2
invokeinterface org.apache.cassandra.cql3.Term.bindAndGet:(Lorg/apache/cassandra/cql3/QueryOptions;)Ljava/nio/ByteBuffer;
ldc "Invalid null value of limit"
iconst_0
anewarray java.lang.Object
invokestatic org.apache.cassandra.cql3.statements.RequestValidations.checkNotNull:(Ljava/lang/Object;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.nio.ByteBuffer
astore 4
start local 4 3: aload 4
getstatic org.apache.cassandra.utils.ByteBufferUtil.UNSET_BYTE_BUFFER:Ljava/nio/ByteBuffer;
if_acmpeq 12
4: getstatic org.apache.cassandra.db.marshal.Int32Type.instance:Lorg/apache/cassandra/db/marshal/Int32Type;
aload 4
invokevirtual org.apache.cassandra.db.marshal.Int32Type.validate:(Ljava/nio/ByteBuffer;)V
5: getstatic org.apache.cassandra.db.marshal.Int32Type.instance:Lorg/apache/cassandra/db/marshal/Int32Type;
aload 4
invokevirtual org.apache.cassandra.db.marshal.Int32Type.compose:(Ljava/nio/ByteBuffer;)Ljava/lang/Object;
checkcast java.lang.Integer
invokevirtual java.lang.Integer.intValue:()I
istore 3
6: iload 3
ifle 7
iconst_1
goto 8
StackMap locals: int java.nio.ByteBuffer
StackMap stack:
7: iconst_0
StackMap locals:
StackMap stack: int
8: ldc "LIMIT must be strictly positive"
invokestatic org.apache.cassandra.cql3.statements.RequestValidations.checkTrue:(ZLjava/lang/String;)V
9: goto 12
10: StackMap locals:
StackMap stack: org.apache.cassandra.serializers.MarshalException
pop
11: new org.apache.cassandra.exceptions.InvalidRequestException
dup
ldc "Invalid limit value"
invokespecial org.apache.cassandra.exceptions.InvalidRequestException.<init>:(Ljava/lang/String;)V
athrow
end local 4 12: StackMap locals:
StackMap stack:
iload 3
ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 13 1 limit Lorg/apache/cassandra/cql3/Term;
0 13 2 options Lorg/apache/cassandra/cql3/QueryOptions;
1 13 3 userLimit I
3 12 4 b Ljava/nio/ByteBuffer;
Exception table:
from to target type
4 9 10 Class org.apache.cassandra.serializers.MarshalException
MethodParameters:
Name Flags
limit
options
private java.util.NavigableSet<org.apache.cassandra.db.Clustering> getRequestedRows(org.apache.cassandra.cql3.QueryOptions);
descriptor: (Lorg/apache/cassandra/cql3/QueryOptions;)Ljava/util/NavigableSet;
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.cql3.statements.SelectStatement.$assertionsDisabled:Z
ifne 1
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.isColumnRange:()Z
ifeq 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
aload 1
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.getClusteringColumns:(Lorg/apache/cassandra/cql3/QueryOptions;)Ljava/util/NavigableSet;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 2 1 options Lorg/apache/cassandra/cql3/QueryOptions;
Exceptions:
throws org.apache.cassandra.exceptions.InvalidRequestException
Signature: (Lorg/apache/cassandra/cql3/QueryOptions;)Ljava/util/NavigableSet<Lorg/apache/cassandra/db/Clustering;>;
MethodParameters:
Name Flags
options
public org.apache.cassandra.db.filter.RowFilter getRowFilter(org.apache.cassandra.cql3.QueryOptions);
descriptor: (Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/db/filter/RowFilter;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.keyspace:()Ljava/lang/String;
invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
aload 0
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.columnFamily:()Ljava/lang/String;
invokevirtual org.apache.cassandra.db.Keyspace.getColumnFamilyStore:(Ljava/lang/String;)Lorg/apache/cassandra/db/ColumnFamilyStore;
astore 2
start local 2 1: aload 2
getfield org.apache.cassandra.db.ColumnFamilyStore.indexManager:Lorg/apache/cassandra/index/SecondaryIndexManager;
astore 3
start local 3 2: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
aload 3
aload 1
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.getRowFilter:(Lorg/apache/cassandra/index/SecondaryIndexManager;Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/db/filter/RowFilter;
astore 4
start local 4 3: aload 4
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 4 1 options Lorg/apache/cassandra/cql3/QueryOptions;
1 4 2 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
2 4 3 secondaryIndexManager Lorg/apache/cassandra/index/SecondaryIndexManager;
3 4 4 filter Lorg/apache/cassandra/db/filter/RowFilter;
Exceptions:
throws org.apache.cassandra.exceptions.InvalidRequestException
MethodParameters:
Name Flags
options
private org.apache.cassandra.cql3.ResultSet process(org.apache.cassandra.db.partitions.PartitionIterator, org.apache.cassandra.cql3.QueryOptions, int, int);
descriptor: (Lorg/apache/cassandra/db/partitions/PartitionIterator;Lorg/apache/cassandra/cql3/QueryOptions;II)Lorg/apache/cassandra/cql3/ResultSet;
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=9, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.selection:Lorg/apache/cassandra/cql3/selection/Selection;
aload 2
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.parameters:Lorg/apache/cassandra/cql3/statements/SelectStatement$Parameters;
getfield org.apache.cassandra.cql3.statements.SelectStatement$Parameters.isJson:Z
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.aggregationSpec:Lorg/apache/cassandra/db/aggregation/AggregationSpecification;
invokevirtual org.apache.cassandra.cql3.selection.Selection.resultSetBuilder:(Lorg/apache/cassandra/cql3/QueryOptions;ZLorg/apache/cassandra/db/aggregation/AggregationSpecification;)Lorg/apache/cassandra/cql3/selection/Selection$ResultSetBuilder;
astore 5
start local 5 1: goto 11
2: StackMap locals: org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder
StackMap stack:
aconst_null
astore 6
aconst_null
astore 7
3: aload 1
invokeinterface org.apache.cassandra.db.partitions.PartitionIterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.RowIterator
astore 8
start local 8 4: aload 0
aload 8
aload 2
aload 5
iload 3
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.processPartition:(Lorg/apache/cassandra/db/rows/RowIterator;Lorg/apache/cassandra/cql3/QueryOptions;Lorg/apache/cassandra/cql3/selection/Selection$ResultSetBuilder;I)V
5: aload 8
ifnull 11
aload 8
invokeinterface org.apache.cassandra.db.rows.RowIterator.close:()V
goto 11
StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.db.partitions.PartitionIterator org.apache.cassandra.cql3.QueryOptions int int org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.rows.RowIterator
StackMap stack: java.lang.Throwable
6: astore 6
aload 8
ifnull 7
aload 8
invokeinterface org.apache.cassandra.db.rows.RowIterator.close:()V
end local 8 StackMap locals:
StackMap stack:
7: aload 6
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
8: astore 7
aload 6
ifnonnull 9
aload 7
astore 6
goto 10
StackMap locals:
StackMap stack:
9: aload 6
aload 7
if_acmpeq 10
aload 6
aload 7
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
10: aload 6
athrow
11: StackMap locals:
StackMap stack:
aload 1
invokeinterface org.apache.cassandra.db.partitions.PartitionIterator.hasNext:()Z
ifne 2
12: aload 5
invokevirtual org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder.build:()Lorg/apache/cassandra/cql3/ResultSet;
astore 6
start local 6 13: aload 0
aload 6
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.orderResults:(Lorg/apache/cassandra/cql3/ResultSet;)V
14: aload 6
iload 4
invokevirtual org.apache.cassandra.cql3.ResultSet.trim:(I)V
15: aload 6
areturn
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 16 1 partitions Lorg/apache/cassandra/db/partitions/PartitionIterator;
0 16 2 options Lorg/apache/cassandra/cql3/QueryOptions;
0 16 3 nowInSec I
0 16 4 userLimit I
1 16 5 result Lorg/apache/cassandra/cql3/selection/Selection$ResultSetBuilder;
4 7 8 partition Lorg/apache/cassandra/db/rows/RowIterator;
13 16 6 cqlRows Lorg/apache/cassandra/cql3/ResultSet;
Exception table:
from to target type
4 5 6 any
3 8 8 any
Exceptions:
throws org.apache.cassandra.exceptions.InvalidRequestException
MethodParameters:
Name Flags
partitions
options
nowInSec
userLimit
public static java.nio.ByteBuffer[] getComponents(org.apache.cassandra.config.CFMetaData, org.apache.cassandra.db.DecoratedKey);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/DecoratedKey;)[Ljava/nio/ByteBuffer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
astore 2
start local 2 1: aload 0
invokevirtual org.apache.cassandra.config.CFMetaData.getKeyValidator:()Lorg/apache/cassandra/db/marshal/AbstractType;
instanceof org.apache.cassandra.db.marshal.CompositeType
ifeq 3
2: aload 0
invokevirtual org.apache.cassandra.config.CFMetaData.getKeyValidator:()Lorg/apache/cassandra/db/marshal/AbstractType;
checkcast org.apache.cassandra.db.marshal.CompositeType
aload 2
invokevirtual org.apache.cassandra.db.marshal.CompositeType.split:(Ljava/nio/ByteBuffer;)[Ljava/nio/ByteBuffer;
areturn
3: StackMap locals: java.nio.ByteBuffer
StackMap stack:
iconst_1
anewarray java.nio.ByteBuffer
dup
iconst_0
aload 2
aastore
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 cfm Lorg/apache/cassandra/config/CFMetaData;
0 4 1 dk Lorg/apache/cassandra/db/DecoratedKey;
1 4 2 key Ljava/nio/ByteBuffer;
MethodParameters:
Name Flags
cfm
dk
void processPartition(org.apache.cassandra.db.rows.RowIterator, org.apache.cassandra.cql3.QueryOptions, org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder, int);
descriptor: (Lorg/apache/cassandra/db/rows/RowIterator;Lorg/apache/cassandra/cql3/QueryOptions;Lorg/apache/cassandra/cql3/selection/Selection$ResultSetBuilder;I)V
flags: (0x0000)
Code:
stack=7, locals=11, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.isSuper:()Z
ifeq 3
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.isDense:()Z
ifeq 3
1: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.selection:Lorg/apache/cassandra/cql3/selection/Selection;
aload 1
aload 3
aload 2
invokevirtual org.apache.cassandra.cql3.QueryOptions.getProtocolVersion:()Lorg/apache/cassandra/transport/ProtocolVersion;
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.getSuperColumnRestrictions:()Lorg/apache/cassandra/cql3/SuperColumnCompatibility$SuperColumnRestrictions;
aload 2
invokestatic org.apache.cassandra.cql3.SuperColumnCompatibility.processPartition:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/cql3/selection/Selection;Lorg/apache/cassandra/db/rows/RowIterator;Lorg/apache/cassandra/cql3/selection/Selection$ResultSetBuilder;Lorg/apache/cassandra/transport/ProtocolVersion;Lorg/apache/cassandra/cql3/SuperColumnCompatibility$SuperColumnRestrictions;Lorg/apache/cassandra/cql3/QueryOptions;)V
2: return
3: StackMap locals:
StackMap stack:
aload 2
invokevirtual org.apache.cassandra.cql3.QueryOptions.getProtocolVersion:()Lorg/apache/cassandra/transport/ProtocolVersion;
astore 5
start local 5 4: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
aload 1
invokeinterface org.apache.cassandra.db.rows.RowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokestatic org.apache.cassandra.cql3.statements.SelectStatement.getComponents:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/DecoratedKey;)[Ljava/nio/ByteBuffer;
astore 6
start local 6 5: aload 1
invokeinterface org.apache.cassandra.db.rows.RowIterator.staticRow:()Lorg/apache/cassandra/db/rows/Row;
astore 7
start local 7 6: aload 1
invokeinterface org.apache.cassandra.db.rows.RowIterator.hasNext:()Z
ifne 32
7: aload 7
invokeinterface org.apache.cassandra.db.rows.Row.isEmpty:()Z
ifne 18
aload 0
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.queriesFullPartitions:()Z
ifne 8
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.isStaticCompactTable:()Z
ifeq 18
8: StackMap locals: org.apache.cassandra.transport.ProtocolVersion java.nio.ByteBuffer[] org.apache.cassandra.db.rows.Row
StackMap stack:
aload 3
aload 1
invokeinterface org.apache.cassandra.db.rows.RowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
aload 7
invokeinterface org.apache.cassandra.db.rows.Row.clustering:()Lorg/apache/cassandra/db/Clustering;
invokevirtual org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder.newRow:(Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/Clustering;)V
9: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.selection:Lorg/apache/cassandra/cql3/selection/Selection;
invokevirtual org.apache.cassandra.cql3.selection.Selection.getColumns:()Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 9
goto 17
StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.db.rows.RowIterator org.apache.cassandra.cql3.QueryOptions org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder int org.apache.cassandra.transport.ProtocolVersion java.nio.ByteBuffer[] org.apache.cassandra.db.rows.Row top java.util.Iterator
StackMap stack:
10: aload 9
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.config.ColumnDefinition
astore 8
start local 8 11: invokestatic org.apache.cassandra.cql3.statements.SelectStatement.$SWITCH_TABLE$org$apache$cassandra$config$ColumnDefinition$Kind:()[I
aload 8
getfield org.apache.cassandra.config.ColumnDefinition.kind:Lorg/apache/cassandra/config/ColumnDefinition$Kind;
invokevirtual org.apache.cassandra.config.ColumnDefinition$Kind.ordinal:()I
iaload
tableswitch { // 1 - 4
1: 12
2: 16
3: 16
4: 14
default: 16
}
12: StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.db.rows.RowIterator org.apache.cassandra.cql3.QueryOptions org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder int org.apache.cassandra.transport.ProtocolVersion java.nio.ByteBuffer[] org.apache.cassandra.db.rows.Row org.apache.cassandra.config.ColumnDefinition java.util.Iterator
StackMap stack:
aload 3
aload 6
aload 8
invokevirtual org.apache.cassandra.config.ColumnDefinition.position:()I
aaload
invokevirtual org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder.add:(Ljava/nio/ByteBuffer;)V
13: goto 17
14: StackMap locals:
StackMap stack:
aload 3
aload 8
aload 7
iload 4
aload 5
invokestatic org.apache.cassandra.cql3.statements.SelectStatement.addValue:(Lorg/apache/cassandra/cql3/selection/Selection$ResultSetBuilder;Lorg/apache/cassandra/config/ColumnDefinition;Lorg/apache/cassandra/db/rows/Row;ILorg/apache/cassandra/transport/ProtocolVersion;)V
15: goto 17
16: StackMap locals:
StackMap stack:
aload 3
aconst_null
invokevirtual org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder.add:(Ljava/nio/ByteBuffer;)V
end local 8 17: StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.db.rows.RowIterator org.apache.cassandra.cql3.QueryOptions org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder int org.apache.cassandra.transport.ProtocolVersion java.nio.ByteBuffer[] org.apache.cassandra.db.rows.Row top java.util.Iterator
StackMap stack:
aload 9
invokeinterface java.util.Iterator.hasNext:()Z
ifne 10
18: StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.db.rows.RowIterator org.apache.cassandra.cql3.QueryOptions org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder int org.apache.cassandra.transport.ProtocolVersion java.nio.ByteBuffer[] org.apache.cassandra.db.rows.Row
StackMap stack:
return
19: StackMap locals:
StackMap stack:
aload 1
invokeinterface org.apache.cassandra.db.rows.RowIterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Row
astore 8
start local 8 20: aload 3
aload 1
invokeinterface org.apache.cassandra.db.rows.RowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
aload 8
invokeinterface org.apache.cassandra.db.rows.Row.clustering:()Lorg/apache/cassandra/db/Clustering;
invokevirtual org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder.newRow:(Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/Clustering;)V
21: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.selection:Lorg/apache/cassandra/cql3/selection/Selection;
invokevirtual org.apache.cassandra.cql3.selection.Selection.getColumns:()Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 10
goto 31
StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.db.rows.RowIterator org.apache.cassandra.cql3.QueryOptions org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder int org.apache.cassandra.transport.ProtocolVersion java.nio.ByteBuffer[] org.apache.cassandra.db.rows.Row org.apache.cassandra.db.rows.Row top java.util.Iterator
StackMap stack:
22: aload 10
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.config.ColumnDefinition
astore 9
start local 9 23: invokestatic org.apache.cassandra.cql3.statements.SelectStatement.$SWITCH_TABLE$org$apache$cassandra$config$ColumnDefinition$Kind:()[I
aload 9
getfield org.apache.cassandra.config.ColumnDefinition.kind:Lorg/apache/cassandra/config/ColumnDefinition$Kind;
invokevirtual org.apache.cassandra.config.ColumnDefinition$Kind.ordinal:()I
iaload
tableswitch { // 1 - 4
1: 24
2: 26
3: 28
4: 30
default: 31
}
24: StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.db.rows.RowIterator org.apache.cassandra.cql3.QueryOptions org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder int org.apache.cassandra.transport.ProtocolVersion java.nio.ByteBuffer[] org.apache.cassandra.db.rows.Row org.apache.cassandra.db.rows.Row org.apache.cassandra.config.ColumnDefinition java.util.Iterator
StackMap stack:
aload 3
aload 6
aload 9
invokevirtual org.apache.cassandra.config.ColumnDefinition.position:()I
aaload
invokevirtual org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder.add:(Ljava/nio/ByteBuffer;)V
25: goto 31
26: StackMap locals:
StackMap stack:
aload 3
aload 8
invokeinterface org.apache.cassandra.db.rows.Row.clustering:()Lorg/apache/cassandra/db/Clustering;
aload 9
invokevirtual org.apache.cassandra.config.ColumnDefinition.position:()I
invokeinterface org.apache.cassandra.db.Clustering.get:(I)Ljava/nio/ByteBuffer;
invokevirtual org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder.add:(Ljava/nio/ByteBuffer;)V
27: goto 31
28: StackMap locals:
StackMap stack:
aload 3
aload 9
aload 8
iload 4
aload 5
invokestatic org.apache.cassandra.cql3.statements.SelectStatement.addValue:(Lorg/apache/cassandra/cql3/selection/Selection$ResultSetBuilder;Lorg/apache/cassandra/config/ColumnDefinition;Lorg/apache/cassandra/db/rows/Row;ILorg/apache/cassandra/transport/ProtocolVersion;)V
29: goto 31
30: StackMap locals:
StackMap stack:
aload 3
aload 9
aload 7
iload 4
aload 5
invokestatic org.apache.cassandra.cql3.statements.SelectStatement.addValue:(Lorg/apache/cassandra/cql3/selection/Selection$ResultSetBuilder;Lorg/apache/cassandra/config/ColumnDefinition;Lorg/apache/cassandra/db/rows/Row;ILorg/apache/cassandra/transport/ProtocolVersion;)V
end local 9 31: StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.db.rows.RowIterator org.apache.cassandra.cql3.QueryOptions org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder int org.apache.cassandra.transport.ProtocolVersion java.nio.ByteBuffer[] org.apache.cassandra.db.rows.Row org.apache.cassandra.db.rows.Row top java.util.Iterator
StackMap stack:
aload 10
invokeinterface java.util.Iterator.hasNext:()Z
ifne 22
end local 8 32: StackMap locals: org.apache.cassandra.cql3.statements.SelectStatement org.apache.cassandra.db.rows.RowIterator org.apache.cassandra.cql3.QueryOptions org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder int org.apache.cassandra.transport.ProtocolVersion java.nio.ByteBuffer[] org.apache.cassandra.db.rows.Row
StackMap stack:
aload 1
invokeinterface org.apache.cassandra.db.rows.RowIterator.hasNext:()Z
ifne 19
33: return
end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 34 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 34 1 partition Lorg/apache/cassandra/db/rows/RowIterator;
0 34 2 options Lorg/apache/cassandra/cql3/QueryOptions;
0 34 3 result Lorg/apache/cassandra/cql3/selection/Selection$ResultSetBuilder;
0 34 4 nowInSec I
4 34 5 protocolVersion Lorg/apache/cassandra/transport/ProtocolVersion;
5 34 6 keyComponents [Ljava/nio/ByteBuffer;
6 34 7 staticRow Lorg/apache/cassandra/db/rows/Row;
11 17 8 def Lorg/apache/cassandra/config/ColumnDefinition;
20 32 8 row Lorg/apache/cassandra/db/rows/Row;
23 31 9 def Lorg/apache/cassandra/config/ColumnDefinition;
Exceptions:
throws org.apache.cassandra.exceptions.InvalidRequestException
MethodParameters:
Name Flags
partition
options
result
nowInSec
private boolean queriesFullPartitions();
descriptor: ()Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.hasClusteringColumnsRestrictions:()Z
ifne 1
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.hasRegularColumnsRestrictions:()Z
ifne 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
private static void addValue(org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder, org.apache.cassandra.config.ColumnDefinition, org.apache.cassandra.db.rows.Row, int, org.apache.cassandra.transport.ProtocolVersion);
descriptor: (Lorg/apache/cassandra/cql3/selection/Selection$ResultSetBuilder;Lorg/apache/cassandra/config/ColumnDefinition;Lorg/apache/cassandra/db/rows/Row;ILorg/apache/cassandra/transport/ProtocolVersion;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=4, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 1
invokevirtual org.apache.cassandra.config.ColumnDefinition.isComplex:()Z
ifeq 9
1: getstatic org.apache.cassandra.cql3.statements.SelectStatement.$assertionsDisabled:Z
ifne 2
aload 1
getfield org.apache.cassandra.config.ColumnDefinition.type:Lorg/apache/cassandra/db/marshal/AbstractType;
invokevirtual org.apache.cassandra.db.marshal.AbstractType.isMultiCell:()Z
ifne 2
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
2: StackMap locals:
StackMap stack:
aload 2
aload 1
invokeinterface org.apache.cassandra.db.rows.Row.getComplexColumnData:(Lorg/apache/cassandra/config/ColumnDefinition;)Lorg/apache/cassandra/db/rows/ComplexColumnData;
astore 5
start local 5 3: aload 5
ifnonnull 5
4: aload 0
aconst_null
invokevirtual org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder.add:(Ljava/nio/ByteBuffer;)V
goto 10
5: StackMap locals: org.apache.cassandra.db.rows.ComplexColumnData
StackMap stack:
aload 1
getfield org.apache.cassandra.config.ColumnDefinition.type:Lorg/apache/cassandra/db/marshal/AbstractType;
invokevirtual org.apache.cassandra.db.marshal.AbstractType.isCollection:()Z
ifeq 7
6: aload 0
aload 1
getfield org.apache.cassandra.config.ColumnDefinition.type:Lorg/apache/cassandra/db/marshal/AbstractType;
checkcast org.apache.cassandra.db.marshal.CollectionType
aload 5
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.iterator:()Ljava/util/Iterator;
aload 4
invokevirtual org.apache.cassandra.db.marshal.CollectionType.serializeForNativeProtocol:(Ljava/util/Iterator;Lorg/apache/cassandra/transport/ProtocolVersion;)Ljava/nio/ByteBuffer;
invokevirtual org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder.add:(Ljava/nio/ByteBuffer;)V
goto 10
7: StackMap locals:
StackMap stack:
aload 0
aload 1
getfield org.apache.cassandra.config.ColumnDefinition.type:Lorg/apache/cassandra/db/marshal/AbstractType;
checkcast org.apache.cassandra.db.marshal.UserType
aload 5
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.iterator:()Ljava/util/Iterator;
aload 4
invokevirtual org.apache.cassandra.db.marshal.UserType.serializeForNativeProtocol:(Ljava/util/Iterator;Lorg/apache/cassandra/transport/ProtocolVersion;)Ljava/nio/ByteBuffer;
invokevirtual org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder.add:(Ljava/nio/ByteBuffer;)V
end local 5 8: goto 10
9: StackMap locals:
StackMap stack:
aload 0
aload 2
aload 1
invokeinterface org.apache.cassandra.db.rows.Row.getCell:(Lorg/apache/cassandra/config/ColumnDefinition;)Lorg/apache/cassandra/db/rows/Cell;
iload 3
invokevirtual org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder.add:(Lorg/apache/cassandra/db/rows/Cell;I)V
10: StackMap locals:
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 result Lorg/apache/cassandra/cql3/selection/Selection$ResultSetBuilder;
0 11 1 def Lorg/apache/cassandra/config/ColumnDefinition;
0 11 2 row Lorg/apache/cassandra/db/rows/Row;
0 11 3 nowInSec I
0 11 4 protocolVersion Lorg/apache/cassandra/transport/ProtocolVersion;
3 8 5 complexData Lorg/apache/cassandra/db/rows/ComplexColumnData;
MethodParameters:
Name Flags
result
def
row
nowInSec
protocolVersion
private boolean needsPostQueryOrdering();
descriptor: ()Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.keyIsInRelation:()Z
ifeq 1
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.parameters:Lorg/apache/cassandra/cql3/statements/SelectStatement$Parameters;
getfield org.apache.cassandra.cql3.statements.SelectStatement$Parameters.orderings:Ljava/util/Map;
invokeinterface java.util.Map.isEmpty:()Z
ifne 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
private void orderResults(org.apache.cassandra.cql3.ResultSet);
descriptor: (Lorg/apache/cassandra/cql3/ResultSet;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual org.apache.cassandra.cql3.ResultSet.size:()I
ifeq 1
aload 0
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.needsPostQueryOrdering:()Z
ifne 2
1: StackMap locals:
StackMap stack:
return
2: StackMap locals:
StackMap stack:
aload 1
getfield org.apache.cassandra.cql3.ResultSet.rows:Ljava/util/List;
aload 0
getfield org.apache.cassandra.cql3.statements.SelectStatement.orderingComparator:Ljava/util/Comparator;
invokestatic java.util.Collections.sort:(Ljava/util/List;Ljava/util/Comparator;)V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/cql3/statements/SelectStatement;
0 4 1 cqlRows Lorg/apache/cassandra/cql3/ResultSet;
MethodParameters:
Name Flags
cqlRows
public org.apache.cassandra.transport.messages.ResultMessage execute(org.apache.cassandra.service.QueryState, org.apache.cassandra.cql3.QueryOptions, long);
descriptor: (Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/QueryOptions;J)Lorg/apache/cassandra/transport/messages/ResultMessage;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=5, locals=5, args_size=4
0: aload 0
aload 1
aload 2
lload 3
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.execute:(Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/QueryOptions;J)Lorg/apache/cassandra/transport/messages/ResultMessage$Rows;
areturn
LocalVariableTable:
Start End Slot Name Signature
Exceptions:
throws org.apache.cassandra.exceptions.RequestValidationException, org.apache.cassandra.exceptions.RequestExecutionException
public org.apache.cassandra.transport.messages.ResultMessage executeInternal(org.apache.cassandra.service.QueryState, org.apache.cassandra.cql3.QueryOptions);
descriptor: (Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/transport/messages/ResultMessage;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
aload 2
invokevirtual org.apache.cassandra.cql3.statements.SelectStatement.executeInternal:(Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/transport/messages/ResultMessage$Rows;
areturn
LocalVariableTable:
Start End Slot Name Signature
Exceptions:
throws org.apache.cassandra.exceptions.RequestValidationException, org.apache.cassandra.exceptions.RequestExecutionException
static int[] $SWITCH_TABLE$org$apache$cassandra$config$ColumnDefinition$Kind();
descriptor: ()[I
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=0
0: getstatic org.apache.cassandra.cql3.statements.SelectStatement.$SWITCH_TABLE$org$apache$cassandra$config$ColumnDefinition$Kind:[I
dup
ifnull 1
areturn
StackMap locals:
StackMap stack: int[]
1: pop
invokestatic org.apache.cassandra.config.ColumnDefinition$Kind.values:()[Lorg/apache/cassandra/config/ColumnDefinition$Kind;
arraylength
newarray 10
astore 0
2: aload 0
getstatic org.apache.cassandra.config.ColumnDefinition$Kind.CLUSTERING:Lorg/apache/cassandra/config/ColumnDefinition$Kind;
invokevirtual org.apache.cassandra.config.ColumnDefinition$Kind.ordinal:()I
iconst_2
iastore
3: goto 5
StackMap locals: int[]
StackMap stack: java.lang.NoSuchFieldError
4: pop
StackMap locals:
StackMap stack:
5: aload 0
getstatic org.apache.cassandra.config.ColumnDefinition$Kind.PARTITION_KEY:Lorg/apache/cassandra/config/ColumnDefinition$Kind;
invokevirtual org.apache.cassandra.config.ColumnDefinition$Kind.ordinal:()I
iconst_1
iastore
6: goto 8
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
7: pop
StackMap locals:
StackMap stack:
8: aload 0
getstatic org.apache.cassandra.config.ColumnDefinition$Kind.REGULAR:Lorg/apache/cassandra/config/ColumnDefinition$Kind;
invokevirtual org.apache.cassandra.config.ColumnDefinition$Kind.ordinal:()I
iconst_3
iastore
9: goto 11
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
10: pop
StackMap locals:
StackMap stack:
11: aload 0
getstatic org.apache.cassandra.config.ColumnDefinition$Kind.STATIC:Lorg/apache/cassandra/config/ColumnDefinition$Kind;
invokevirtual org.apache.cassandra.config.ColumnDefinition$Kind.ordinal:()I
iconst_4
iastore
12: goto 14
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
13: pop
StackMap locals:
StackMap stack:
14: aload 0
dup
putstatic org.apache.cassandra.cql3.statements.SelectStatement.$SWITCH_TABLE$org$apache$cassandra$config$ColumnDefinition$Kind:[I
areturn
LocalVariableTable:
Start End Slot Name Signature
Exception table:
from to target type
2 3 4 Class java.lang.NoSuchFieldError
5 6 7 Class java.lang.NoSuchFieldError
8 9 10 Class java.lang.NoSuchFieldError
11 12 13 Class java.lang.NoSuchFieldError
}
SourceFile: "SelectStatement.java"
NestMembers:
org.apache.cassandra.cql3.statements.SelectStatement$ColumnComparator org.apache.cassandra.cql3.statements.SelectStatement$CompositeComparator org.apache.cassandra.cql3.statements.SelectStatement$Pager org.apache.cassandra.cql3.statements.SelectStatement$Pager$InternalPager org.apache.cassandra.cql3.statements.SelectStatement$Pager$NormalPager org.apache.cassandra.cql3.statements.SelectStatement$Parameters org.apache.cassandra.cql3.statements.SelectStatement$RawStatement org.apache.cassandra.cql3.statements.SelectStatement$SingleColumnComparator
InnerClasses:
public final Kind = org.apache.cassandra.config.ColumnDefinition$Kind of org.apache.cassandra.config.ColumnDefinition
public abstract Raw = org.apache.cassandra.config.ColumnDefinition$Raw of org.apache.cassandra.config.ColumnDefinition
public ResultMetadata = org.apache.cassandra.cql3.ResultSet$ResultMetadata of org.apache.cassandra.cql3.ResultSet
public SuperColumnRestrictions = org.apache.cassandra.cql3.SuperColumnCompatibility$SuperColumnRestrictions of org.apache.cassandra.cql3.SuperColumnCompatibility
public ResultSetBuilder = org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder of org.apache.cassandra.cql3.selection.Selection
private abstract ColumnComparator = org.apache.cassandra.cql3.statements.SelectStatement$ColumnComparator of org.apache.cassandra.cql3.statements.SelectStatement
private CompositeComparator = org.apache.cassandra.cql3.statements.SelectStatement$CompositeComparator of org.apache.cassandra.cql3.statements.SelectStatement
private abstract Pager = org.apache.cassandra.cql3.statements.SelectStatement$Pager of org.apache.cassandra.cql3.statements.SelectStatement
public Parameters = org.apache.cassandra.cql3.statements.SelectStatement$Parameters of org.apache.cassandra.cql3.statements.SelectStatement
public RawStatement = org.apache.cassandra.cql3.statements.SelectStatement$RawStatement of org.apache.cassandra.cql3.statements.SelectStatement
private SingleColumnComparator = org.apache.cassandra.cql3.statements.SelectStatement$SingleColumnComparator of org.apache.cassandra.cql3.statements.SelectStatement
public Group = org.apache.cassandra.db.SinglePartitionReadCommand$Group of org.apache.cassandra.db.SinglePartitionReadCommand
public Builder = org.apache.cassandra.db.Slices$Builder of org.apache.cassandra.db.Slices
public Builder = org.apache.cassandra.db.filter.ColumnFilter$Builder of org.apache.cassandra.db.filter.ColumnFilter
public Rows = org.apache.cassandra.transport.messages.ResultMessage$Rows of org.apache.cassandra.transport.messages.ResultMessage