public class org.apache.cassandra.db.Mutation$MutationSerializer implements org.apache.cassandra.io.IVersionedSerializer<org.apache.cassandra.db.Mutation>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.db.Mutation$MutationSerializer
super_class: java.lang.Object
{
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=1, 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$MutationSerializer.$assertionsDisabled:Z
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Mutation$MutationSerializer;
public void serialize(org.apache.cassandra.db.Mutation, org.apache.cassandra.io.util.DataOutputPlus, int);
descriptor: (Lorg/apache/cassandra/db/Mutation;Lorg/apache/cassandra/io/util/DataOutputPlus;I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: iload 3
bipush 7
if_icmpge 2
1: aload 2
aload 1
invokevirtual org.apache.cassandra.db.Mutation.getKeyspaceName:()Ljava/lang/String;
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeUTF:(Ljava/lang/String;)V
2: StackMap locals:
StackMap stack:
aload 1
getfield org.apache.cassandra.db.Mutation.modifications:Ljava/util/Map;
invokeinterface java.util.Map.size:()I
istore 4
start local 4 3: iload 3
bipush 10
if_icmpge 7
4: aload 1
invokevirtual org.apache.cassandra.db.Mutation.key:()Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
aload 2
invokestatic org.apache.cassandra.utils.ByteBufferUtil.writeWithShortLength:(Ljava/nio/ByteBuffer;Lorg/apache/cassandra/io/util/DataOutputPlus;)V
5: aload 2
iload 4
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeInt:(I)V
6: goto 8
7: StackMap locals: int
StackMap stack:
aload 2
iload 4
i2l
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeUnsignedVInt:(J)V
8: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.db.Mutation$MutationSerializer.$assertionsDisabled:Z
ifne 9
iload 4
ifgt 9
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
9: StackMap locals:
StackMap stack:
aload 1
getfield org.apache.cassandra.db.Mutation.modifications:Ljava/util/Map;
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 6
goto 12
StackMap locals: org.apache.cassandra.db.Mutation$MutationSerializer org.apache.cassandra.db.Mutation org.apache.cassandra.io.util.DataOutputPlus int int top java.util.Iterator
StackMap stack:
10: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 5
start local 5 11: getstatic org.apache.cassandra.db.partitions.PartitionUpdate.serializer:Lorg/apache/cassandra/db/partitions/PartitionUpdate$PartitionUpdateSerializer;
aload 5
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.partitions.PartitionUpdate
aload 2
iload 3
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate$PartitionUpdateSerializer.serialize:(Lorg/apache/cassandra/db/partitions/PartitionUpdate;Lorg/apache/cassandra/io/util/DataOutputPlus;I)V
end local 5 12: StackMap locals:
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 10
13: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lorg/apache/cassandra/db/Mutation$MutationSerializer;
0 14 1 mutation Lorg/apache/cassandra/db/Mutation;
0 14 2 out Lorg/apache/cassandra/io/util/DataOutputPlus;
0 14 3 version I
3 14 4 size I
11 12 5 entry Ljava/util/Map$Entry<Ljava/util/UUID;Lorg/apache/cassandra/db/partitions/PartitionUpdate;>;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
mutation
out
version
public org.apache.cassandra.db.Mutation deserialize(org.apache.cassandra.io.util.DataInputPlus, int, org.apache.cassandra.db.rows.SerializationHelper$Flag);
descriptor: (Lorg/apache/cassandra/io/util/DataInputPlus;ILorg/apache/cassandra/db/rows/SerializationHelper$Flag;)Lorg/apache/cassandra/db/Mutation;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=10, args_size=4
start local 0 start local 1 start local 2 start local 3 0: iload 2
bipush 7
if_icmpge 2
1: aload 1
invokeinterface org.apache.cassandra.io.util.DataInputPlus.readUTF:()Ljava/lang/String;
pop
2: StackMap locals:
StackMap stack:
aconst_null
astore 4
start local 4 3: iload 2
bipush 10
if_icmpge 7
4: aload 1
invokestatic org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength:(Ljava/io/DataInput;)Ljava/nio/ByteBuffer;
astore 4
5: aload 1
invokeinterface org.apache.cassandra.io.util.DataInputPlus.readInt:()I
istore 5
start local 5 6: goto 8
end local 5 7: StackMap locals: java.nio.ByteBuffer
StackMap stack:
aload 1
invokeinterface org.apache.cassandra.io.util.DataInputPlus.readUnsignedVInt:()J
l2i
istore 5
start local 5 8: StackMap locals: int
StackMap stack:
getstatic org.apache.cassandra.db.Mutation$MutationSerializer.$assertionsDisabled:Z
ifne 9
iload 5
ifgt 9
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
9: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.db.partitions.PartitionUpdate.serializer:Lorg/apache/cassandra/db/partitions/PartitionUpdate$PartitionUpdateSerializer;
aload 1
iload 2
aload 3
aload 4
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate$PartitionUpdateSerializer.deserialize:(Lorg/apache/cassandra/io/util/DataInputPlus;ILorg/apache/cassandra/db/rows/SerializationHelper$Flag;Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/db/partitions/PartitionUpdate;
astore 6
start local 6 10: iload 5
iconst_1
if_icmpne 12
11: new org.apache.cassandra.db.Mutation
dup
aload 6
invokespecial org.apache.cassandra.db.Mutation.<init>:(Lorg/apache/cassandra/db/partitions/PartitionUpdate;)V
areturn
12: StackMap locals: org.apache.cassandra.db.partitions.PartitionUpdate
StackMap stack:
new java.util.HashMap
dup
iload 5
invokespecial java.util.HashMap.<init>:(I)V
astore 7
start local 7 13: aload 6
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
astore 8
start local 8 14: aload 7
aload 6
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
aload 6
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
15: iconst_1
istore 9
start local 9 16: goto 20
17: StackMap locals: java.util.Map org.apache.cassandra.db.DecoratedKey int
StackMap stack:
getstatic org.apache.cassandra.db.partitions.PartitionUpdate.serializer:Lorg/apache/cassandra/db/partitions/PartitionUpdate$PartitionUpdateSerializer;
aload 1
iload 2
aload 3
aload 8
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate$PartitionUpdateSerializer.deserialize:(Lorg/apache/cassandra/io/util/DataInputPlus;ILorg/apache/cassandra/db/rows/SerializationHelper$Flag;Lorg/apache/cassandra/db/DecoratedKey;)Lorg/apache/cassandra/db/partitions/PartitionUpdate;
astore 6
18: aload 7
aload 6
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
aload 6
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
19: iinc 9 1
StackMap locals:
StackMap stack:
20: iload 9
iload 5
if_icmplt 17
end local 9 21: new org.apache.cassandra.db.Mutation
dup
aload 6
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.ksName:Ljava/lang/String;
aload 8
aload 7
invokespecial org.apache.cassandra.db.Mutation.<init>:(Ljava/lang/String;Lorg/apache/cassandra/db/DecoratedKey;Ljava/util/Map;)V
areturn
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 22 0 this Lorg/apache/cassandra/db/Mutation$MutationSerializer;
0 22 1 in Lorg/apache/cassandra/io/util/DataInputPlus;
0 22 2 version I
0 22 3 flag Lorg/apache/cassandra/db/rows/SerializationHelper$Flag;
3 22 4 key Ljava/nio/ByteBuffer;
6 7 5 size I
8 22 5 size I
10 22 6 update Lorg/apache/cassandra/db/partitions/PartitionUpdate;
13 22 7 modifications Ljava/util/Map<Ljava/util/UUID;Lorg/apache/cassandra/db/partitions/PartitionUpdate;>;
14 22 8 dk Lorg/apache/cassandra/db/DecoratedKey;
16 21 9 i I
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
in
version
flag
public org.apache.cassandra.db.Mutation deserialize(org.apache.cassandra.io.util.DataInputPlus, int);
descriptor: (Lorg/apache/cassandra/io/util/DataInputPlus;I)Lorg/apache/cassandra/db/Mutation;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
iload 2
getstatic org.apache.cassandra.db.rows.SerializationHelper$Flag.FROM_REMOTE:Lorg/apache/cassandra/db/rows/SerializationHelper$Flag;
invokevirtual org.apache.cassandra.db.Mutation$MutationSerializer.deserialize:(Lorg/apache/cassandra/io/util/DataInputPlus;ILorg/apache/cassandra/db/rows/SerializationHelper$Flag;)Lorg/apache/cassandra/db/Mutation;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/Mutation$MutationSerializer;
0 1 1 in Lorg/apache/cassandra/io/util/DataInputPlus;
0 1 2 version I
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
in
version
public long serializedSize(org.apache.cassandra.db.Mutation, int);
descriptor: (Lorg/apache/cassandra/db/Mutation;I)J
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=6, args_size=3
start local 0 start local 1 start local 2 0: iconst_0
istore 3
start local 3 1: iload 2
bipush 7
if_icmpge 3
2: iload 3
aload 1
invokevirtual org.apache.cassandra.db.Mutation.getKeyspaceName:()Ljava/lang/String;
invokestatic org.apache.cassandra.db.TypeSizes.sizeof:(Ljava/lang/String;)I
iadd
istore 3
3: StackMap locals: int
StackMap stack:
iload 2
bipush 10
if_icmpge 8
4: aload 1
invokevirtual org.apache.cassandra.db.Mutation.key:()Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.remaining:()I
istore 4
start local 4 5: iload 3
iload 4
i2s
invokestatic org.apache.cassandra.db.TypeSizes.sizeof:(S)I
iload 4
iadd
iadd
istore 3
6: iload 3
aload 1
getfield org.apache.cassandra.db.Mutation.modifications:Ljava/util/Map;
invokeinterface java.util.Map.size:()I
invokestatic org.apache.cassandra.db.TypeSizes.sizeof:(I)I
iadd
istore 3
end local 4 7: goto 9
8: StackMap locals:
StackMap stack:
iload 3
aload 1
getfield org.apache.cassandra.db.Mutation.modifications:Ljava/util/Map;
invokeinterface java.util.Map.size:()I
i2l
invokestatic org.apache.cassandra.db.TypeSizes.sizeofUnsignedVInt:(J)I
iadd
istore 3
9: StackMap locals:
StackMap stack:
aload 1
getfield org.apache.cassandra.db.Mutation.modifications:Ljava/util/Map;
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 5
goto 12
StackMap locals: org.apache.cassandra.db.Mutation$MutationSerializer org.apache.cassandra.db.Mutation int int top java.util.Iterator
StackMap stack:
10: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 4
start local 4 11: iload 3
i2l
getstatic org.apache.cassandra.db.partitions.PartitionUpdate.serializer:Lorg/apache/cassandra/db/partitions/PartitionUpdate$PartitionUpdateSerializer;
aload 4
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.partitions.PartitionUpdate
iload 2
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate$PartitionUpdateSerializer.serializedSize:(Lorg/apache/cassandra/db/partitions/PartitionUpdate;I)J
ladd
l2i
istore 3
end local 4 12: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 10
13: iload 3
i2l
lreturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lorg/apache/cassandra/db/Mutation$MutationSerializer;
0 14 1 mutation Lorg/apache/cassandra/db/Mutation;
0 14 2 version I
1 14 3 size I
5 7 4 keySize I
11 12 4 entry Ljava/util/Map$Entry<Ljava/util/UUID;Lorg/apache/cassandra/db/partitions/PartitionUpdate;>;
MethodParameters:
Name Flags
mutation
version
public void serialize(java.lang.Object, org.apache.cassandra.io.util.DataOutputPlus, int);
descriptor: (Ljava/lang/Object;Lorg/apache/cassandra/io/util/DataOutputPlus;I)V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=4
0: aload 0
aload 1
checkcast org.apache.cassandra.db.Mutation
aload 2
iload 3
invokevirtual org.apache.cassandra.db.Mutation$MutationSerializer.serialize:(Lorg/apache/cassandra/db/Mutation;Lorg/apache/cassandra/io/util/DataOutputPlus;I)V
return
LocalVariableTable:
Start End Slot Name Signature
Exceptions:
throws java.io.IOException
public long serializedSize(java.lang.Object, int);
descriptor: (Ljava/lang/Object;I)J
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
checkcast org.apache.cassandra.db.Mutation
iload 2
invokevirtual org.apache.cassandra.db.Mutation$MutationSerializer.serializedSize:(Lorg/apache/cassandra/db/Mutation;I)J
lreturn
LocalVariableTable:
Start End Slot Name Signature
public java.lang.Object deserialize(org.apache.cassandra.io.util.DataInputPlus, int);
descriptor: (Lorg/apache/cassandra/io/util/DataInputPlus;I)Ljava/lang/Object;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
iload 2
invokevirtual org.apache.cassandra.db.Mutation$MutationSerializer.deserialize:(Lorg/apache/cassandra/io/util/DataInputPlus;I)Lorg/apache/cassandra/db/Mutation;
areturn
LocalVariableTable:
Start End Slot Name Signature
Exceptions:
throws java.io.IOException
}
Signature: Ljava/lang/Object;Lorg/apache/cassandra/io/IVersionedSerializer<Lorg/apache/cassandra/db/Mutation;>;
SourceFile: "Mutation.java"
NestHost: org.apache.cassandra.db.Mutation
InnerClasses:
public abstract Entry = java.util.Map$Entry of java.util.Map
public MutationSerializer = org.apache.cassandra.db.Mutation$MutationSerializer of org.apache.cassandra.db.Mutation
public PartitionUpdateSerializer = org.apache.cassandra.db.partitions.PartitionUpdate$PartitionUpdateSerializer of org.apache.cassandra.db.partitions.PartitionUpdate
public final Flag = org.apache.cassandra.db.rows.SerializationHelper$Flag of org.apache.cassandra.db.rows.SerializationHelper