public class org.apache.cassandra.db.Mutation implements org.apache.cassandra.db.IMutation
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.db.Mutation
super_class: java.lang.Object
{
public static final org.apache.cassandra.db.Mutation$MutationSerializer serializer;
descriptor: Lorg/apache/cassandra/db/Mutation$MutationSerializer;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
public static final java.lang.String FORWARD_TO;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "FWD_TO"
public static final java.lang.String FORWARD_FROM;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "FWD_FRM"
private final java.lang.String keyspaceName;
descriptor: Ljava/lang/String;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.cassandra.db.DecoratedKey key;
descriptor: Lorg/apache/cassandra/db/DecoratedKey;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.Map<java.util.UUID, org.apache.cassandra.db.partitions.PartitionUpdate> modifications;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Ljava/util/UUID;Lorg/apache/cassandra/db/partitions/PartitionUpdate;>;
public final long createdAt;
descriptor: J
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
public final java.util.concurrent.atomic.AtomicLong viewLockAcquireStart;
descriptor: Ljava/util/concurrent/atomic/AtomicLong;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
private boolean cdcEnabled;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
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=2, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/db/Mutation;
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.db.Mutation.$assertionsDisabled:Z
3: new org.apache.cassandra.db.Mutation$MutationSerializer
dup
invokespecial org.apache.cassandra.db.Mutation$MutationSerializer.<init>:()V
putstatic org.apache.cassandra.db.Mutation.serializer:Lorg/apache/cassandra/db/Mutation$MutationSerializer;
4: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(java.lang.String, org.apache.cassandra.db.DecoratedKey);
descriptor: (Ljava/lang/String;Lorg/apache/cassandra/db/DecoratedKey;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
invokespecial org.apache.cassandra.db.Mutation.<init>:(Ljava/lang/String;Lorg/apache/cassandra/db/DecoratedKey;Ljava/util/Map;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/Mutation;
0 2 1 keyspaceName Ljava/lang/String;
0 2 2 key Lorg/apache/cassandra/db/DecoratedKey;
MethodParameters:
Name Flags
keyspaceName
key
public void <init>(org.apache.cassandra.db.partitions.PartitionUpdate);
descriptor: (Lorg/apache/cassandra/db/partitions/PartitionUpdate;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.ksName:Ljava/lang/String;
aload 1
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
aload 1
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
aload 1
invokestatic java.util.Collections.singletonMap:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/util/Map;
invokespecial org.apache.cassandra.db.Mutation.<init>:(Ljava/lang/String;Lorg/apache/cassandra/db/DecoratedKey;Ljava/util/Map;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/Mutation;
0 2 1 update Lorg/apache/cassandra/db/partitions/PartitionUpdate;
MethodParameters:
Name Flags
update
protected void <init>(java.lang.String, org.apache.cassandra.db.DecoratedKey, java.util.Map<java.util.UUID, org.apache.cassandra.db.partitions.PartitionUpdate>);
descriptor: (Ljava/lang/String;Lorg/apache/cassandra/db/DecoratedKey;Ljava/util/Map;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=5, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
invokestatic java.lang.System.currentTimeMillis:()J
putfield org.apache.cassandra.db.Mutation.createdAt:J
2: aload 0
new java.util.concurrent.atomic.AtomicLong
dup
lconst_0
invokespecial java.util.concurrent.atomic.AtomicLong.<init>:(J)V
putfield org.apache.cassandra.db.Mutation.viewLockAcquireStart:Ljava/util/concurrent/atomic/AtomicLong;
3: aload 0
iconst_0
putfield org.apache.cassandra.db.Mutation.cdcEnabled:Z
4: aload 0
aload 1
putfield org.apache.cassandra.db.Mutation.keyspaceName:Ljava/lang/String;
5: aload 0
aload 2
putfield org.apache.cassandra.db.Mutation.key:Lorg/apache/cassandra/db/DecoratedKey;
6: aload 0
aload 3
putfield org.apache.cassandra.db.Mutation.modifications:Ljava/util/Map;
7: aload 3
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 5
goto 10
StackMap locals: org.apache.cassandra.db.Mutation java.lang.String org.apache.cassandra.db.DecoratedKey java.util.Map top java.util.Iterator
StackMap stack:
8: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.partitions.PartitionUpdate
astore 4
start local 4 9: aload 0
dup
getfield org.apache.cassandra.db.Mutation.cdcEnabled:Z
aload 4
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.params:Lorg/apache/cassandra/schema/TableParams;
getfield org.apache.cassandra.schema.TableParams.cdc:Z
ior
putfield org.apache.cassandra.db.Mutation.cdcEnabled:Z
end local 4 10: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 8
11: return
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/db/Mutation;
0 12 1 keyspaceName Ljava/lang/String;
0 12 2 key Lorg/apache/cassandra/db/DecoratedKey;
0 12 3 modifications Ljava/util/Map<Ljava/util/UUID;Lorg/apache/cassandra/db/partitions/PartitionUpdate;>;
9 10 4 pu Lorg/apache/cassandra/db/partitions/PartitionUpdate;
Signature: (Ljava/lang/String;Lorg/apache/cassandra/db/DecoratedKey;Ljava/util/Map<Ljava/util/UUID;Lorg/apache/cassandra/db/partitions/PartitionUpdate;>;)V
MethodParameters:
Name Flags
keyspaceName
key
modifications
public org.apache.cassandra.db.Mutation copy();
descriptor: ()Lorg/apache/cassandra/db/Mutation;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=1, args_size=1
start local 0 0: new org.apache.cassandra.db.Mutation
dup
aload 0
getfield org.apache.cassandra.db.Mutation.keyspaceName:Ljava/lang/String;
aload 0
getfield org.apache.cassandra.db.Mutation.key:Lorg/apache/cassandra/db/DecoratedKey;
new java.util.HashMap
dup
aload 0
getfield org.apache.cassandra.db.Mutation.modifications:Ljava/util/Map;
invokespecial java.util.HashMap.<init>:(Ljava/util/Map;)V
invokespecial org.apache.cassandra.db.Mutation.<init>:(Ljava/lang/String;Lorg/apache/cassandra/db/DecoratedKey;Ljava/util/Map;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Mutation;
public org.apache.cassandra.db.Mutation without(java.util.Set<java.util.UUID>);
descriptor: (Ljava/util/Set;)Lorg/apache/cassandra/db/Mutation;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface java.util.Set.isEmpty:()Z
ifeq 2
1: aload 0
areturn
2: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.db.Mutation.copy:()Lorg/apache/cassandra/db/Mutation;
astore 2
start local 2 3: aload 2
getfield org.apache.cassandra.db.Mutation.modifications:Ljava/util/Map;
invokeinterface java.util.Map.keySet:()Ljava/util/Set;
aload 1
invokeinterface java.util.Set.removeAll:(Ljava/util/Collection;)Z
pop
4: aload 2
iconst_0
putfield org.apache.cassandra.db.Mutation.cdcEnabled:Z
5: aload 0
getfield org.apache.cassandra.db.Mutation.modifications:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 4
goto 8
StackMap locals: org.apache.cassandra.db.Mutation java.util.Set org.apache.cassandra.db.Mutation top java.util.Iterator
StackMap stack:
6: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.partitions.PartitionUpdate
astore 3
start local 3 7: aload 2
dup
getfield org.apache.cassandra.db.Mutation.cdcEnabled:Z
aload 3
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.params:Lorg/apache/cassandra/schema/TableParams;
getfield org.apache.cassandra.schema.TableParams.cdc:Z
ior
putfield org.apache.cassandra.db.Mutation.cdcEnabled:Z
end local 3 8: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 6
9: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/apache/cassandra/db/Mutation;
0 10 1 cfIds Ljava/util/Set<Ljava/util/UUID;>;
3 10 2 copy Lorg/apache/cassandra/db/Mutation;
7 8 3 pu Lorg/apache/cassandra/db/partitions/PartitionUpdate;
Signature: (Ljava/util/Set<Ljava/util/UUID;>;)Lorg/apache/cassandra/db/Mutation;
MethodParameters:
Name Flags
cfIds
public org.apache.cassandra.db.Mutation without(java.util.UUID);
descriptor: (Ljava/util/UUID;)Lorg/apache/cassandra/db/Mutation;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic java.util.Collections.singleton:(Ljava/lang/Object;)Ljava/util/Set;
invokevirtual org.apache.cassandra.db.Mutation.without:(Ljava/util/Set;)Lorg/apache/cassandra/db/Mutation;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Mutation;
0 1 1 cfId Ljava/util/UUID;
MethodParameters:
Name Flags
cfId
public java.lang.String getKeyspaceName();
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.db.Mutation.keyspaceName:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Mutation;
public java.util.Collection<java.util.UUID> getColumnFamilyIds();
descriptor: ()Ljava/util/Collection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.Mutation.modifications:Ljava/util/Map;
invokeinterface java.util.Map.keySet:()Ljava/util/Set;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Mutation;
Signature: ()Ljava/util/Collection<Ljava/util/UUID;>;
public org.apache.cassandra.db.DecoratedKey key();
descriptor: ()Lorg/apache/cassandra/db/DecoratedKey;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.Mutation.key:Lorg/apache/cassandra/db/DecoratedKey;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Mutation;
public java.util.Collection<org.apache.cassandra.db.partitions.PartitionUpdate> getPartitionUpdates();
descriptor: ()Ljava/util/Collection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.Mutation.modifications:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Mutation;
Signature: ()Ljava/util/Collection<Lorg/apache/cassandra/db/partitions/PartitionUpdate;>;
public org.apache.cassandra.db.partitions.PartitionUpdate getPartitionUpdate(java.util.UUID);
descriptor: (Ljava/util/UUID;)Lorg/apache/cassandra/db/partitions/PartitionUpdate;
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.db.Mutation.modifications:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.partitions.PartitionUpdate
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Mutation;
0 1 1 cfId Ljava/util/UUID;
MethodParameters:
Name Flags
cfId
public org.apache.cassandra.db.Mutation add(org.apache.cassandra.db.partitions.PartitionUpdate);
descriptor: (Lorg/apache/cassandra/db/partitions/PartitionUpdate;)Lorg/apache/cassandra/db/Mutation;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.db.Mutation.$assertionsDisabled:Z
ifne 1
aload 1
ifnonnull 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.db.Mutation.$assertionsDisabled:Z
ifne 2
aload 1
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.DecoratedKey.getPartitioner:()Lorg/apache/cassandra/dht/IPartitioner;
aload 0
getfield org.apache.cassandra.db.Mutation.key:Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.DecoratedKey.getPartitioner:()Lorg/apache/cassandra/dht/IPartitioner;
if_acmpeq 2
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
2: StackMap locals:
StackMap stack:
aload 0
dup
getfield org.apache.cassandra.db.Mutation.cdcEnabled:Z
aload 1
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.params:Lorg/apache/cassandra/schema/TableParams;
getfield org.apache.cassandra.schema.TableParams.cdc:Z
ior
putfield org.apache.cassandra.db.Mutation.cdcEnabled:Z
3: aload 0
getfield org.apache.cassandra.db.Mutation.modifications:Ljava/util/Map;
aload 1
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
aload 1
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.partitions.PartitionUpdate
astore 2
start local 2 4: aload 2
ifnull 6
5: new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "Table "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfName:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " already has modifications in this mutation: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
6: StackMap locals: org.apache.cassandra.db.partitions.PartitionUpdate
StackMap stack:
aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/db/Mutation;
0 7 1 update Lorg/apache/cassandra/db/partitions/PartitionUpdate;
4 7 2 prev Lorg/apache/cassandra/db/partitions/PartitionUpdate;
MethodParameters:
Name Flags
update
public org.apache.cassandra.db.partitions.PartitionUpdate get(org.apache.cassandra.config.CFMetaData);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/db/partitions/PartitionUpdate;
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.db.Mutation.modifications:Ljava/util/Map;
aload 1
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.partitions.PartitionUpdate
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Mutation;
0 1 1 cfm Lorg/apache/cassandra/config/CFMetaData;
MethodParameters:
Name Flags
cfm
public boolean isEmpty();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.Mutation.modifications:Ljava/util/Map;
invokeinterface java.util.Map.isEmpty:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Mutation;
public static org.apache.cassandra.db.Mutation merge(java.util.List<org.apache.cassandra.db.Mutation>);
descriptor: (Ljava/util/List;)Lorg/apache/cassandra/db/Mutation;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=11, args_size=1
start local 0 0: getstatic org.apache.cassandra.db.Mutation.$assertionsDisabled:Z
ifne 1
aload 0
invokeinterface java.util.List.isEmpty:()Z
ifeq 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
invokeinterface java.util.List.size:()I
iconst_1
if_icmpne 3
2: aload 0
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.Mutation
areturn
3: StackMap locals:
StackMap stack:
new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 1
start local 1 4: aconst_null
astore 2
start local 2 5: aconst_null
astore 3
start local 3 6: aload 0
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 5
goto 15
StackMap locals: java.util.List java.util.Set java.lang.String org.apache.cassandra.db.DecoratedKey top java.util.Iterator
StackMap stack:
7: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.Mutation
astore 4
start local 4 8: aload 1
aload 4
getfield org.apache.cassandra.db.Mutation.modifications:Ljava/util/Map;
invokeinterface java.util.Map.keySet:()Ljava/util/Set;
invokeinterface java.util.Set.addAll:(Ljava/util/Collection;)Z
pop
9: aload 2
ifnull 11
aload 2
aload 4
getfield org.apache.cassandra.db.Mutation.keyspaceName:Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 11
10: new java.lang.IllegalArgumentException
dup
invokespecial java.lang.IllegalArgumentException.<init>:()V
athrow
11: StackMap locals: java.util.List java.util.Set java.lang.String org.apache.cassandra.db.DecoratedKey org.apache.cassandra.db.Mutation java.util.Iterator
StackMap stack:
aload 3
ifnull 13
aload 3
aload 4
getfield org.apache.cassandra.db.Mutation.key:Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.DecoratedKey.equals:(Ljava/lang/Object;)Z
ifne 13
12: new java.lang.IllegalArgumentException
dup
invokespecial java.lang.IllegalArgumentException.<init>:()V
athrow
13: StackMap locals:
StackMap stack:
aload 4
getfield org.apache.cassandra.db.Mutation.keyspaceName:Ljava/lang/String;
astore 2
14: aload 4
getfield org.apache.cassandra.db.Mutation.key:Lorg/apache/cassandra/db/DecoratedKey;
astore 3
end local 4 15: StackMap locals: java.util.List java.util.Set java.lang.String org.apache.cassandra.db.DecoratedKey top java.util.Iterator
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 7
16: new java.util.ArrayList
dup
aload 0
invokeinterface java.util.List.size:()I
invokespecial java.util.ArrayList.<init>:(I)V
astore 4
start local 4 17: new java.util.HashMap
dup
aload 1
invokeinterface java.util.Set.size:()I
invokespecial java.util.HashMap.<init>:(I)V
astore 5
start local 5 18: aload 1
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 7
goto 32
StackMap locals: java.util.List java.util.Set java.lang.String org.apache.cassandra.db.DecoratedKey java.util.List java.util.Map top java.util.Iterator
StackMap stack:
19: aload 7
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.UUID
astore 6
start local 6 20: aload 0
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 9
goto 25
StackMap locals: java.util.List java.util.Set java.lang.String org.apache.cassandra.db.DecoratedKey java.util.List java.util.Map java.util.UUID java.util.Iterator top java.util.Iterator
StackMap stack:
21: aload 9
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.Mutation
astore 8
start local 8 22: aload 8
getfield org.apache.cassandra.db.Mutation.modifications:Ljava/util/Map;
aload 6
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.partitions.PartitionUpdate
astore 10
start local 10 23: aload 10
ifnull 25
24: aload 4
aload 10
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 10 end local 8 25: StackMap locals:
StackMap stack:
aload 9
invokeinterface java.util.Iterator.hasNext:()Z
ifne 21
26: aload 4
invokeinterface java.util.List.isEmpty:()Z
ifeq 28
27: goto 32
28: StackMap locals: java.util.List java.util.Set java.lang.String org.apache.cassandra.db.DecoratedKey java.util.List java.util.Map java.util.UUID java.util.Iterator
StackMap stack:
aload 5
aload 6
aload 4
invokeinterface java.util.List.size:()I
iconst_1
if_icmpne 29
aload 4
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.partitions.PartitionUpdate
goto 30
StackMap locals: java.util.List java.util.Set java.lang.String org.apache.cassandra.db.DecoratedKey java.util.List java.util.Map java.util.UUID java.util.Iterator
StackMap stack: java.util.Map java.util.UUID
29: aload 4
invokestatic org.apache.cassandra.db.partitions.PartitionUpdate.merge:(Ljava/util/List;)Lorg/apache/cassandra/db/partitions/PartitionUpdate;
StackMap locals: java.util.List java.util.Set java.lang.String org.apache.cassandra.db.DecoratedKey java.util.List java.util.Map java.util.UUID java.util.Iterator
StackMap stack: java.util.Map java.util.UUID org.apache.cassandra.db.partitions.PartitionUpdate
30: invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
31: aload 4
invokeinterface java.util.List.clear:()V
end local 6 32: StackMap locals: java.util.List java.util.Set java.lang.String org.apache.cassandra.db.DecoratedKey java.util.List java.util.Map top java.util.Iterator
StackMap stack:
aload 7
invokeinterface java.util.Iterator.hasNext:()Z
ifne 19
33: new org.apache.cassandra.db.Mutation
dup
aload 2
aload 3
aload 5
invokespecial org.apache.cassandra.db.Mutation.<init>:(Ljava/lang/String;Lorg/apache/cassandra/db/DecoratedKey;Ljava/util/Map;)V
areturn
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 34 0 mutations Ljava/util/List<Lorg/apache/cassandra/db/Mutation;>;
4 34 1 updatedTables Ljava/util/Set<Ljava/util/UUID;>;
5 34 2 ks Ljava/lang/String;
6 34 3 key Lorg/apache/cassandra/db/DecoratedKey;
8 15 4 mutation Lorg/apache/cassandra/db/Mutation;
17 34 4 updates Ljava/util/List<Lorg/apache/cassandra/db/partitions/PartitionUpdate;>;
18 34 5 modifications Ljava/util/Map<Ljava/util/UUID;Lorg/apache/cassandra/db/partitions/PartitionUpdate;>;
20 32 6 table Ljava/util/UUID;
22 25 8 mutation Lorg/apache/cassandra/db/Mutation;
23 25 10 upd Lorg/apache/cassandra/db/partitions/PartitionUpdate;
Signature: (Ljava/util/List<Lorg/apache/cassandra/db/Mutation;>;)Lorg/apache/cassandra/db/Mutation;
MethodParameters:
Name Flags
mutations
public java.util.concurrent.CompletableFuture<?> applyFuture();
descriptor: ()Ljava/util/concurrent/CompletableFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.Mutation.keyspaceName:Ljava/lang/String;
invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
astore 1
start local 1 1: aload 1
aload 0
aload 0
getfield org.apache.cassandra.db.Mutation.keyspaceName:Ljava/lang/String;
invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
invokevirtual org.apache.cassandra.db.Keyspace.getMetadata:()Lorg/apache/cassandra/schema/KeyspaceMetadata;
getfield org.apache.cassandra.schema.KeyspaceMetadata.params:Lorg/apache/cassandra/schema/KeyspaceParams;
getfield org.apache.cassandra.schema.KeyspaceParams.durableWrites:Z
iconst_1
invokevirtual org.apache.cassandra.db.Keyspace.applyFuture:(Lorg/apache/cassandra/db/Mutation;ZZ)Ljava/util/concurrent/CompletableFuture;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/Mutation;
1 2 1 ks Lorg/apache/cassandra/db/Keyspace;
Signature: ()Ljava/util/concurrent/CompletableFuture<*>;
public void apply(boolean, boolean);
descriptor: (ZZ)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.apache.cassandra.db.Mutation.keyspaceName:Ljava/lang/String;
invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
aload 0
iload 1
iconst_1
iload 2
invokevirtual org.apache.cassandra.db.Keyspace.apply:(Lorg/apache/cassandra/db/Mutation;ZZZ)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/Mutation;
0 2 1 durableWrites Z
0 2 2 isDroppable Z
MethodParameters:
Name Flags
durableWrites
isDroppable
public void apply(boolean);
descriptor: (Z)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
iconst_1
invokevirtual org.apache.cassandra.db.Mutation.apply:(ZZ)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/Mutation;
0 2 1 durableWrites Z
MethodParameters:
Name Flags
durableWrites
public void apply();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
aload 0
getfield org.apache.cassandra.db.Mutation.keyspaceName:Ljava/lang/String;
invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
invokevirtual org.apache.cassandra.db.Keyspace.getMetadata:()Lorg/apache/cassandra/schema/KeyspaceMetadata;
getfield org.apache.cassandra.schema.KeyspaceMetadata.params:Lorg/apache/cassandra/schema/KeyspaceParams;
getfield org.apache.cassandra.schema.KeyspaceParams.durableWrites:Z
invokevirtual org.apache.cassandra.db.Mutation.apply:(Z)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/Mutation;
public void applyUnsafe();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_0
invokevirtual org.apache.cassandra.db.Mutation.apply:(Z)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/Mutation;
public org.apache.cassandra.net.MessageOut<org.apache.cassandra.db.Mutation> createMessage();
descriptor: ()Lorg/apache/cassandra/net/MessageOut;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getstatic org.apache.cassandra.net.MessagingService$Verb.MUTATION:Lorg/apache/cassandra/net/MessagingService$Verb;
invokevirtual org.apache.cassandra.db.Mutation.createMessage:(Lorg/apache/cassandra/net/MessagingService$Verb;)Lorg/apache/cassandra/net/MessageOut;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Mutation;
Signature: ()Lorg/apache/cassandra/net/MessageOut<Lorg/apache/cassandra/db/Mutation;>;
public org.apache.cassandra.net.MessageOut<org.apache.cassandra.db.Mutation> createMessage(org.apache.cassandra.net.MessagingService$Verb);
descriptor: (Lorg/apache/cassandra/net/MessagingService$Verb;)Lorg/apache/cassandra/net/MessageOut;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: new org.apache.cassandra.net.MessageOut
dup
aload 1
aload 0
getstatic org.apache.cassandra.db.Mutation.serializer:Lorg/apache/cassandra/db/Mutation$MutationSerializer;
invokespecial org.apache.cassandra.net.MessageOut.<init>:(Lorg/apache/cassandra/net/MessagingService$Verb;Ljava/lang/Object;Lorg/apache/cassandra/io/IVersionedSerializer;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Mutation;
0 1 1 verb Lorg/apache/cassandra/net/MessagingService$Verb;
Signature: (Lorg/apache/cassandra/net/MessagingService$Verb;)Lorg/apache/cassandra/net/MessageOut<Lorg/apache/cassandra/db/Mutation;>;
MethodParameters:
Name Flags
verb
public long getTimeout();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: invokestatic org.apache.cassandra.config.DatabaseDescriptor.getWriteRpcTimeout:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Mutation;
public int smallestGCGS();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=1
start local 0 0: ldc 2147483647
istore 1
start local 1 1: aload 0
invokevirtual org.apache.cassandra.db.Mutation.getPartitionUpdates:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 3
goto 4
StackMap locals: org.apache.cassandra.db.Mutation int top java.util.Iterator
StackMap stack:
2: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.partitions.PartitionUpdate
astore 2
start local 2 3: iload 1
aload 2
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.params:Lorg/apache/cassandra/schema/TableParams;
getfield org.apache.cassandra.schema.TableParams.gcGraceSeconds:I
invokestatic java.lang.Math.min:(II)I
istore 1
end local 2 4: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
5: iload 1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/db/Mutation;
1 6 1 gcgs I
3 4 2 update Lorg/apache/cassandra/db/partitions/PartitionUpdate;
public boolean trackedByCDC();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.Mutation.cdcEnabled:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Mutation;
public java.lang.String toString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_0
invokevirtual org.apache.cassandra.db.Mutation.toString:(Z)Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Mutation;
public java.lang.String toString(boolean);
descriptor: (Z)Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=7, args_size=2
start local 0 start local 1 0: new java.lang.StringBuilder
dup
ldc "Mutation("
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
astore 2
start local 2 1: aload 2
ldc "keyspace='"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.cassandra.db.Mutation.keyspaceName:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
bipush 39
invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
pop
2: aload 2
ldc ", key='"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.cassandra.db.Mutation.key:Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
invokestatic org.apache.cassandra.utils.ByteBufferUtil.bytesToHex:(Ljava/nio/ByteBuffer;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
bipush 39
invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
pop
3: aload 2
ldc ", modifications=["
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
pop
4: iload 1
ifeq 15
5: new java.util.ArrayList
dup
aload 0
getfield org.apache.cassandra.db.Mutation.modifications:Ljava/util/Map;
invokeinterface java.util.Map.size:()I
invokespecial java.util.ArrayList.<init>:(I)V
astore 3
start local 3 6: aload 0
getfield org.apache.cassandra.db.Mutation.modifications:Ljava/util/Map;
invokeinterface java.util.Map.keySet:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 5
goto 12
StackMap locals: org.apache.cassandra.db.Mutation int java.lang.StringBuilder java.util.List top java.util.Iterator
StackMap stack:
7: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.UUID
astore 4
start local 4 8: getstatic org.apache.cassandra.config.Schema.instance:Lorg/apache/cassandra/config/Schema;
aload 4
invokevirtual org.apache.cassandra.config.Schema.getCFMetaData:(Ljava/util/UUID;)Lorg/apache/cassandra/config/CFMetaData;
astore 6
start local 6 9: aload 3
aload 6
ifnonnull 10
ldc "-dropped-"
goto 11
StackMap locals: org.apache.cassandra.db.Mutation int java.lang.StringBuilder java.util.List java.util.UUID java.util.Iterator org.apache.cassandra.config.CFMetaData
StackMap stack: java.util.List
10: aload 6
getfield org.apache.cassandra.config.CFMetaData.cfName:Ljava/lang/String;
StackMap locals: org.apache.cassandra.db.Mutation int java.lang.StringBuilder java.util.List java.util.UUID java.util.Iterator org.apache.cassandra.config.CFMetaData
StackMap stack: java.util.List java.lang.String
11: invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 6 end local 4 12: StackMap locals: org.apache.cassandra.db.Mutation int java.lang.StringBuilder java.util.List top java.util.Iterator
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 7
13: aload 2
aload 3
ldc ", "
invokestatic org.apache.commons.lang3.StringUtils.join:(Ljava/lang/Iterable;Ljava/lang/String;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
pop
end local 3 14: goto 16
15: StackMap locals: org.apache.cassandra.db.Mutation int java.lang.StringBuilder
StackMap stack:
aload 2
ldc "\n "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.cassandra.db.Mutation.modifications:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
ldc "\n "
invokestatic org.apache.commons.lang3.StringUtils.join:(Ljava/lang/Iterable;Ljava/lang/String;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
bipush 10
invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
pop
16: StackMap locals:
StackMap stack:
aload 2
ldc "])"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lorg/apache/cassandra/db/Mutation;
0 17 1 shallow Z
1 17 2 buff Ljava/lang/StringBuilder;
6 14 3 cfnames Ljava/util/List<Ljava/lang/String;>;
8 12 4 cfid Ljava/util/UUID;
9 12 6 cfm Lorg/apache/cassandra/config/CFMetaData;
MethodParameters:
Name Flags
shallow
public static org.apache.cassandra.db.Mutation$SimpleBuilder simpleBuilder(java.lang.String, org.apache.cassandra.db.DecoratedKey);
descriptor: (Ljava/lang/String;Lorg/apache/cassandra/db/DecoratedKey;)Lorg/apache/cassandra/db/Mutation$SimpleBuilder;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: new org.apache.cassandra.db.SimpleBuilders$MutationBuilder
dup
aload 0
aload 1
invokespecial org.apache.cassandra.db.SimpleBuilders$MutationBuilder.<init>:(Ljava/lang/String;Lorg/apache/cassandra/db/DecoratedKey;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 keyspaceName Ljava/lang/String;
0 1 1 partitionKey Lorg/apache/cassandra/db/DecoratedKey;
MethodParameters:
Name Flags
keyspaceName
partitionKey
}
SourceFile: "Mutation.java"
NestMembers:
org.apache.cassandra.db.Mutation$MutationSerializer org.apache.cassandra.db.Mutation$SimpleBuilder
InnerClasses:
public MutationSerializer = org.apache.cassandra.db.Mutation$MutationSerializer of org.apache.cassandra.db.Mutation
public abstract SimpleBuilder = org.apache.cassandra.db.Mutation$SimpleBuilder of org.apache.cassandra.db.Mutation
public MutationBuilder = org.apache.cassandra.db.SimpleBuilders$MutationBuilder of org.apache.cassandra.db.SimpleBuilders
public Verb = org.apache.cassandra.net.MessagingService$Verb of org.apache.cassandra.net.MessagingService