public abstract class org.apache.cassandra.cql3.statements.ModificationStatement implements org.apache.cassandra.cql3.CQLStatement
minor version: 0
major version: 59
flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
this_class: org.apache.cassandra.cql3.statements.ModificationStatement
super_class: java.lang.Object
{
protected static final org.slf4j.Logger logger;
descriptor: Lorg/slf4j/Logger;
flags: (0x001c) ACC_PROTECTED, ACC_STATIC, ACC_FINAL
public static final java.lang.String CUSTOM_EXPRESSIONS_NOT_ALLOWED;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "Custom index expressions cannot be used in WHERE clauses for UPDATE or DELETE statements"
private static final org.apache.cassandra.cql3.ColumnIdentifier CAS_RESULT_COLUMN;
descriptor: Lorg/apache/cassandra/cql3/ColumnIdentifier;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
protected final org.apache.cassandra.cql3.statements.StatementType type;
descriptor: Lorg/apache/cassandra/cql3/statements/StatementType;
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
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
private final org.apache.cassandra.cql3.Attributes attrs;
descriptor: Lorg/apache/cassandra/cql3/Attributes;
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 org.apache.cassandra.cql3.Operations operations;
descriptor: Lorg/apache/cassandra/cql3/Operations;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.cassandra.db.PartitionColumns updatedColumns;
descriptor: Lorg/apache/cassandra/db/PartitionColumns;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.cassandra.cql3.Conditions conditions;
descriptor: Lorg/apache/cassandra/cql3/Conditions;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.cassandra.db.PartitionColumns conditionColumns;
descriptor: Lorg/apache/cassandra/db/PartitionColumns;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.cassandra.db.PartitionColumns requiresRead;
descriptor: Lorg/apache/cassandra/db/PartitionColumns;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
static final boolean $assertionsDisabled;
descriptor: Z
flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/cql3/statements/ModificationStatement;
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.ModificationStatement.$assertionsDisabled:Z
3: ldc Lorg/apache/cassandra/cql3/statements/ModificationStatement;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic org.apache.cassandra.cql3.statements.ModificationStatement.logger:Lorg/slf4j/Logger;
4: new org.apache.cassandra.cql3.ColumnIdentifier
dup
ldc "[applied]"
iconst_0
invokespecial org.apache.cassandra.cql3.ColumnIdentifier.<init>:(Ljava/lang/String;Z)V
putstatic org.apache.cassandra.cql3.statements.ModificationStatement.CAS_RESULT_COLUMN:Lorg/apache/cassandra/cql3/ColumnIdentifier;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(org.apache.cassandra.cql3.statements.StatementType, int, org.apache.cassandra.config.CFMetaData, org.apache.cassandra.cql3.Operations, org.apache.cassandra.cql3.restrictions.StatementRestrictions, org.apache.cassandra.cql3.Conditions, org.apache.cassandra.cql3.Attributes);
descriptor: (Lorg/apache/cassandra/cql3/statements/StatementType;ILorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/cql3/Operations;Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;Lorg/apache/cassandra/cql3/Conditions;Lorg/apache/cassandra/cql3/Attributes;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=14, args_size=8
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield org.apache.cassandra.cql3.statements.ModificationStatement.type:Lorg/apache/cassandra/cql3/statements/StatementType;
2: aload 0
iload 2
putfield org.apache.cassandra.cql3.statements.ModificationStatement.boundTerms:I
3: aload 0
aload 3
putfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
4: aload 0
aload 5
putfield org.apache.cassandra.cql3.statements.ModificationStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
5: aload 0
aload 4
putfield org.apache.cassandra.cql3.statements.ModificationStatement.operations:Lorg/apache/cassandra/cql3/Operations;
6: aload 0
aload 6
putfield org.apache.cassandra.cql3.statements.ModificationStatement.conditions:Lorg/apache/cassandra/cql3/Conditions;
7: aload 0
aload 7
putfield org.apache.cassandra.cql3.statements.ModificationStatement.attrs:Lorg/apache/cassandra/cql3/Attributes;
8: aload 6
invokeinterface org.apache.cassandra.cql3.Conditions.isEmpty:()Z
ifne 11
9: aload 3
invokevirtual org.apache.cassandra.config.CFMetaData.isCounter:()Z
ldc "Conditional updates are not supported on counter tables"
invokestatic org.apache.cassandra.cql3.statements.RequestValidations.checkFalse:(ZLjava/lang/String;)V
10: aload 7
invokevirtual org.apache.cassandra.cql3.Attributes.isTimestampSet:()Z
ldc "Cannot provide custom timestamp for conditional updates"
invokestatic org.apache.cassandra.cql3.statements.RequestValidations.checkFalse:(ZLjava/lang/String;)V
11: StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.cql3.statements.StatementType int org.apache.cassandra.config.CFMetaData org.apache.cassandra.cql3.Operations org.apache.cassandra.cql3.restrictions.StatementRestrictions org.apache.cassandra.cql3.Conditions org.apache.cassandra.cql3.Attributes
StackMap stack:
invokestatic org.apache.cassandra.db.PartitionColumns.builder:()Lorg/apache/cassandra/db/PartitionColumns$Builder;
astore 8
start local 8 12: aload 6
invokeinterface org.apache.cassandra.cql3.Conditions.getColumns:()Ljava/lang/Iterable;
astore 9
start local 9 13: aload 9
ifnull 15
14: aload 8
aload 9
invokevirtual org.apache.cassandra.db.PartitionColumns$Builder.addAll:(Ljava/lang/Iterable;)Lorg/apache/cassandra/db/PartitionColumns$Builder;
pop
15: StackMap locals: org.apache.cassandra.db.PartitionColumns$Builder java.lang.Iterable
StackMap stack:
invokestatic org.apache.cassandra.db.PartitionColumns.builder:()Lorg/apache/cassandra/db/PartitionColumns$Builder;
astore 10
start local 10 16: invokestatic org.apache.cassandra.db.PartitionColumns.builder:()Lorg/apache/cassandra/db/PartitionColumns$Builder;
astore 11
start local 11 17: aload 4
invokevirtual org.apache.cassandra.cql3.Operations.iterator:()Ljava/util/Iterator;
astore 13
goto 23
StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.cql3.statements.StatementType int org.apache.cassandra.config.CFMetaData org.apache.cassandra.cql3.Operations org.apache.cassandra.cql3.restrictions.StatementRestrictions org.apache.cassandra.cql3.Conditions org.apache.cassandra.cql3.Attributes org.apache.cassandra.db.PartitionColumns$Builder java.lang.Iterable org.apache.cassandra.db.PartitionColumns$Builder org.apache.cassandra.db.PartitionColumns$Builder top java.util.Iterator
StackMap stack:
18: aload 13
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.cql3.Operation
astore 12
start local 12 19: aload 10
aload 12
getfield org.apache.cassandra.cql3.Operation.column:Lorg/apache/cassandra/config/ColumnDefinition;
invokevirtual org.apache.cassandra.db.PartitionColumns$Builder.add:(Lorg/apache/cassandra/config/ColumnDefinition;)Lorg/apache/cassandra/db/PartitionColumns$Builder;
pop
20: aload 12
invokevirtual org.apache.cassandra.cql3.Operation.requiresRead:()Z
ifeq 23
21: aload 8
aload 12
getfield org.apache.cassandra.cql3.Operation.column:Lorg/apache/cassandra/config/ColumnDefinition;
invokevirtual org.apache.cassandra.db.PartitionColumns$Builder.add:(Lorg/apache/cassandra/config/ColumnDefinition;)Lorg/apache/cassandra/db/PartitionColumns$Builder;
pop
22: aload 11
aload 12
getfield org.apache.cassandra.cql3.Operation.column:Lorg/apache/cassandra/config/ColumnDefinition;
invokevirtual org.apache.cassandra.db.PartitionColumns$Builder.add:(Lorg/apache/cassandra/config/ColumnDefinition;)Lorg/apache/cassandra/db/PartitionColumns$Builder;
pop
end local 12 23: StackMap locals:
StackMap stack:
aload 13
invokeinterface java.util.Iterator.hasNext:()Z
ifne 18
24: aload 10
invokevirtual org.apache.cassandra.db.PartitionColumns$Builder.build:()Lorg/apache/cassandra/db/PartitionColumns;
astore 12
start local 12 25: aload 3
invokevirtual org.apache.cassandra.config.CFMetaData.isCompactTable:()Z
ifeq 27
aload 12
invokevirtual org.apache.cassandra.db.PartitionColumns.isEmpty:()Z
ifeq 27
aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.updatesRegularRows:()Z
ifeq 27
26: aload 3
invokevirtual org.apache.cassandra.config.CFMetaData.partitionColumns:()Lorg/apache/cassandra/db/PartitionColumns;
astore 12
27: StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.cql3.statements.StatementType int org.apache.cassandra.config.CFMetaData org.apache.cassandra.cql3.Operations org.apache.cassandra.cql3.restrictions.StatementRestrictions org.apache.cassandra.cql3.Conditions org.apache.cassandra.cql3.Attributes org.apache.cassandra.db.PartitionColumns$Builder java.lang.Iterable org.apache.cassandra.db.PartitionColumns$Builder org.apache.cassandra.db.PartitionColumns$Builder org.apache.cassandra.db.PartitionColumns
StackMap stack:
aload 0
aload 12
putfield org.apache.cassandra.cql3.statements.ModificationStatement.updatedColumns:Lorg/apache/cassandra/db/PartitionColumns;
28: aload 0
aload 8
invokevirtual org.apache.cassandra.db.PartitionColumns$Builder.build:()Lorg/apache/cassandra/db/PartitionColumns;
putfield org.apache.cassandra.cql3.statements.ModificationStatement.conditionColumns:Lorg/apache/cassandra/db/PartitionColumns;
29: aload 0
aload 11
invokevirtual org.apache.cassandra.db.PartitionColumns$Builder.build:()Lorg/apache/cassandra/db/PartitionColumns;
putfield org.apache.cassandra.cql3.statements.ModificationStatement.requiresRead:Lorg/apache/cassandra/db/PartitionColumns;
30: return
end local 12 end local 11 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 31 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
0 31 1 type Lorg/apache/cassandra/cql3/statements/StatementType;
0 31 2 boundTerms I
0 31 3 cfm Lorg/apache/cassandra/config/CFMetaData;
0 31 4 operations Lorg/apache/cassandra/cql3/Operations;
0 31 5 restrictions Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
0 31 6 conditions Lorg/apache/cassandra/cql3/Conditions;
0 31 7 attrs Lorg/apache/cassandra/cql3/Attributes;
12 31 8 conditionColumnsBuilder Lorg/apache/cassandra/db/PartitionColumns$Builder;
13 31 9 columns Ljava/lang/Iterable<Lorg/apache/cassandra/config/ColumnDefinition;>;
16 31 10 updatedColumnsBuilder Lorg/apache/cassandra/db/PartitionColumns$Builder;
17 31 11 requiresReadBuilder Lorg/apache/cassandra/db/PartitionColumns$Builder;
19 23 12 operation Lorg/apache/cassandra/cql3/Operation;
25 31 12 modifiedColumns Lorg/apache/cassandra/db/PartitionColumns;
MethodParameters:
Name Flags
type
boundTerms
cfm
operations
restrictions
conditions
attrs
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.ModificationStatement.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/ModificationStatement;
1 3 1 functions Ljava/util/List<Lorg/apache/cassandra/cql3/functions/Function;>;
Signature: ()Ljava/lang/Iterable<Lorg/apache/cassandra/cql3/functions/Function;>;
public void addFunctionsTo(java.util.List<org.apache.cassandra.cql3.functions.Function>);
descriptor: (Ljava/util/List;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.attrs:Lorg/apache/cassandra/cql3/Attributes;
aload 1
invokevirtual org.apache.cassandra.cql3.Attributes.addFunctionsTo:(Ljava/util/List;)V
1: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.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.ModificationStatement.operations:Lorg/apache/cassandra/cql3/Operations;
aload 1
invokevirtual org.apache.cassandra.cql3.Operations.addFunctionsTo:(Ljava/util/List;)V
3: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.conditions:Lorg/apache/cassandra/cql3/Conditions;
aload 1
invokeinterface org.apache.cassandra.cql3.Conditions.addFunctionsTo:(Ljava/util/List;)V
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
0 5 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
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.ModificationStatement.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/ModificationStatement;
public abstract void addUpdateForKey(org.apache.cassandra.db.partitions.PartitionUpdate, org.apache.cassandra.db.Clustering, org.apache.cassandra.cql3.UpdateParameters);
descriptor: (Lorg/apache/cassandra/db/partitions/PartitionUpdate;Lorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/cql3/UpdateParameters;)V
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
MethodParameters:
Name Flags
update
clustering
params
public abstract void addUpdateForKey(org.apache.cassandra.db.partitions.PartitionUpdate, org.apache.cassandra.db.Slice, org.apache.cassandra.cql3.UpdateParameters);
descriptor: (Lorg/apache/cassandra/db/partitions/PartitionUpdate;Lorg/apache/cassandra/db/Slice;Lorg/apache/cassandra/cql3/UpdateParameters;)V
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
MethodParameters:
Name Flags
update
slice
params
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.ModificationStatement.boundTerms:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
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.ModificationStatement.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/ModificationStatement;
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.ModificationStatement.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/ModificationStatement;
public boolean isCounter();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.isCounter:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
public boolean isView();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.isView:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
public long getTimestamp(long, org.apache.cassandra.cql3.QueryOptions);
descriptor: (JLorg/apache/cassandra/cql3/QueryOptions;)J
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 3 0: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.attrs:Lorg/apache/cassandra/cql3/Attributes;
lload 1
aload 3
invokevirtual org.apache.cassandra.cql3.Attributes.getTimestamp:(JLorg/apache/cassandra/cql3/QueryOptions;)J
lreturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
0 1 1 now J
0 1 3 options Lorg/apache/cassandra/cql3/QueryOptions;
Exceptions:
throws org.apache.cassandra.exceptions.InvalidRequestException
MethodParameters:
Name Flags
now
options
public boolean isTimestampSet();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.attrs:Lorg/apache/cassandra/cql3/Attributes;
invokevirtual org.apache.cassandra.cql3.Attributes.isTimestampSet:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
public int getTimeToLive(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
getfield org.apache.cassandra.cql3.statements.ModificationStatement.attrs:Lorg/apache/cassandra/cql3/Attributes;
aload 1
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.cql3.Attributes.getTimeToLive:(Lorg/apache/cassandra/cql3/QueryOptions;Lorg/apache/cassandra/config/CFMetaData;)I
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
0 1 1 options Lorg/apache/cassandra/cql3/QueryOptions;
Exceptions:
throws org.apache.cassandra.exceptions.InvalidRequestException
MethodParameters:
Name Flags
options
public void checkAccess(org.apache.cassandra.service.ClientState);
descriptor: (Lorg/apache/cassandra/service/ClientState;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: aload 1
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
getstatic org.apache.cassandra.auth.Permission.MODIFY:Lorg/apache/cassandra/auth/Permission;
invokevirtual org.apache.cassandra.service.ClientState.hasColumnFamilyAccess:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/auth/Permission;)V
1: aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.hasConditions:()Z
ifeq 3
2: aload 1
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.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
3: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.keyspace:()Ljava/lang/String;
aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.columnFamily:()Ljava/lang/String;
invokestatic org.apache.cassandra.db.view.View.findAll:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Iterable;
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 2
start local 2 4: aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifeq 8
5: aload 1
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.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: java.util.Iterator
StackMap stack:
aload 1
aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.config.ViewDefinition
getfield org.apache.cassandra.config.ViewDefinition.metadata:Lorg/apache/cassandra/config/CFMetaData;
getstatic org.apache.cassandra.auth.Permission.MODIFY:Lorg/apache/cassandra/auth/Permission;
invokevirtual org.apache.cassandra.service.ClientState.hasColumnFamilyAccess:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/auth/Permission;)V
7: aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 6
8: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.getFunctions:()Ljava/lang/Iterable;
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 4
goto 11
StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.service.ClientState java.util.Iterator top java.util.Iterator
StackMap stack:
9: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.cql3.functions.Function
astore 3
start local 3 10: aload 1
getstatic org.apache.cassandra.auth.Permission.EXECUTE:Lorg/apache/cassandra/auth/Permission;
aload 3
invokevirtual org.apache.cassandra.service.ClientState.ensureHasPermission:(Lorg/apache/cassandra/auth/Permission;Lorg/apache/cassandra/cql3/functions/Function;)V
end local 3 11: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 9
12: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
0 13 1 state Lorg/apache/cassandra/service/ClientState;
4 13 2 views Ljava/util/Iterator<Lorg/apache/cassandra/config/ViewDefinition;>;
10 11 3 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=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.hasConditions:()Z
ifeq 1
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.attrs:Lorg/apache/cassandra/cql3/Attributes;
invokevirtual org.apache.cassandra.cql3.Attributes.isTimestampSet:()Z
ifeq 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: ldc "Cannot provide custom timestamp for conditional updates"
invokestatic org.apache.cassandra.cql3.statements.RequestValidations.checkFalse:(ZLjava/lang/String;)V
3: aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.isCounter:()Z
ifeq 4
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.attrs:Lorg/apache/cassandra/cql3/Attributes;
invokevirtual org.apache.cassandra.cql3.Attributes.isTimestampSet:()Z
ifeq 4
iconst_1
goto 5
StackMap locals:
StackMap stack:
4: iconst_0
StackMap locals:
StackMap stack: int
5: ldc "Cannot provide custom timestamp for counter updates"
invokestatic org.apache.cassandra.cql3.statements.RequestValidations.checkFalse:(ZLjava/lang/String;)V
6: aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.isCounter:()Z
ifeq 7
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.attrs:Lorg/apache/cassandra/cql3/Attributes;
invokevirtual org.apache.cassandra.cql3.Attributes.isTimeToLiveSet:()Z
ifeq 7
iconst_1
goto 8
StackMap locals:
StackMap stack:
7: iconst_0
StackMap locals:
StackMap stack: int
8: ldc "Cannot provide custom TTL for counter updates"
invokestatic org.apache.cassandra.cql3.statements.RequestValidations.checkFalse:(ZLjava/lang/String;)V
9: aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.isView:()Z
ldc "Cannot directly modify a materialized view"
invokestatic org.apache.cassandra.cql3.statements.RequestValidations.checkFalse:(ZLjava/lang/String;)V
10: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
0 11 1 state Lorg/apache/cassandra/service/ClientState;
Exceptions:
throws org.apache.cassandra.exceptions.InvalidRequestException
MethodParameters:
Name Flags
state
public org.apache.cassandra.db.PartitionColumns updatedColumns();
descriptor: ()Lorg/apache/cassandra/db/PartitionColumns;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.updatedColumns:Lorg/apache/cassandra/db/PartitionColumns;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
public org.apache.cassandra.db.PartitionColumns conditionColumns();
descriptor: ()Lorg/apache/cassandra/db/PartitionColumns;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.conditionColumns:Lorg/apache/cassandra/db/PartitionColumns;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
public boolean updatesRegularRows();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.clusteringColumns:()Ljava/util/List;
invokeinterface java.util.List.isEmpty:()Z
ifne 1
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.hasClusteringColumnsRestrictions:()Z
ifne 1
iconst_0
ireturn
StackMap locals:
StackMap stack:
1: iconst_1
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
public boolean updatesStaticRow();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.operations:Lorg/apache/cassandra/cql3/Operations;
invokevirtual org.apache.cassandra.cql3.Operations.appliesToStaticColumns:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
public java.util.List<org.apache.cassandra.cql3.Operation> getRegularOperations();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.operations:Lorg/apache/cassandra/cql3/Operations;
invokevirtual org.apache.cassandra.cql3.Operations.regularOperations:()Ljava/util/List;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
Signature: ()Ljava/util/List<Lorg/apache/cassandra/cql3/Operation;>;
public java.util.List<org.apache.cassandra.cql3.Operation> getStaticOperations();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.operations:Lorg/apache/cassandra/cql3/Operations;
invokevirtual org.apache.cassandra.cql3.Operations.staticOperations:()Ljava/util/List;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
Signature: ()Ljava/util/List<Lorg/apache/cassandra/cql3/Operation;>;
public java.lang.Iterable<org.apache.cassandra.cql3.Operation> allOperations();
descriptor: ()Ljava/lang/Iterable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.operations:Lorg/apache/cassandra/cql3/Operations;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
Signature: ()Ljava/lang/Iterable<Lorg/apache/cassandra/cql3/Operation;>;
public java.lang.Iterable<org.apache.cassandra.config.ColumnDefinition> getColumnsWithConditions();
descriptor: ()Ljava/lang/Iterable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.conditions:Lorg/apache/cassandra/cql3/Conditions;
invokeinterface org.apache.cassandra.cql3.Conditions.getColumns:()Ljava/lang/Iterable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
Signature: ()Ljava/lang/Iterable<Lorg/apache/cassandra/config/ColumnDefinition;>;
public boolean hasIfNotExistCondition();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.conditions:Lorg/apache/cassandra/cql3/Conditions;
invokeinterface org.apache.cassandra.cql3.Conditions.isIfNotExists:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
public boolean hasIfExistCondition();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.conditions:Lorg/apache/cassandra/cql3/Conditions;
invokeinterface org.apache.cassandra.cql3.Conditions.isIfExists:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
public java.util.List<java.nio.ByteBuffer> buildPartitionKeyNames(org.apache.cassandra.cql3.QueryOptions);
descriptor: (Lorg/apache/cassandra/cql3/QueryOptions;)Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.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 2
start local 2 1: aload 2
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 4
goto 4
StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.cql3.QueryOptions java.util.List top java.util.Iterator
StackMap stack:
2: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.nio.ByteBuffer
astore 3
start local 3 3: aload 3
invokestatic org.apache.cassandra.cql3.QueryProcessor.validateKey:(Ljava/nio/ByteBuffer;)V
end local 3 4: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
5: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
0 6 1 options Lorg/apache/cassandra/cql3/QueryOptions;
1 6 2 partitionKeys Ljava/util/List<Ljava/nio/ByteBuffer;>;
3 4 3 key Ljava/nio/ByteBuffer;
Exceptions:
throws org.apache.cassandra.exceptions.InvalidRequestException
Signature: (Lorg/apache/cassandra/cql3/QueryOptions;)Ljava/util/List<Ljava/nio/ByteBuffer;>;
MethodParameters:
Name Flags
options
public java.util.NavigableSet<org.apache.cassandra.db.Clustering> createClustering(org.apache.cassandra.cql3.QueryOptions);
descriptor: (Lorg/apache/cassandra/cql3/QueryOptions;)Ljava/util/NavigableSet;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.appliesOnlyToStaticColumns:()Z
ifeq 2
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.hasClusteringColumnsRestrictions:()Z
ifne 2
1: getstatic org.apache.cassandra.db.CBuilder.STATIC_BUILDER:Lorg/apache/cassandra/db/CBuilder;
invokevirtual org.apache.cassandra.db.CBuilder.build:()Lorg/apache/cassandra/db/Clustering;
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.comparator:Lorg/apache/cassandra/db/ClusteringComparator;
invokestatic org.apache.cassandra.utils.FBUtilities.singleton:(Ljava/lang/Object;Ljava/util/Comparator;)Ljava/util/NavigableSet;
areturn
2: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.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 3 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
0 3 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
private boolean appliesOnlyToStaticColumns();
descriptor: ()Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.operations:Lorg/apache/cassandra/cql3/Operations;
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.conditions:Lorg/apache/cassandra/cql3/Conditions;
invokestatic org.apache.cassandra.cql3.statements.ModificationStatement.appliesOnlyToStaticColumns:(Lorg/apache/cassandra/cql3/Operations;Lorg/apache/cassandra/cql3/Conditions;)Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
public static boolean appliesOnlyToStaticColumns(org.apache.cassandra.cql3.Operations, org.apache.cassandra.cql3.Conditions);
descriptor: (Lorg/apache/cassandra/cql3/Operations;Lorg/apache/cassandra/cql3/Conditions;)Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.cql3.Operations.appliesToRegularColumns:()Z
ifne 3
aload 1
invokeinterface org.apache.cassandra.cql3.Conditions.appliesToRegularColumns:()Z
ifne 3
1: aload 0
invokevirtual org.apache.cassandra.cql3.Operations.appliesToStaticColumns:()Z
ifne 2
aload 1
invokeinterface org.apache.cassandra.cql3.Conditions.appliesToStaticColumns:()Z
ifeq 3
2: StackMap locals:
StackMap stack:
iconst_1
ireturn
StackMap locals:
StackMap stack:
3: iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 operation Lorg/apache/cassandra/cql3/Operations;
0 4 1 conditions Lorg/apache/cassandra/cql3/Conditions;
MethodParameters:
Name Flags
operation
conditions
public boolean requiresRead();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=3, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.allOperations:()Ljava/lang/Iterable;
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 2
goto 4
StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement top java.util.Iterator
StackMap stack:
1: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.cql3.Operation
astore 1
start local 1 2: aload 1
invokevirtual org.apache.cassandra.cql3.Operation.requiresRead:()Z
ifeq 4
3: iconst_1
ireturn
end local 1 4: StackMap locals:
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
5: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
2 4 1 op Lorg/apache/cassandra/cql3/Operation;
private java.util.Map<org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.db.partitions.Partition> readRequiredLists(java.util.Collection<java.nio.ByteBuffer>, org.apache.cassandra.db.filter.ClusteringIndexFilter, org.apache.cassandra.db.filter.DataLimits, boolean, org.apache.cassandra.db.ConsistencyLevel, long);
descriptor: (Ljava/util/Collection;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/db/filter/DataLimits;ZLorg/apache/cassandra/db/ConsistencyLevel;J)Ljava/util/Map;
flags: (0x0002) ACC_PRIVATE
Code:
stack=8, locals=15, 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
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.requiresRead:()Z
ifne 2
1: aconst_null
areturn
2: StackMap locals:
StackMap stack:
aload 5
aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.keyspace:()Ljava/lang/String;
invokevirtual org.apache.cassandra.db.ConsistencyLevel.validateForRead:(Ljava/lang/String;)V
3: goto 6
4: StackMap locals:
StackMap stack: org.apache.cassandra.exceptions.InvalidRequestException
pop
5: new org.apache.cassandra.exceptions.InvalidRequestException
dup
ldc "Write operation require a read but consistency %s is not supported on reads"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 5
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokespecial org.apache.cassandra.exceptions.InvalidRequestException.<init>:(Ljava/lang/String;)V
athrow
6: StackMap locals:
StackMap stack:
new java.util.ArrayList
dup
aload 1
invokeinterface java.util.Collection.size:()I
invokespecial java.util.ArrayList.<init>:(I)V
astore 8
start local 8 7: invokestatic org.apache.cassandra.utils.FBUtilities.nowInSeconds:()I
istore 9
start local 9 8: aload 1
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 11
goto 18
StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement java.util.Collection org.apache.cassandra.db.filter.ClusteringIndexFilter org.apache.cassandra.db.filter.DataLimits int org.apache.cassandra.db.ConsistencyLevel long java.util.List int top java.util.Iterator
StackMap stack:
9: aload 11
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.nio.ByteBuffer
astore 10
start local 10 10: aload 8
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
11: iload 9
12: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.requiresRead:Lorg/apache/cassandra/db/PartitionColumns;
invokestatic org.apache.cassandra.db.filter.ColumnFilter.selection:(Lorg/apache/cassandra/db/PartitionColumns;)Lorg/apache/cassandra/db/filter/ColumnFilter;
13: getstatic org.apache.cassandra.db.filter.RowFilter.NONE:Lorg/apache/cassandra/db/filter/RowFilter;
14: aload 3
15: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
aload 10
invokevirtual org.apache.cassandra.config.CFMetaData.decorateKey:(Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/db/DecoratedKey;
16: aload 2
17: 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 10 18: StackMap locals:
StackMap stack:
aload 11
invokeinterface java.util.Iterator.hasNext:()Z
ifne 9
19: new org.apache.cassandra.db.SinglePartitionReadCommand$Group
dup
aload 8
getstatic org.apache.cassandra.db.filter.DataLimits.NONE:Lorg/apache/cassandra/db/filter/DataLimits;
invokespecial org.apache.cassandra.db.SinglePartitionReadCommand$Group.<init>:(Ljava/util/List;Lorg/apache/cassandra/db/filter/DataLimits;)V
astore 10
start local 10 20: iload 4
ifeq 38
21: aconst_null
astore 11
aconst_null
astore 12
22: aload 10
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand$Group.executionController:()Lorg/apache/cassandra/db/ReadExecutionController;
astore 13
start local 13 23: aload 10
aload 13
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand$Group.executeInternal:(Lorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/db/partitions/PartitionIterator;
astore 14
start local 14 24: aload 0
aload 14
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.asMaterializedMap:(Lorg/apache/cassandra/db/partitions/PartitionIterator;)Ljava/util/Map;
25: aload 14
ifnull 26
aload 14
invokeinterface org.apache.cassandra.db.partitions.PartitionIterator.close:()V
StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement java.util.Collection org.apache.cassandra.db.filter.ClusteringIndexFilter org.apache.cassandra.db.filter.DataLimits int org.apache.cassandra.db.ConsistencyLevel long java.util.List int org.apache.cassandra.db.SinglePartitionReadCommand$Group java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.ReadExecutionController org.apache.cassandra.db.partitions.PartitionIterator
StackMap stack: java.util.Map
26: aload 13
ifnull 27
aload 13
invokevirtual org.apache.cassandra.db.ReadExecutionController.close:()V
27: StackMap locals:
StackMap stack: java.util.Map
areturn
StackMap locals:
StackMap stack: java.lang.Throwable
28: astore 11
29: aload 14
ifnull 30
aload 14
invokeinterface org.apache.cassandra.db.partitions.PartitionIterator.close:()V
end local 14 StackMap locals:
StackMap stack:
30: aload 11
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
31: astore 12
aload 11
ifnonnull 32
aload 12
astore 11
goto 33
StackMap locals:
StackMap stack:
32: aload 11
aload 12
if_acmpeq 33
aload 11
aload 12
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
33: aload 13
ifnull 34
aload 13
invokevirtual org.apache.cassandra.db.ReadExecutionController.close:()V
end local 13 StackMap locals:
StackMap stack:
34: aload 11
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
35: astore 12
aload 11
ifnonnull 36
aload 12
astore 11
goto 37
StackMap locals:
StackMap stack:
36: aload 11
aload 12
if_acmpeq 37
aload 11
aload 12
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
37: aload 11
athrow
38: StackMap locals:
StackMap stack:
aconst_null
astore 11
aconst_null
astore 12
39: aload 10
aload 5
aconst_null
lload 6
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand$Group.execute:(Lorg/apache/cassandra/db/ConsistencyLevel;Lorg/apache/cassandra/service/ClientState;J)Lorg/apache/cassandra/db/partitions/PartitionIterator;
astore 13
start local 13 40: aload 0
aload 13
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.asMaterializedMap:(Lorg/apache/cassandra/db/partitions/PartitionIterator;)Ljava/util/Map;
41: aload 13
ifnull 42
aload 13
invokeinterface org.apache.cassandra.db.partitions.PartitionIterator.close:()V
42: StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement java.util.Collection org.apache.cassandra.db.filter.ClusteringIndexFilter org.apache.cassandra.db.filter.DataLimits int org.apache.cassandra.db.ConsistencyLevel long java.util.List int org.apache.cassandra.db.SinglePartitionReadCommand$Group java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.partitions.PartitionIterator
StackMap stack: java.util.Map
areturn
StackMap locals:
StackMap stack: java.lang.Throwable
43: astore 11
44: aload 13
ifnull 45
aload 13
invokeinterface org.apache.cassandra.db.partitions.PartitionIterator.close:()V
end local 13 StackMap locals:
StackMap stack:
45: aload 11
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
46: astore 12
aload 11
ifnonnull 47
aload 12
astore 11
goto 48
StackMap locals:
StackMap stack:
47: aload 11
aload 12
if_acmpeq 48
aload 11
aload 12
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
48: aload 11
athrow
end local 10 end local 9 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 49 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
0 49 1 partitionKeys Ljava/util/Collection<Ljava/nio/ByteBuffer;>;
0 49 2 filter Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
0 49 3 limits Lorg/apache/cassandra/db/filter/DataLimits;
0 49 4 local Z
0 49 5 cl Lorg/apache/cassandra/db/ConsistencyLevel;
0 49 6 queryStartNanoTime J
7 49 8 commands Ljava/util/List<Lorg/apache/cassandra/db/SinglePartitionReadCommand;>;
8 49 9 nowInSec I
10 18 10 key Ljava/nio/ByteBuffer;
20 49 10 group Lorg/apache/cassandra/db/SinglePartitionReadCommand$Group;
23 34 13 executionController Lorg/apache/cassandra/db/ReadExecutionController;
24 30 14 iter Lorg/apache/cassandra/db/partitions/PartitionIterator;
40 45 13 iter Lorg/apache/cassandra/db/partitions/PartitionIterator;
Exception table:
from to target type
2 3 4 Class org.apache.cassandra.exceptions.InvalidRequestException
24 25 28 any
23 26 31 any
28 31 31 any
22 27 35 any
28 35 35 any
40 41 43 any
39 42 46 any
43 46 46 any
Signature: (Ljava/util/Collection<Ljava/nio/ByteBuffer;>;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/db/filter/DataLimits;ZLorg/apache/cassandra/db/ConsistencyLevel;J)Ljava/util/Map<Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/partitions/Partition;>;
MethodParameters:
Name Flags
partitionKeys
filter
limits
local
cl
queryStartNanoTime
private java.util.Map<org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.db.partitions.Partition> asMaterializedMap(org.apache.cassandra.db.partitions.PartitionIterator);
descriptor: (Lorg/apache/cassandra/db/partitions/PartitionIterator;)Ljava/util/Map;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=6, args_size=2
start local 0 start local 1 0: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 2
start local 2 1: goto 11
2: StackMap locals: java.util.Map
StackMap stack:
aconst_null
astore 3
aconst_null
astore 4
3: aload 1
invokeinterface org.apache.cassandra.db.partitions.PartitionIterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.RowIterator
astore 5
start local 5 4: aload 2
aload 5
invokeinterface org.apache.cassandra.db.rows.RowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
aload 5
invokestatic org.apache.cassandra.db.partitions.FilteredPartition.create:(Lorg/apache/cassandra/db/rows/RowIterator;)Lorg/apache/cassandra/db/partitions/FilteredPartition;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
5: aload 5
ifnull 11
aload 5
invokeinterface org.apache.cassandra.db.rows.RowIterator.close:()V
goto 11
StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.db.partitions.PartitionIterator java.util.Map java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.rows.RowIterator
StackMap stack: java.lang.Throwable
6: astore 3
aload 5
ifnull 7
aload 5
invokeinterface org.apache.cassandra.db.rows.RowIterator.close:()V
end local 5 StackMap locals:
StackMap stack:
7: aload 3
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
8: astore 4
aload 3
ifnonnull 9
aload 4
astore 3
goto 10
StackMap locals:
StackMap stack:
9: aload 3
aload 4
if_acmpeq 10
aload 3
aload 4
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
10: aload 3
athrow
11: StackMap locals:
StackMap stack:
aload 1
invokeinterface org.apache.cassandra.db.partitions.PartitionIterator.hasNext:()Z
ifne 2
12: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
0 13 1 iterator Lorg/apache/cassandra/db/partitions/PartitionIterator;
1 13 2 map Ljava/util/Map<Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/partitions/Partition;>;
4 7 5 partition Lorg/apache/cassandra/db/rows/RowIterator;
Exception table:
from to target type
4 5 6 any
3 8 8 any
Signature: (Lorg/apache/cassandra/db/partitions/PartitionIterator;)Ljava/util/Map<Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/partitions/Partition;>;
MethodParameters:
Name Flags
iterator
public boolean hasConditions();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.conditions:Lorg/apache/cassandra/cql3/Conditions;
invokeinterface org.apache.cassandra.cql3.Conditions.isEmpty:()Z
ifeq 1
iconst_0
goto 2
StackMap locals:
StackMap stack:
1: iconst_1
StackMap locals:
StackMap stack: int
2: ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
public boolean hasSlices();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.type:Lorg/apache/cassandra/cql3/statements/StatementType;
invokevirtual org.apache.cassandra.cql3.statements.StatementType.allowClusteringColumnSlices:()Z
ifeq 4
1: aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.getRestrictions:()Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.hasClusteringColumnsRestrictions:()Z
ifeq 4
2: aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.getRestrictions:()Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.isColumnRange:()Z
ifeq 4
3: iconst_1
ireturn
StackMap locals:
StackMap stack:
4: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
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: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, 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;
ifnonnull 2
1: new org.apache.cassandra.exceptions.InvalidRequestException
dup
ldc "Invalid empty consistency level"
invokespecial org.apache.cassandra.exceptions.InvalidRequestException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.hasConditions:()Z
ifeq 4
3: aload 0
aload 1
aload 2
lload 3
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.executeWithCondition:(Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/QueryOptions;J)Lorg/apache/cassandra/transport/messages/ResultMessage;
goto 5
4: StackMap locals:
StackMap stack:
aload 0
aload 1
aload 2
lload 3
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.executeWithoutCondition:(Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/QueryOptions;J)Lorg/apache/cassandra/transport/messages/ResultMessage;
5: StackMap locals:
StackMap stack: org.apache.cassandra.transport.messages.ResultMessage
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
0 6 1 queryState Lorg/apache/cassandra/service/QueryState;
0 6 2 options Lorg/apache/cassandra/cql3/QueryOptions;
0 6 3 queryStartNanoTime J
Exceptions:
throws org.apache.cassandra.exceptions.RequestExecutionException, org.apache.cassandra.exceptions.RequestValidationException
MethodParameters:
Name Flags
queryState
options
queryStartNanoTime
private org.apache.cassandra.transport.messages.ResultMessage executeWithoutCondition(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: (0x0002) ACC_PRIVATE
Code:
stack=7, locals=7, 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 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.isCounter:()Z
ifeq 3
2: aload 5
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.db.ConsistencyLevel.validateCounterForWrite:(Lorg/apache/cassandra/config/CFMetaData;)V
goto 4
3: StackMap locals: org.apache.cassandra.db.ConsistencyLevel
StackMap stack:
aload 5
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.ksName:Ljava/lang/String;
invokevirtual org.apache.cassandra.db.ConsistencyLevel.validateForWrite:(Ljava/lang/String;)V
4: StackMap locals:
StackMap stack:
aload 0
aload 2
iconst_0
aload 2
aload 1
invokevirtual org.apache.cassandra.cql3.QueryOptions.getTimestamp:(Lorg/apache/cassandra/service/QueryState;)J
lload 3
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.getMutations:(Lorg/apache/cassandra/cql3/QueryOptions;ZJJ)Ljava/util/Collection;
astore 6
start local 6 5: aload 6
invokeinterface java.util.Collection.isEmpty:()Z
ifne 7
6: aload 6
aload 5
iconst_0
lload 3
invokestatic org.apache.cassandra.service.StorageProxy.mutateWithTriggers:(Ljava/util/Collection;Lorg/apache/cassandra/db/ConsistencyLevel;ZJ)V
7: StackMap locals: java.util.Collection
StackMap stack:
aconst_null
areturn
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 8 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
0 8 1 queryState Lorg/apache/cassandra/service/QueryState;
0 8 2 options Lorg/apache/cassandra/cql3/QueryOptions;
0 8 3 queryStartNanoTime J
1 8 5 cl Lorg/apache/cassandra/db/ConsistencyLevel;
5 8 6 mutations Ljava/util/Collection<+Lorg/apache/cassandra/db/IMutation;>;
Exceptions:
throws org.apache.cassandra.exceptions.RequestExecutionException, org.apache.cassandra.exceptions.RequestValidationException
MethodParameters:
Name Flags
queryState
options
queryStartNanoTime
public org.apache.cassandra.transport.messages.ResultMessage executeWithCondition(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: (0x0001) ACC_PUBLIC
Code:
stack=9, locals=9, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.makeCasRequest:(Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/cql3/statements/CQL3CasRequest;
astore 5
start local 5 1: aconst_null
astore 6
aconst_null
astore 7
2: aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.keyspace:()Ljava/lang/String;
3: aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.columnFamily:()Ljava/lang/String;
4: aload 5
getfield org.apache.cassandra.cql3.statements.CQL3CasRequest.key:Lorg/apache/cassandra/db/DecoratedKey;
5: aload 5
6: aload 2
invokevirtual org.apache.cassandra.cql3.QueryOptions.getSerialConsistency:()Lorg/apache/cassandra/db/ConsistencyLevel;
7: aload 2
invokevirtual org.apache.cassandra.cql3.QueryOptions.getConsistency:()Lorg/apache/cassandra/db/ConsistencyLevel;
8: aload 1
invokevirtual org.apache.cassandra.service.QueryState.getClientState:()Lorg/apache/cassandra/service/ClientState;
9: lload 3
10: invokestatic org.apache.cassandra.service.StorageProxy.cas:(Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/service/CASRequest;Lorg/apache/cassandra/db/ConsistencyLevel;Lorg/apache/cassandra/db/ConsistencyLevel;Lorg/apache/cassandra/service/ClientState;J)Lorg/apache/cassandra/db/rows/RowIterator;
astore 8
start local 8 11: new org.apache.cassandra.transport.messages.ResultMessage$Rows
dup
aload 0
aload 8
aload 2
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.buildCasResultSet:(Lorg/apache/cassandra/db/rows/RowIterator;Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/cql3/ResultSet;
invokespecial org.apache.cassandra.transport.messages.ResultMessage$Rows.<init>:(Lorg/apache/cassandra/cql3/ResultSet;)V
12: aload 8
ifnull 13
aload 8
invokeinterface org.apache.cassandra.db.rows.RowIterator.close:()V
13: StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.service.QueryState org.apache.cassandra.cql3.QueryOptions long org.apache.cassandra.cql3.statements.CQL3CasRequest java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.rows.RowIterator
StackMap stack: org.apache.cassandra.transport.messages.ResultMessage$Rows
areturn
StackMap locals:
StackMap stack: java.lang.Throwable
14: astore 6
15: aload 8
ifnull 16
aload 8
invokeinterface org.apache.cassandra.db.rows.RowIterator.close:()V
end local 8 StackMap locals:
StackMap stack:
16: aload 6
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
17: astore 7
aload 6
ifnonnull 18
aload 7
astore 6
goto 19
StackMap locals:
StackMap stack:
18: aload 6
aload 7
if_acmpeq 19
aload 6
aload 7
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
19: aload 6
athrow
end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
0 20 1 queryState Lorg/apache/cassandra/service/QueryState;
0 20 2 options Lorg/apache/cassandra/cql3/QueryOptions;
0 20 3 queryStartNanoTime J
1 20 5 request Lorg/apache/cassandra/cql3/statements/CQL3CasRequest;
11 16 8 result Lorg/apache/cassandra/db/rows/RowIterator;
Exception table:
from to target type
11 12 14 any
2 13 17 any
14 17 17 any
Exceptions:
throws org.apache.cassandra.exceptions.RequestExecutionException, org.apache.cassandra.exceptions.RequestValidationException
MethodParameters:
Name Flags
queryState
options
queryStartNanoTime
private org.apache.cassandra.cql3.statements.CQL3CasRequest makeCasRequest(org.apache.cassandra.service.QueryState, org.apache.cassandra.cql3.QueryOptions);
descriptor: (Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/cql3/statements/CQL3CasRequest;
flags: (0x0002) ACC_PRIVATE
Code:
stack=8, locals=9, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 2
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.buildPartitionKeyNames:(Lorg/apache/cassandra/cql3/QueryOptions;)Ljava/util/List;
astore 3
start local 3 1: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.keyIsInRelation:()Z
2: ldc "IN on the partition key is not supported with conditional %s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
3: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.type:Lorg/apache/cassandra/cql3/statements/StatementType;
invokevirtual org.apache.cassandra.cql3.statements.StatementType.isUpdate:()Z
ifeq 4
ldc "updates"
goto 5
StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.service.QueryState org.apache.cassandra.cql3.QueryOptions java.util.List
StackMap stack: int java.lang.String java.lang.Object[] java.lang.Object[] int
4: ldc "deletions"
StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.service.QueryState org.apache.cassandra.cql3.QueryOptions java.util.List
StackMap stack: int java.lang.String java.lang.Object[] java.lang.Object[] int java.lang.String
5: aastore
6: invokestatic org.apache.cassandra.cql3.statements.RequestValidations.checkFalse:(ZLjava/lang/String;[Ljava/lang/Object;)V
7: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
aload 3
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.nio.ByteBuffer
invokevirtual org.apache.cassandra.config.CFMetaData.decorateKey:(Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/db/DecoratedKey;
astore 4
start local 4 8: aload 2
aload 1
invokevirtual org.apache.cassandra.cql3.QueryOptions.getTimestamp:(Lorg/apache/cassandra/service/QueryState;)J
lstore 5
start local 5 9: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.clusteringKeyRestrictionsHasIN:()Z
10: ldc "IN on the clustering key columns is not supported with conditional %s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
11: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.type:Lorg/apache/cassandra/cql3/statements/StatementType;
invokevirtual org.apache.cassandra.cql3.statements.StatementType.isUpdate:()Z
ifeq 12
ldc "updates"
goto 13
StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.service.QueryState org.apache.cassandra.cql3.QueryOptions java.util.List org.apache.cassandra.db.DecoratedKey long
StackMap stack: int java.lang.String java.lang.Object[] java.lang.Object[] int
12: ldc "deletions"
StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.service.QueryState org.apache.cassandra.cql3.QueryOptions java.util.List org.apache.cassandra.db.DecoratedKey long
StackMap stack: int java.lang.String java.lang.Object[] java.lang.Object[] int java.lang.String
13: aastore
14: invokestatic org.apache.cassandra.cql3.statements.RequestValidations.checkFalse:(ZLjava/lang/String;[Ljava/lang/Object;)V
15: aload 0
aload 2
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.createClustering:(Lorg/apache/cassandra/cql3/QueryOptions;)Ljava/util/NavigableSet;
invokestatic com.google.common.collect.Iterables.getOnlyElement:(Ljava/lang/Iterable;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.Clustering
astore 7
start local 7 16: new org.apache.cassandra.cql3.statements.CQL3CasRequest
dup
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
aload 4
iconst_0
aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.conditionColumns:()Lorg/apache/cassandra/db/PartitionColumns;
aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.updatesRegularRows:()Z
aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.updatesStaticRow:()Z
invokespecial org.apache.cassandra.cql3.statements.CQL3CasRequest.<init>:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/DecoratedKey;ZLorg/apache/cassandra/db/PartitionColumns;ZZ)V
astore 8
start local 8 17: aload 0
aload 7
aload 8
aload 2
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.addConditions:(Lorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/cql3/statements/CQL3CasRequest;Lorg/apache/cassandra/cql3/QueryOptions;)V
18: aload 8
aload 7
aload 0
aload 2
lload 5
invokevirtual org.apache.cassandra.cql3.statements.CQL3CasRequest.addRowUpdate:(Lorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/cql3/statements/ModificationStatement;Lorg/apache/cassandra/cql3/QueryOptions;J)V
19: aload 8
areturn
end local 8 end local 7 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 20 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
0 20 1 queryState Lorg/apache/cassandra/service/QueryState;
0 20 2 options Lorg/apache/cassandra/cql3/QueryOptions;
1 20 3 keys Ljava/util/List<Ljava/nio/ByteBuffer;>;
8 20 4 key Lorg/apache/cassandra/db/DecoratedKey;
9 20 5 now J
16 20 7 clustering Lorg/apache/cassandra/db/Clustering;
17 20 8 request Lorg/apache/cassandra/cql3/statements/CQL3CasRequest;
MethodParameters:
Name Flags
queryState
options
public void addConditions(org.apache.cassandra.db.Clustering, org.apache.cassandra.cql3.statements.CQL3CasRequest, org.apache.cassandra.cql3.QueryOptions);
descriptor: (Lorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/cql3/statements/CQL3CasRequest;Lorg/apache/cassandra/cql3/QueryOptions;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.conditions:Lorg/apache/cassandra/cql3/Conditions;
aload 2
aload 1
aload 3
invokeinterface org.apache.cassandra.cql3.Conditions.addConditionsTo:(Lorg/apache/cassandra/cql3/statements/CQL3CasRequest;Lorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/cql3/QueryOptions;)V
1: return
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/ModificationStatement;
0 2 1 clustering Lorg/apache/cassandra/db/Clustering;
0 2 2 request Lorg/apache/cassandra/cql3/statements/CQL3CasRequest;
0 2 3 options Lorg/apache/cassandra/cql3/QueryOptions;
Exceptions:
throws org.apache.cassandra.exceptions.InvalidRequestException
MethodParameters:
Name Flags
clustering
request
options
private org.apache.cassandra.cql3.ResultSet buildCasResultSet(org.apache.cassandra.db.rows.RowIterator, org.apache.cassandra.cql3.QueryOptions);
descriptor: (Lorg/apache/cassandra/db/rows/RowIterator;Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/cql3/ResultSet;
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.keyspace:()Ljava/lang/String;
aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.columnFamily:()Ljava/lang/String;
aload 1
aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.getColumnsWithConditions:()Ljava/lang/Iterable;
iconst_0
aload 2
invokestatic org.apache.cassandra.cql3.statements.ModificationStatement.buildCasResultSet:(Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/db/rows/RowIterator;Ljava/lang/Iterable;ZLorg/apache/cassandra/cql3/QueryOptions;)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/ModificationStatement;
0 1 1 partition Lorg/apache/cassandra/db/rows/RowIterator;
0 1 2 options Lorg/apache/cassandra/cql3/QueryOptions;
Exceptions:
throws org.apache.cassandra.exceptions.InvalidRequestException
MethodParameters:
Name Flags
partition
options
public static org.apache.cassandra.cql3.ResultSet buildCasResultSet(java.lang.String, java.lang.String, org.apache.cassandra.db.rows.RowIterator, java.lang.Iterable<org.apache.cassandra.config.ColumnDefinition>, boolean, org.apache.cassandra.cql3.QueryOptions);
descriptor: (Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/db/rows/RowIterator;Ljava/lang/Iterable;ZLorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/cql3/ResultSet;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=11, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 2
ifnonnull 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: istore 6
start local 6 3: new org.apache.cassandra.cql3.ColumnSpecification
dup
aload 0
aload 1
getstatic org.apache.cassandra.cql3.statements.ModificationStatement.CAS_RESULT_COLUMN:Lorg/apache/cassandra/cql3/ColumnIdentifier;
getstatic org.apache.cassandra.db.marshal.BooleanType.instance:Lorg/apache/cassandra/db/marshal/BooleanType;
invokespecial org.apache.cassandra.cql3.ColumnSpecification.<init>:(Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/cql3/ColumnIdentifier;Lorg/apache/cassandra/db/marshal/AbstractType;)V
astore 7
start local 7 4: new org.apache.cassandra.cql3.ResultSet$ResultMetadata
dup
aload 7
invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
invokespecial org.apache.cassandra.cql3.ResultSet$ResultMetadata.<init>:(Ljava/util/List;)V
astore 8
start local 8 5: getstatic org.apache.cassandra.db.marshal.BooleanType.instance:Lorg/apache/cassandra/db/marshal/BooleanType;
iload 6
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokevirtual org.apache.cassandra.db.marshal.BooleanType.decompose:(Ljava/lang/Object;)Ljava/nio/ByteBuffer;
invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
astore 9
start local 9 6: new org.apache.cassandra.cql3.ResultSet
dup
aload 8
aload 9
invokespecial org.apache.cassandra.cql3.ResultSet.<init>:(Lorg/apache/cassandra/cql3/ResultSet$ResultMetadata;Ljava/util/List;)V
astore 10
start local 10 7: iload 6
ifeq 8
aload 10
goto 9
StackMap locals: java.lang.String java.lang.String org.apache.cassandra.db.rows.RowIterator java.lang.Iterable int org.apache.cassandra.cql3.QueryOptions int org.apache.cassandra.cql3.ColumnSpecification org.apache.cassandra.cql3.ResultSet$ResultMetadata java.util.List org.apache.cassandra.cql3.ResultSet
StackMap stack:
8: aload 10
aload 2
aload 3
iload 4
aload 5
invokestatic org.apache.cassandra.cql3.statements.ModificationStatement.buildCasFailureResultSet:(Lorg/apache/cassandra/db/rows/RowIterator;Ljava/lang/Iterable;ZLorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/cql3/ResultSet;
invokestatic org.apache.cassandra.cql3.statements.ModificationStatement.merge:(Lorg/apache/cassandra/cql3/ResultSet;Lorg/apache/cassandra/cql3/ResultSet;)Lorg/apache/cassandra/cql3/ResultSet;
StackMap locals:
StackMap stack: org.apache.cassandra.cql3.ResultSet
9: areturn
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 10 0 ksName Ljava/lang/String;
0 10 1 tableName Ljava/lang/String;
0 10 2 partition Lorg/apache/cassandra/db/rows/RowIterator;
0 10 3 columnsWithConditions Ljava/lang/Iterable<Lorg/apache/cassandra/config/ColumnDefinition;>;
0 10 4 isBatch Z
0 10 5 options Lorg/apache/cassandra/cql3/QueryOptions;
3 10 6 success Z
4 10 7 spec Lorg/apache/cassandra/cql3/ColumnSpecification;
5 10 8 metadata Lorg/apache/cassandra/cql3/ResultSet$ResultMetadata;
6 10 9 rows Ljava/util/List<Ljava/util/List<Ljava/nio/ByteBuffer;>;>;
7 10 10 rs Lorg/apache/cassandra/cql3/ResultSet;
Exceptions:
throws org.apache.cassandra.exceptions.InvalidRequestException
Signature: (Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/db/rows/RowIterator;Ljava/lang/Iterable<Lorg/apache/cassandra/config/ColumnDefinition;>;ZLorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/cql3/ResultSet;
MethodParameters:
Name Flags
ksName
tableName
partition
columnsWithConditions
isBatch
options
private static org.apache.cassandra.cql3.ResultSet merge(org.apache.cassandra.cql3.ResultSet, org.apache.cassandra.cql3.ResultSet);
descriptor: (Lorg/apache/cassandra/cql3/ResultSet;Lorg/apache/cassandra/cql3/ResultSet;)Lorg/apache/cassandra/cql3/ResultSet;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=7, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.cql3.ResultSet.size:()I
ifne 2
1: aload 1
areturn
2: StackMap locals:
StackMap stack:
aload 1
invokevirtual org.apache.cassandra.cql3.ResultSet.size:()I
ifne 4
3: aload 0
areturn
4: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.cql3.statements.ModificationStatement.$assertionsDisabled:Z
ifne 5
aload 0
invokevirtual org.apache.cassandra.cql3.ResultSet.size:()I
iconst_1
if_icmpeq 5
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
5: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.cql3.ResultSet.metadata:Lorg/apache/cassandra/cql3/ResultSet$ResultMetadata;
getfield org.apache.cassandra.cql3.ResultSet$ResultMetadata.names:Ljava/util/List;
invokeinterface java.util.List.size:()I
aload 1
getfield org.apache.cassandra.cql3.ResultSet.metadata:Lorg/apache/cassandra/cql3/ResultSet$ResultMetadata;
getfield org.apache.cassandra.cql3.ResultSet$ResultMetadata.names:Ljava/util/List;
invokeinterface java.util.List.size:()I
iadd
istore 2
start local 2 6: new java.util.ArrayList
dup
iload 2
invokespecial java.util.ArrayList.<init>:(I)V
astore 3
start local 3 7: aload 3
aload 0
getfield org.apache.cassandra.cql3.ResultSet.metadata:Lorg/apache/cassandra/cql3/ResultSet$ResultMetadata;
getfield org.apache.cassandra.cql3.ResultSet$ResultMetadata.names:Ljava/util/List;
invokeinterface java.util.List.addAll:(Ljava/util/Collection;)Z
pop
8: aload 3
aload 1
getfield org.apache.cassandra.cql3.ResultSet.metadata:Lorg/apache/cassandra/cql3/ResultSet$ResultMetadata;
getfield org.apache.cassandra.cql3.ResultSet$ResultMetadata.names:Ljava/util/List;
invokeinterface java.util.List.addAll:(Ljava/util/Collection;)Z
pop
9: new java.util.ArrayList
dup
aload 1
invokevirtual org.apache.cassandra.cql3.ResultSet.size:()I
invokespecial java.util.ArrayList.<init>:(I)V
astore 4
start local 4 10: iconst_0
istore 5
start local 5 11: goto 17
12: StackMap locals: org.apache.cassandra.cql3.ResultSet org.apache.cassandra.cql3.ResultSet int java.util.List java.util.List int
StackMap stack:
new java.util.ArrayList
dup
iload 2
invokespecial java.util.ArrayList.<init>:(I)V
astore 6
start local 6 13: aload 6
aload 0
getfield org.apache.cassandra.cql3.ResultSet.rows:Ljava/util/List;
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.util.Collection
invokeinterface java.util.List.addAll:(Ljava/util/Collection;)Z
pop
14: aload 6
aload 1
getfield org.apache.cassandra.cql3.ResultSet.rows:Ljava/util/List;
iload 5
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.util.Collection
invokeinterface java.util.List.addAll:(Ljava/util/Collection;)Z
pop
15: aload 4
aload 6
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 6 16: iinc 5 1
StackMap locals:
StackMap stack:
17: iload 5
aload 1
invokevirtual org.apache.cassandra.cql3.ResultSet.size:()I
if_icmplt 12
end local 5 18: new org.apache.cassandra.cql3.ResultSet
dup
new org.apache.cassandra.cql3.ResultSet$ResultMetadata
dup
aload 3
invokespecial org.apache.cassandra.cql3.ResultSet$ResultMetadata.<init>:(Ljava/util/List;)V
aload 4
invokespecial org.apache.cassandra.cql3.ResultSet.<init>:(Lorg/apache/cassandra/cql3/ResultSet$ResultMetadata;Ljava/util/List;)V
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 left Lorg/apache/cassandra/cql3/ResultSet;
0 19 1 right Lorg/apache/cassandra/cql3/ResultSet;
6 19 2 size I
7 19 3 specs Ljava/util/List<Lorg/apache/cassandra/cql3/ColumnSpecification;>;
10 19 4 rows Ljava/util/List<Ljava/util/List<Ljava/nio/ByteBuffer;>;>;
11 18 5 i I
13 16 6 row Ljava/util/List<Ljava/nio/ByteBuffer;>;
MethodParameters:
Name Flags
left
right
private static org.apache.cassandra.cql3.ResultSet buildCasFailureResultSet(org.apache.cassandra.db.rows.RowIterator, java.lang.Iterable<org.apache.cassandra.config.ColumnDefinition>, boolean, org.apache.cassandra.cql3.QueryOptions);
descriptor: (Lorg/apache/cassandra/db/rows/RowIterator;Ljava/lang/Iterable;ZLorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/cql3/ResultSet;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=9, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokeinterface org.apache.cassandra.db.rows.RowIterator.metadata:()Lorg/apache/cassandra/config/CFMetaData;
astore 4
start local 4 1: aload 1
ifnonnull 4
2: aload 4
invokestatic org.apache.cassandra.cql3.selection.Selection.wildcard:(Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/cql3/selection/Selection;
astore 5
start local 5 3: goto 16
end local 5 4: StackMap locals: org.apache.cassandra.config.CFMetaData
StackMap stack:
new java.util.LinkedHashSet
dup
invokespecial java.util.LinkedHashSet.<init>:()V
astore 6
start local 6 5: iload 2
ifeq 8
6: aload 6
aload 4
invokevirtual org.apache.cassandra.config.CFMetaData.partitionKeyColumns:()Ljava/util/List;
invokeinterface java.util.Set.addAll:(Ljava/util/Collection;)Z
pop
7: aload 6
aload 4
invokevirtual org.apache.cassandra.config.CFMetaData.clusteringColumns:()Ljava/util/List;
invokeinterface java.util.Set.addAll:(Ljava/util/Collection;)Z
pop
8: StackMap locals: org.apache.cassandra.db.rows.RowIterator java.lang.Iterable int org.apache.cassandra.cql3.QueryOptions org.apache.cassandra.config.CFMetaData top java.util.Set
StackMap stack:
aload 4
invokevirtual org.apache.cassandra.config.CFMetaData.isSuper:()Z
ifeq 11
aload 4
invokevirtual org.apache.cassandra.config.CFMetaData.isDense:()Z
ifeq 11
9: aload 6
aload 4
invokevirtual org.apache.cassandra.config.CFMetaData.superColumnValueColumn:()Lorg/apache/cassandra/config/ColumnDefinition;
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
10: goto 15
11: StackMap locals:
StackMap stack:
aload 1
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 8
goto 14
StackMap locals: org.apache.cassandra.db.rows.RowIterator java.lang.Iterable int org.apache.cassandra.cql3.QueryOptions org.apache.cassandra.config.CFMetaData top java.util.Set top java.util.Iterator
StackMap stack:
12: aload 8
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.config.ColumnDefinition
astore 7
start local 7 13: aload 6
aload 7
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
end local 7 14: StackMap locals:
StackMap stack:
aload 8
invokeinterface java.util.Iterator.hasNext:()Z
ifne 12
15: StackMap locals: org.apache.cassandra.db.rows.RowIterator java.lang.Iterable int org.apache.cassandra.cql3.QueryOptions org.apache.cassandra.config.CFMetaData top java.util.Set
StackMap stack:
aload 4
new java.util.ArrayList
dup
aload 6
invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
invokestatic org.apache.cassandra.cql3.selection.Selection.forColumns:(Lorg/apache/cassandra/config/CFMetaData;Ljava/util/List;)Lorg/apache/cassandra/cql3/selection/Selection;
astore 5
end local 6 start local 5 16: StackMap locals: org.apache.cassandra.db.rows.RowIterator java.lang.Iterable int org.apache.cassandra.cql3.QueryOptions org.apache.cassandra.config.CFMetaData org.apache.cassandra.cql3.selection.Selection
StackMap stack:
aload 5
aload 3
iconst_0
invokevirtual org.apache.cassandra.cql3.selection.Selection.resultSetBuilder:(Lorg/apache/cassandra/cql3/QueryOptions;Z)Lorg/apache/cassandra/cql3/selection/Selection$ResultSetBuilder;
astore 6
start local 6 17: aload 4
aload 5
invokestatic org.apache.cassandra.cql3.statements.SelectStatement.forSelection:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/cql3/selection/Selection;)Lorg/apache/cassandra/cql3/statements/SelectStatement;
aload 0
18: aload 3
19: aload 6
20: invokestatic org.apache.cassandra.utils.FBUtilities.nowInSeconds:()I
21: 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
22: aload 6
invokevirtual org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder.build:()Lorg/apache/cassandra/cql3/ResultSet;
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 23 0 partition Lorg/apache/cassandra/db/rows/RowIterator;
0 23 1 columnsWithConditions Ljava/lang/Iterable<Lorg/apache/cassandra/config/ColumnDefinition;>;
0 23 2 isBatch Z
0 23 3 options Lorg/apache/cassandra/cql3/QueryOptions;
1 23 4 cfm Lorg/apache/cassandra/config/CFMetaData;
3 4 5 selection Lorg/apache/cassandra/cql3/selection/Selection;
16 23 5 selection Lorg/apache/cassandra/cql3/selection/Selection;
5 16 6 defs Ljava/util/Set<Lorg/apache/cassandra/config/ColumnDefinition;>;
13 14 7 def Lorg/apache/cassandra/config/ColumnDefinition;
17 23 6 builder Lorg/apache/cassandra/cql3/selection/Selection$ResultSetBuilder;
Exceptions:
throws org.apache.cassandra.exceptions.InvalidRequestException
Signature: (Lorg/apache/cassandra/db/rows/RowIterator;Ljava/lang/Iterable<Lorg/apache/cassandra/config/ColumnDefinition;>;ZLorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/cql3/ResultSet;
MethodParameters:
Name Flags
partition
columnsWithConditions
isBatch
options
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: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.hasConditions:()Z
ifeq 2
1: aload 0
aload 1
aload 2
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.executeInternalWithCondition:(Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/transport/messages/ResultMessage;
goto 3
2: StackMap locals:
StackMap stack:
aload 0
aload 1
aload 2
invokestatic java.lang.System.nanoTime:()J
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.executeInternalWithoutCondition:(Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/QueryOptions;J)Lorg/apache/cassandra/transport/messages/ResultMessage;
3: StackMap locals:
StackMap stack: org.apache.cassandra.transport.messages.ResultMessage
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
0 4 1 queryState Lorg/apache/cassandra/service/QueryState;
0 4 2 options Lorg/apache/cassandra/cql3/QueryOptions;
Exceptions:
throws org.apache.cassandra.exceptions.RequestValidationException, org.apache.cassandra.exceptions.RequestExecutionException
MethodParameters:
Name Flags
queryState
options
public org.apache.cassandra.transport.messages.ResultMessage executeInternalWithoutCondition(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: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 2
iconst_1
aload 1
invokevirtual org.apache.cassandra.service.QueryState.getTimestamp:()J
lload 3
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.getMutations:(Lorg/apache/cassandra/cql3/QueryOptions;ZJJ)Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 6
goto 3
StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.service.QueryState org.apache.cassandra.cql3.QueryOptions long top java.util.Iterator
StackMap stack:
1: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.IMutation
astore 5
start local 5 2: aload 5
invokeinterface org.apache.cassandra.db.IMutation.apply:()V
end local 5 3: StackMap locals:
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
4: aconst_null
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
0 5 1 queryState Lorg/apache/cassandra/service/QueryState;
0 5 2 options Lorg/apache/cassandra/cql3/QueryOptions;
0 5 3 queryStartNanoTime J
2 3 5 mutation Lorg/apache/cassandra/db/IMutation;
Exceptions:
throws org.apache.cassandra.exceptions.RequestValidationException, org.apache.cassandra.exceptions.RequestExecutionException
MethodParameters:
Name Flags
queryState
options
queryStartNanoTime
public org.apache.cassandra.transport.messages.ResultMessage executeInternalWithCondition(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: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=7, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.makeCasRequest:(Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/cql3/statements/CQL3CasRequest;
astore 3
start local 3 1: aconst_null
astore 4
aconst_null
astore 5
2: aload 3
aload 1
invokestatic org.apache.cassandra.cql3.statements.ModificationStatement.casInternal:(Lorg/apache/cassandra/cql3/statements/CQL3CasRequest;Lorg/apache/cassandra/service/QueryState;)Lorg/apache/cassandra/db/rows/RowIterator;
astore 6
start local 6 3: new org.apache.cassandra.transport.messages.ResultMessage$Rows
dup
aload 0
aload 6
aload 2
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.buildCasResultSet:(Lorg/apache/cassandra/db/rows/RowIterator;Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/cql3/ResultSet;
invokespecial org.apache.cassandra.transport.messages.ResultMessage$Rows.<init>:(Lorg/apache/cassandra/cql3/ResultSet;)V
4: aload 6
ifnull 5
aload 6
invokeinterface org.apache.cassandra.db.rows.RowIterator.close:()V
5: StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.service.QueryState org.apache.cassandra.cql3.QueryOptions org.apache.cassandra.cql3.statements.CQL3CasRequest java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.rows.RowIterator
StackMap stack: org.apache.cassandra.transport.messages.ResultMessage$Rows
areturn
StackMap locals:
StackMap stack: java.lang.Throwable
6: astore 4
7: aload 6
ifnull 8
aload 6
invokeinterface org.apache.cassandra.db.rows.RowIterator.close:()V
end local 6 StackMap locals:
StackMap stack:
8: aload 4
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
9: astore 5
aload 4
ifnonnull 10
aload 5
astore 4
goto 11
StackMap locals:
StackMap stack:
10: aload 4
aload 5
if_acmpeq 11
aload 4
aload 5
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
11: aload 4
athrow
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/ModificationStatement;
0 12 1 state Lorg/apache/cassandra/service/QueryState;
0 12 2 options Lorg/apache/cassandra/cql3/QueryOptions;
1 12 3 request Lorg/apache/cassandra/cql3/statements/CQL3CasRequest;
3 8 6 result Lorg/apache/cassandra/db/rows/RowIterator;
Exception table:
from to target type
3 4 6 any
2 5 9 any
6 9 9 any
Exceptions:
throws org.apache.cassandra.exceptions.RequestValidationException, org.apache.cassandra.exceptions.RequestExecutionException
MethodParameters:
Name Flags
state
options
static org.apache.cassandra.db.rows.RowIterator casInternal(org.apache.cassandra.cql3.statements.CQL3CasRequest, org.apache.cassandra.service.QueryState);
descriptor: (Lorg/apache/cassandra/cql3/statements/CQL3CasRequest;Lorg/apache/cassandra/service/QueryState;)Lorg/apache/cassandra/db/rows/RowIterator;
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=9, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual org.apache.cassandra.service.QueryState.getTimestamp:()J
invokestatic org.apache.cassandra.utils.UUIDGen.getTimeUUIDFromMicros:(J)Ljava/util/UUID;
astore 2
start local 2 1: aload 0
invokestatic org.apache.cassandra.utils.FBUtilities.nowInSeconds:()I
invokevirtual org.apache.cassandra.cql3.statements.CQL3CasRequest.readCommand:(I)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
astore 3
start local 3 2: aconst_null
astore 5
aconst_null
astore 6
3: aload 3
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.executionController:()Lorg/apache/cassandra/db/ReadExecutionController;
astore 7
start local 7 4: aload 3
aload 7
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.executeInternal:(Lorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/db/partitions/PartitionIterator;
astore 8
start local 8 5: aload 8
aload 3
invokestatic org.apache.cassandra.db.partitions.PartitionIterators.getOnlyElement:(Lorg/apache/cassandra/db/partitions/PartitionIterator;Lorg/apache/cassandra/db/SinglePartitionReadCommand;)Lorg/apache/cassandra/db/rows/RowIterator;
invokestatic org.apache.cassandra.db.partitions.FilteredPartition.create:(Lorg/apache/cassandra/db/rows/RowIterator;)Lorg/apache/cassandra/db/partitions/FilteredPartition;
astore 4
start local 4 6: aload 8
ifnull 9
aload 8
invokeinterface org.apache.cassandra.db.partitions.PartitionIterator.close:()V
goto 9
end local 4 StackMap locals: org.apache.cassandra.cql3.statements.CQL3CasRequest org.apache.cassandra.service.QueryState java.util.UUID org.apache.cassandra.db.SinglePartitionReadCommand top java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.ReadExecutionController org.apache.cassandra.db.partitions.PartitionIterator
StackMap stack: java.lang.Throwable
7: astore 5
aload 8
ifnull 8
aload 8
invokeinterface org.apache.cassandra.db.partitions.PartitionIterator.close:()V
end local 8 StackMap locals:
StackMap stack:
8: aload 5
athrow
start local 4 StackMap locals: org.apache.cassandra.cql3.statements.CQL3CasRequest org.apache.cassandra.service.QueryState java.util.UUID org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.partitions.FilteredPartition java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.ReadExecutionController
StackMap stack:
9: aload 7
ifnull 17
aload 7
invokevirtual org.apache.cassandra.db.ReadExecutionController.close:()V
goto 17
end local 4 StackMap locals: org.apache.cassandra.cql3.statements.CQL3CasRequest org.apache.cassandra.service.QueryState java.util.UUID org.apache.cassandra.db.SinglePartitionReadCommand top java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.ReadExecutionController
StackMap stack: java.lang.Throwable
10: astore 6
aload 5
ifnonnull 11
aload 6
astore 5
goto 12
StackMap locals:
StackMap stack:
11: aload 5
aload 6
if_acmpeq 12
aload 5
aload 6
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
12: aload 7
ifnull 13
aload 7
invokevirtual org.apache.cassandra.db.ReadExecutionController.close:()V
end local 7 StackMap locals:
StackMap stack:
13: aload 5
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
14: astore 6
aload 5
ifnonnull 15
aload 6
astore 5
goto 16
StackMap locals:
StackMap stack:
15: aload 5
aload 6
if_acmpeq 16
aload 5
aload 6
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
16: aload 5
athrow
start local 4 17: StackMap locals: org.apache.cassandra.cql3.statements.CQL3CasRequest org.apache.cassandra.service.QueryState java.util.UUID org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.partitions.FilteredPartition
StackMap stack:
aload 0
aload 4
invokevirtual org.apache.cassandra.cql3.statements.CQL3CasRequest.appliesTo:(Lorg/apache/cassandra/db/partitions/FilteredPartition;)Z
ifne 19
18: aload 4
invokevirtual org.apache.cassandra.db.partitions.FilteredPartition.rowIterator:()Lorg/apache/cassandra/db/rows/RowIterator;
areturn
19: StackMap locals:
StackMap stack:
aload 0
aload 4
invokevirtual org.apache.cassandra.cql3.statements.CQL3CasRequest.makeUpdates:(Lorg/apache/cassandra/db/partitions/FilteredPartition;)Lorg/apache/cassandra/db/partitions/PartitionUpdate;
astore 5
start local 5 20: getstatic org.apache.cassandra.triggers.TriggerExecutor.instance:Lorg/apache/cassandra/triggers/TriggerExecutor;
aload 5
invokevirtual org.apache.cassandra.triggers.TriggerExecutor.execute:(Lorg/apache/cassandra/db/partitions/PartitionUpdate;)Lorg/apache/cassandra/db/partitions/PartitionUpdate;
astore 5
21: aload 2
aload 5
invokestatic org.apache.cassandra.service.paxos.Commit.newProposal:(Ljava/util/UUID;Lorg/apache/cassandra/db/partitions/PartitionUpdate;)Lorg/apache/cassandra/service/paxos/Commit;
astore 6
start local 6 22: aload 6
invokevirtual org.apache.cassandra.service.paxos.Commit.makeMutation:()Lorg/apache/cassandra/db/Mutation;
invokevirtual org.apache.cassandra.db.Mutation.apply:()V
23: aconst_null
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 24 0 request Lorg/apache/cassandra/cql3/statements/CQL3CasRequest;
0 24 1 state Lorg/apache/cassandra/service/QueryState;
1 24 2 ballot Ljava/util/UUID;
2 24 3 readCommand Lorg/apache/cassandra/db/SinglePartitionReadCommand;
6 7 4 current Lorg/apache/cassandra/db/partitions/FilteredPartition;
9 10 4 current Lorg/apache/cassandra/db/partitions/FilteredPartition;
17 24 4 current Lorg/apache/cassandra/db/partitions/FilteredPartition;
4 13 7 executionController Lorg/apache/cassandra/db/ReadExecutionController;
5 8 8 iter Lorg/apache/cassandra/db/partitions/PartitionIterator;
20 24 5 updates Lorg/apache/cassandra/db/partitions/PartitionUpdate;
22 24 6 proposal Lorg/apache/cassandra/service/paxos/Commit;
Exception table:
from to target type
5 6 7 any
4 9 10 any
3 14 14 any
MethodParameters:
Name Flags
request
state
private java.util.Collection<? extends org.apache.cassandra.db.IMutation> getMutations(org.apache.cassandra.cql3.QueryOptions, boolean, long, long);
descriptor: (Lorg/apache/cassandra/cql3/QueryOptions;ZJJ)Ljava/util/Collection;
flags: (0x0002) ACC_PRIVATE
Code:
stack=8, locals=8, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 5 0: new org.apache.cassandra.cql3.statements.UpdatesCollector
dup
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.updatedColumns:Lorg/apache/cassandra/db/PartitionColumns;
invokestatic java.util.Collections.singletonMap:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/util/Map;
iconst_1
invokespecial org.apache.cassandra.cql3.statements.UpdatesCollector.<init>:(Ljava/util/Map;I)V
astore 7
start local 7 1: aload 0
aload 7
aload 1
iload 2
lload 3
lload 5
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.addUpdates:(Lorg/apache/cassandra/cql3/statements/UpdatesCollector;Lorg/apache/cassandra/cql3/QueryOptions;ZJJ)V
2: aload 7
invokevirtual org.apache.cassandra.cql3.statements.UpdatesCollector.validateIndexedColumns:()V
3: aload 7
invokevirtual org.apache.cassandra.cql3.statements.UpdatesCollector.toMutations:()Ljava/util/Collection;
areturn
end local 7 end local 5 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/ModificationStatement;
0 4 1 options Lorg/apache/cassandra/cql3/QueryOptions;
0 4 2 local Z
0 4 3 now J
0 4 5 queryStartNanoTime J
1 4 7 collector Lorg/apache/cassandra/cql3/statements/UpdatesCollector;
Signature: (Lorg/apache/cassandra/cql3/QueryOptions;ZJJ)Ljava/util/Collection<+Lorg/apache/cassandra/db/IMutation;>;
MethodParameters:
Name Flags
options
local
now
queryStartNanoTime
final void addUpdates(org.apache.cassandra.cql3.statements.UpdatesCollector, org.apache.cassandra.cql3.QueryOptions, boolean, long, long);
descriptor: (Lorg/apache/cassandra/cql3/statements/UpdatesCollector;Lorg/apache/cassandra/cql3/QueryOptions;ZJJ)V
flags: (0x0010) ACC_FINAL
Code:
stack=10, locals=21, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 6 0: aload 0
aload 2
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.buildPartitionKeyNames:(Lorg/apache/cassandra/cql3/QueryOptions;)Ljava/util/List;
astore 8
start local 8 1: aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.hasSlices:()Z
ifeq 24
2: aload 0
aload 2
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.createSlices:(Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/db/Slices;
astore 9
start local 9 3: aload 9
invokevirtual org.apache.cassandra.db.Slices.isEmpty:()Z
ifeq 5
4: return
5: StackMap locals: java.util.List org.apache.cassandra.db.Slices
StackMap stack:
aload 0
aload 8
6: new org.apache.cassandra.db.filter.ClusteringIndexSliceFilter
dup
aload 9
iconst_0
invokespecial org.apache.cassandra.db.filter.ClusteringIndexSliceFilter.<init>:(Lorg/apache/cassandra/db/Slices;Z)V
7: aload 2
8: getstatic org.apache.cassandra.db.filter.DataLimits.NONE:Lorg/apache/cassandra/db/filter/DataLimits;
9: iload 3
10: lload 4
11: lload 6
12: invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.makeUpdateParameters:(Ljava/util/Collection;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/cql3/QueryOptions;Lorg/apache/cassandra/db/filter/DataLimits;ZJJ)Lorg/apache/cassandra/cql3/UpdateParameters;
astore 10
start local 10 13: aload 8
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 12
goto 22
StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.cql3.statements.UpdatesCollector org.apache.cassandra.cql3.QueryOptions int long long java.util.List org.apache.cassandra.db.Slices org.apache.cassandra.cql3.UpdateParameters top java.util.Iterator
StackMap stack:
14: aload 12
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.nio.ByteBuffer
astore 11
start local 11 15: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
aload 11
invokestatic org.apache.cassandra.thrift.ThriftValidation.validateKey:(Lorg/apache/cassandra/config/CFMetaData;Ljava/nio/ByteBuffer;)V
16: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
aload 11
invokevirtual org.apache.cassandra.config.CFMetaData.decorateKey:(Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/db/DecoratedKey;
astore 13
start local 13 17: aload 1
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
aload 13
aload 2
invokevirtual org.apache.cassandra.cql3.QueryOptions.getConsistency:()Lorg/apache/cassandra/db/ConsistencyLevel;
invokevirtual org.apache.cassandra.cql3.statements.UpdatesCollector.getPartitionUpdate:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/ConsistencyLevel;)Lorg/apache/cassandra/db/partitions/PartitionUpdate;
astore 14
start local 14 18: aload 9
invokevirtual org.apache.cassandra.db.Slices.iterator:()Ljava/util/Iterator;
astore 16
goto 21
StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.cql3.statements.UpdatesCollector org.apache.cassandra.cql3.QueryOptions int long long java.util.List org.apache.cassandra.db.Slices org.apache.cassandra.cql3.UpdateParameters java.nio.ByteBuffer java.util.Iterator org.apache.cassandra.db.DecoratedKey org.apache.cassandra.db.partitions.PartitionUpdate top java.util.Iterator
StackMap stack:
19: aload 16
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.Slice
astore 15
start local 15 20: aload 0
aload 14
aload 15
aload 10
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.addUpdateForKey:(Lorg/apache/cassandra/db/partitions/PartitionUpdate;Lorg/apache/cassandra/db/Slice;Lorg/apache/cassandra/cql3/UpdateParameters;)V
end local 15 21: StackMap locals:
StackMap stack:
aload 16
invokeinterface java.util.Iterator.hasNext:()Z
ifne 19
end local 14 end local 13 end local 11 22: StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.cql3.statements.UpdatesCollector org.apache.cassandra.cql3.QueryOptions int long long java.util.List org.apache.cassandra.db.Slices org.apache.cassandra.cql3.UpdateParameters top java.util.Iterator
StackMap stack:
aload 12
invokeinterface java.util.Iterator.hasNext:()Z
ifne 14
end local 10 end local 9 23: goto 50
24: StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.cql3.statements.UpdatesCollector org.apache.cassandra.cql3.QueryOptions int long long java.util.List
StackMap stack:
aload 0
aload 2
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.createClustering:(Lorg/apache/cassandra/cql3/QueryOptions;)Ljava/util/NavigableSet;
astore 9
start local 9 25: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.hasClusteringColumnsRestrictions:()Z
ifeq 27
aload 9
invokeinterface java.util.NavigableSet.isEmpty:()Z
ifeq 27
26: return
27: StackMap locals: java.util.NavigableSet
StackMap stack:
aload 0
aload 8
aload 9
aload 2
iload 3
lload 4
lload 6
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.makeUpdateParameters:(Ljava/util/Collection;Ljava/util/NavigableSet;Lorg/apache/cassandra/cql3/QueryOptions;ZJJ)Lorg/apache/cassandra/cql3/UpdateParameters;
astore 10
start local 10 28: aload 8
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 12
goto 49
StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.cql3.statements.UpdatesCollector org.apache.cassandra.cql3.QueryOptions int long long java.util.List java.util.NavigableSet org.apache.cassandra.cql3.UpdateParameters top java.util.Iterator
StackMap stack:
29: aload 12
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.nio.ByteBuffer
astore 11
start local 11 30: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
aload 11
invokestatic org.apache.cassandra.thrift.ThriftValidation.validateKey:(Lorg/apache/cassandra/config/CFMetaData;Ljava/nio/ByteBuffer;)V
31: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
aload 11
invokevirtual org.apache.cassandra.config.CFMetaData.decorateKey:(Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/db/DecoratedKey;
astore 13
start local 13 32: aload 1
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
aload 13
aload 2
invokevirtual org.apache.cassandra.cql3.QueryOptions.getConsistency:()Lorg/apache/cassandra/db/ConsistencyLevel;
invokevirtual org.apache.cassandra.cql3.statements.UpdatesCollector.getPartitionUpdate:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/ConsistencyLevel;)Lorg/apache/cassandra/db/partitions/PartitionUpdate;
astore 14
start local 14 33: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.restrictions:Lorg/apache/cassandra/cql3/restrictions/StatementRestrictions;
invokevirtual org.apache.cassandra.cql3.restrictions.StatementRestrictions.hasClusteringColumnsRestrictions:()Z
ifne 36
34: aload 0
aload 14
getstatic org.apache.cassandra.db.Clustering.EMPTY:Lorg/apache/cassandra/db/Clustering;
aload 10
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.addUpdateForKey:(Lorg/apache/cassandra/db/partitions/PartitionUpdate;Lorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/cql3/UpdateParameters;)V
35: goto 49
36: StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.cql3.statements.UpdatesCollector org.apache.cassandra.cql3.QueryOptions int long long java.util.List java.util.NavigableSet org.apache.cassandra.cql3.UpdateParameters java.nio.ByteBuffer java.util.Iterator org.apache.cassandra.db.DecoratedKey org.apache.cassandra.db.partitions.PartitionUpdate
StackMap stack:
aload 9
invokeinterface java.util.NavigableSet.iterator:()Ljava/util/Iterator;
astore 16
goto 48
StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.cql3.statements.UpdatesCollector org.apache.cassandra.cql3.QueryOptions int long long java.util.List java.util.NavigableSet org.apache.cassandra.cql3.UpdateParameters java.nio.ByteBuffer java.util.Iterator org.apache.cassandra.db.DecoratedKey org.apache.cassandra.db.partitions.PartitionUpdate top java.util.Iterator
StackMap stack:
37: aload 16
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.Clustering
astore 15
start local 15 38: aload 15
invokeinterface org.apache.cassandra.db.Clustering.getRawValues:()[Ljava/nio/ByteBuffer;
dup
astore 20
arraylength
istore 19
iconst_0
istore 18
goto 46
StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.cql3.statements.UpdatesCollector org.apache.cassandra.cql3.QueryOptions int long long java.util.List java.util.NavigableSet org.apache.cassandra.cql3.UpdateParameters java.nio.ByteBuffer java.util.Iterator org.apache.cassandra.db.DecoratedKey org.apache.cassandra.db.partitions.PartitionUpdate org.apache.cassandra.db.Clustering java.util.Iterator top int int java.nio.ByteBuffer[]
StackMap stack:
39: aload 20
iload 18
aaload
astore 17
start local 17 40: aload 17
ifnull 45
aload 17
invokevirtual java.nio.ByteBuffer.remaining:()I
ldc 65535
if_icmple 45
41: new org.apache.cassandra.exceptions.InvalidRequestException
dup
ldc "Key length of %d is longer than maximum of %d"
iconst_2
anewarray java.lang.Object
dup
iconst_0
42: aload 15
invokeinterface org.apache.cassandra.db.Clustering.dataSize:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
43: ldc 65535
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
44: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokespecial org.apache.cassandra.exceptions.InvalidRequestException.<init>:(Ljava/lang/String;)V
athrow
end local 17 45: StackMap locals:
StackMap stack:
iinc 18 1
StackMap locals:
StackMap stack:
46: iload 18
iload 19
if_icmplt 39
47: aload 0
aload 14
aload 15
aload 10
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.addUpdateForKey:(Lorg/apache/cassandra/db/partitions/PartitionUpdate;Lorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/cql3/UpdateParameters;)V
end local 15 48: StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.cql3.statements.UpdatesCollector org.apache.cassandra.cql3.QueryOptions int long long java.util.List java.util.NavigableSet org.apache.cassandra.cql3.UpdateParameters java.nio.ByteBuffer java.util.Iterator org.apache.cassandra.db.DecoratedKey org.apache.cassandra.db.partitions.PartitionUpdate top java.util.Iterator
StackMap stack:
aload 16
invokeinterface java.util.Iterator.hasNext:()Z
ifne 37
end local 14 end local 13 end local 11 49: StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.cql3.statements.UpdatesCollector org.apache.cassandra.cql3.QueryOptions int long long java.util.List java.util.NavigableSet org.apache.cassandra.cql3.UpdateParameters top java.util.Iterator
StackMap stack:
aload 12
invokeinterface java.util.Iterator.hasNext:()Z
ifne 29
end local 10 end local 9 50: StackMap locals: org.apache.cassandra.cql3.statements.ModificationStatement org.apache.cassandra.cql3.statements.UpdatesCollector org.apache.cassandra.cql3.QueryOptions int long long java.util.List
StackMap stack:
return
end local 8 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 51 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
0 51 1 collector Lorg/apache/cassandra/cql3/statements/UpdatesCollector;
0 51 2 options Lorg/apache/cassandra/cql3/QueryOptions;
0 51 3 local Z
0 51 4 now J
0 51 6 queryStartNanoTime J
1 51 8 keys Ljava/util/List<Ljava/nio/ByteBuffer;>;
3 23 9 slices Lorg/apache/cassandra/db/Slices;
13 23 10 params Lorg/apache/cassandra/cql3/UpdateParameters;
15 22 11 key Ljava/nio/ByteBuffer;
17 22 13 dk Lorg/apache/cassandra/db/DecoratedKey;
18 22 14 upd Lorg/apache/cassandra/db/partitions/PartitionUpdate;
20 21 15 slice Lorg/apache/cassandra/db/Slice;
25 50 9 clusterings Ljava/util/NavigableSet<Lorg/apache/cassandra/db/Clustering;>;
28 50 10 params Lorg/apache/cassandra/cql3/UpdateParameters;
30 49 11 key Ljava/nio/ByteBuffer;
32 49 13 dk Lorg/apache/cassandra/db/DecoratedKey;
33 49 14 upd Lorg/apache/cassandra/db/partitions/PartitionUpdate;
38 48 15 clustering Lorg/apache/cassandra/db/Clustering;
40 45 17 c Ljava/nio/ByteBuffer;
MethodParameters:
Name Flags
collector
options
local
now
queryStartNanoTime
org.apache.cassandra.db.Slices createSlices(org.apache.cassandra.cql3.QueryOptions);
descriptor: (Lorg/apache/cassandra/cql3/QueryOptions;)Lorg/apache/cassandra/db/Slices;
flags: (0x0000)
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.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.ModificationStatement.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: aload 0
aload 2
aload 3
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.toSlices:(Ljava/util/SortedSet;Ljava/util/SortedSet;)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 3 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
0 3 1 options Lorg/apache/cassandra/cql3/QueryOptions;
1 3 2 startBounds Ljava/util/SortedSet<Lorg/apache/cassandra/db/ClusteringBound;>;
2 3 3 endBounds Ljava/util/SortedSet<Lorg/apache/cassandra/db/ClusteringBound;>;
MethodParameters:
Name Flags
options
private org.apache.cassandra.cql3.UpdateParameters makeUpdateParameters(java.util.Collection<java.nio.ByteBuffer>, java.util.NavigableSet<org.apache.cassandra.db.Clustering>, org.apache.cassandra.cql3.QueryOptions, boolean, long, long);
descriptor: (Ljava/util/Collection;Ljava/util/NavigableSet;Lorg/apache/cassandra/cql3/QueryOptions;ZJJ)Lorg/apache/cassandra/cql3/UpdateParameters;
flags: (0x0002) ACC_PRIVATE
Code:
stack=10, locals=9, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 7 0: aload 2
getstatic org.apache.cassandra.db.Clustering.STATIC_CLUSTERING:Lorg/apache/cassandra/db/Clustering;
invokeinterface java.util.NavigableSet.contains:(Ljava/lang/Object;)Z
ifeq 9
1: aload 0
aload 1
2: 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
3: aload 3
4: iconst_1
invokestatic org.apache.cassandra.db.filter.DataLimits.cqlLimits:(I)Lorg/apache/cassandra/db/filter/DataLimits;
5: iload 4
6: lload 5
7: lload 7
8: invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.makeUpdateParameters:(Ljava/util/Collection;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/cql3/QueryOptions;Lorg/apache/cassandra/db/filter/DataLimits;ZJJ)Lorg/apache/cassandra/cql3/UpdateParameters;
areturn
9: StackMap locals:
StackMap stack:
aload 0
aload 1
10: new org.apache.cassandra.db.filter.ClusteringIndexNamesFilter
dup
aload 2
iconst_0
invokespecial org.apache.cassandra.db.filter.ClusteringIndexNamesFilter.<init>:(Ljava/util/NavigableSet;Z)V
11: aload 3
12: getstatic org.apache.cassandra.db.filter.DataLimits.NONE:Lorg/apache/cassandra/db/filter/DataLimits;
13: iload 4
14: lload 5
15: lload 7
16: invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.makeUpdateParameters:(Ljava/util/Collection;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/cql3/QueryOptions;Lorg/apache/cassandra/db/filter/DataLimits;ZJJ)Lorg/apache/cassandra/cql3/UpdateParameters;
areturn
end local 7 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 17 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
0 17 1 keys Ljava/util/Collection<Ljava/nio/ByteBuffer;>;
0 17 2 clusterings Ljava/util/NavigableSet<Lorg/apache/cassandra/db/Clustering;>;
0 17 3 options Lorg/apache/cassandra/cql3/QueryOptions;
0 17 4 local Z
0 17 5 now J
0 17 7 queryStartNanoTime J
Signature: (Ljava/util/Collection<Ljava/nio/ByteBuffer;>;Ljava/util/NavigableSet<Lorg/apache/cassandra/db/Clustering;>;Lorg/apache/cassandra/cql3/QueryOptions;ZJJ)Lorg/apache/cassandra/cql3/UpdateParameters;
MethodParameters:
Name Flags
keys
clusterings
options
local
now
queryStartNanoTime
private org.apache.cassandra.cql3.UpdateParameters makeUpdateParameters(java.util.Collection<java.nio.ByteBuffer>, org.apache.cassandra.db.filter.ClusteringIndexFilter, org.apache.cassandra.cql3.QueryOptions, org.apache.cassandra.db.filter.DataLimits, boolean, long, long);
descriptor: (Ljava/util/Collection;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/cql3/QueryOptions;Lorg/apache/cassandra/db/filter/DataLimits;ZJJ)Lorg/apache/cassandra/cql3/UpdateParameters;
flags: (0x0002) ACC_PRIVATE
Code:
stack=9, locals=11, args_size=8
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 8 0: aload 0
aload 1
aload 2
aload 4
iload 5
aload 3
invokevirtual org.apache.cassandra.cql3.QueryOptions.getConsistency:()Lorg/apache/cassandra/db/ConsistencyLevel;
lload 8
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.readRequiredLists:(Ljava/util/Collection;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/db/filter/DataLimits;ZLorg/apache/cassandra/db/ConsistencyLevel;J)Ljava/util/Map;
astore 10
start local 10 1: new org.apache.cassandra.cql3.UpdateParameters
dup
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
aload 0
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.updatedColumns:()Lorg/apache/cassandra/db/PartitionColumns;
aload 3
aload 0
lload 6
aload 3
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.getTimestamp:(JLorg/apache/cassandra/cql3/QueryOptions;)J
aload 0
aload 3
invokevirtual org.apache.cassandra.cql3.statements.ModificationStatement.getTimeToLive:(Lorg/apache/cassandra/cql3/QueryOptions;)I
aload 10
invokespecial org.apache.cassandra.cql3.UpdateParameters.<init>:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/PartitionColumns;Lorg/apache/cassandra/cql3/QueryOptions;JILjava/util/Map;)V
areturn
end local 10 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 2 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
0 2 1 keys Ljava/util/Collection<Ljava/nio/ByteBuffer;>;
0 2 2 filter Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
0 2 3 options Lorg/apache/cassandra/cql3/QueryOptions;
0 2 4 limits Lorg/apache/cassandra/db/filter/DataLimits;
0 2 5 local Z
0 2 6 now J
0 2 8 queryStartNanoTime J
1 2 10 lists Ljava/util/Map<Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/partitions/Partition;>;
Signature: (Ljava/util/Collection<Ljava/nio/ByteBuffer;>;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/cql3/QueryOptions;Lorg/apache/cassandra/db/filter/DataLimits;ZJJ)Lorg/apache/cassandra/cql3/UpdateParameters;
MethodParameters:
Name Flags
keys
filter
options
limits
local
now
queryStartNanoTime
private org.apache.cassandra.db.Slices toSlices(java.util.SortedSet<org.apache.cassandra.db.ClusteringBound>, java.util.SortedSet<org.apache.cassandra.db.ClusteringBound>);
descriptor: (Ljava/util/SortedSet;Ljava/util/SortedSet;)Lorg/apache/cassandra/db/Slices;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=7, args_size=3
start local 0 start local 1 start local 2 0: getstatic org.apache.cassandra.cql3.statements.ModificationStatement.$assertionsDisabled:Z
ifne 1
aload 1
invokeinterface java.util.SortedSet.size:()I
aload 2
invokeinterface java.util.SortedSet.size:()I
if_icmpeq 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
new org.apache.cassandra.db.Slices$Builder
dup
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.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 2: aload 1
invokeinterface java.util.SortedSet.iterator:()Ljava/util/Iterator;
astore 4
start local 4 3: aload 2
invokeinterface java.util.SortedSet.iterator:()Ljava/util/Iterator;
astore 5
start local 5 4: goto 8
5: StackMap locals: org.apache.cassandra.db.Slices$Builder java.util.Iterator java.util.Iterator
StackMap stack:
aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.ClusteringBound
aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.ClusteringBound
invokestatic org.apache.cassandra.db.Slice.make:(Lorg/apache/cassandra/db/ClusteringBound;Lorg/apache/cassandra/db/ClusteringBound;)Lorg/apache/cassandra/db/Slice;
astore 6
start local 6 6: aload 6
aload 0
getfield org.apache.cassandra.cql3.statements.ModificationStatement.cfm:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.comparator:Lorg/apache/cassandra/db/ClusteringComparator;
invokevirtual org.apache.cassandra.db.Slice.isEmpty:(Lorg/apache/cassandra/db/ClusteringComparator;)Z
ifne 8
7: aload 3
aload 6
invokevirtual org.apache.cassandra.db.Slices$Builder.add:(Lorg/apache/cassandra/db/Slice;)Lorg/apache/cassandra/db/Slices$Builder;
pop
end local 6 8: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 5
9: aload 3
invokevirtual org.apache.cassandra.db.Slices$Builder.build:()Lorg/apache/cassandra/db/Slices;
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 10 0 this Lorg/apache/cassandra/cql3/statements/ModificationStatement;
0 10 1 startBounds Ljava/util/SortedSet<Lorg/apache/cassandra/db/ClusteringBound;>;
0 10 2 endBounds Ljava/util/SortedSet<Lorg/apache/cassandra/db/ClusteringBound;>;
2 10 3 builder Lorg/apache/cassandra/db/Slices$Builder;
3 10 4 starts Ljava/util/Iterator<Lorg/apache/cassandra/db/ClusteringBound;>;
4 10 5 ends Ljava/util/Iterator<Lorg/apache/cassandra/db/ClusteringBound;>;
6 8 6 slice Lorg/apache/cassandra/db/Slice;
Signature: (Ljava/util/SortedSet<Lorg/apache/cassandra/db/ClusteringBound;>;Ljava/util/SortedSet<Lorg/apache/cassandra/db/ClusteringBound;>;)Lorg/apache/cassandra/db/Slices;
MethodParameters:
Name Flags
startBounds
endBounds
}
SourceFile: "ModificationStatement.java"
NestMembers:
org.apache.cassandra.cql3.statements.ModificationStatement$Parsed
InnerClasses:
public ResultMetadata = org.apache.cassandra.cql3.ResultSet$ResultMetadata of org.apache.cassandra.cql3.ResultSet
public ResultSetBuilder = org.apache.cassandra.cql3.selection.Selection$ResultSetBuilder of org.apache.cassandra.cql3.selection.Selection
public abstract Parsed = org.apache.cassandra.cql3.statements.ModificationStatement$Parsed of org.apache.cassandra.cql3.statements.ModificationStatement
public Builder = org.apache.cassandra.db.PartitionColumns$Builder of org.apache.cassandra.db.PartitionColumns
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 Rows = org.apache.cassandra.transport.messages.ResultMessage$Rows of org.apache.cassandra.transport.messages.ResultMessage
ModificationStatement
logger: Logger
CAS_RESULT_COLUMN: ColumnIdentifier
$assertionsDisabled: boolean
