public class org.apache.cassandra.io.sstable.metadata.MetadataSerializer implements org.apache.cassandra.io.sstable.metadata.IMetadataSerializer
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.io.sstable.metadata.MetadataSerializer
super_class: java.lang.Object
{
private static final org.slf4j.Logger logger;
descriptor: Lorg/slf4j/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/io/sstable/metadata/MetadataSerializer;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic org.apache.cassandra.io.sstable.metadata.MetadataSerializer.logger:Lorg/slf4j/Logger;
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/io/sstable/metadata/MetadataSerializer;
public void serialize(java.util.Map<org.apache.cassandra.io.sstable.metadata.MetadataType, org.apache.cassandra.io.sstable.metadata.MetadataComponent>, org.apache.cassandra.io.util.DataOutputPlus, org.apache.cassandra.io.sstable.format.Version);
descriptor: (Ljava/util/Map;Lorg/apache/cassandra/io/util/DataOutputPlus;Lorg/apache/cassandra/io/sstable/format/Version;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=9, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokestatic com.google.common.collect.Lists.newArrayList:(Ljava/lang/Iterable;)Ljava/util/ArrayList;
astore 4
start local 4 1: aload 4
invokestatic java.util.Collections.sort:(Ljava/util/List;)V
2: aload 2
aload 1
invokeinterface java.util.Map.size:()I
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeInt:(I)V
3: iconst_4
bipush 8
aload 4
invokeinterface java.util.List.size:()I
imul
iadd
istore 5
start local 5 4: aload 4
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 7
goto 10
StackMap locals: org.apache.cassandra.io.sstable.metadata.MetadataSerializer java.util.Map org.apache.cassandra.io.util.DataOutputPlus org.apache.cassandra.io.sstable.format.Version java.util.List int top java.util.Iterator
StackMap stack:
5: aload 7
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.metadata.MetadataComponent
astore 6
start local 6 6: aload 6
invokevirtual org.apache.cassandra.io.sstable.metadata.MetadataComponent.getType:()Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
astore 8
start local 8 7: aload 2
aload 8
invokevirtual org.apache.cassandra.io.sstable.metadata.MetadataType.ordinal:()I
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeInt:(I)V
8: aload 2
iload 5
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeInt:(I)V
9: iload 5
aload 8
getfield org.apache.cassandra.io.sstable.metadata.MetadataType.serializer:Lorg/apache/cassandra/io/sstable/metadata/IMetadataComponentSerializer;
aload 3
aload 6
invokeinterface org.apache.cassandra.io.sstable.metadata.IMetadataComponentSerializer.serializedSize:(Lorg/apache/cassandra/io/sstable/format/Version;Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;)I
iadd
istore 5
end local 8 end local 6 10: StackMap locals:
StackMap stack:
aload 7
invokeinterface java.util.Iterator.hasNext:()Z
ifne 5
11: aload 4
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 7
goto 14
StackMap locals:
StackMap stack:
12: aload 7
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.metadata.MetadataComponent
astore 6
start local 6 13: aload 6
invokevirtual org.apache.cassandra.io.sstable.metadata.MetadataComponent.getType:()Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
getfield org.apache.cassandra.io.sstable.metadata.MetadataType.serializer:Lorg/apache/cassandra/io/sstable/metadata/IMetadataComponentSerializer;
aload 3
aload 6
aload 2
invokeinterface org.apache.cassandra.io.sstable.metadata.IMetadataComponentSerializer.serialize:(Lorg/apache/cassandra/io/sstable/format/Version;Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;Lorg/apache/cassandra/io/util/DataOutputPlus;)V
end local 6 14: StackMap locals:
StackMap stack:
aload 7
invokeinterface java.util.Iterator.hasNext:()Z
ifne 12
15: return
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lorg/apache/cassandra/io/sstable/metadata/MetadataSerializer;
0 16 1 components Ljava/util/Map<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;>;
0 16 2 out Lorg/apache/cassandra/io/util/DataOutputPlus;
0 16 3 version Lorg/apache/cassandra/io/sstable/format/Version;
1 16 4 sortedComponents Ljava/util/List<Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;>;
4 16 5 lastPosition I
6 10 6 component Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;
7 10 8 type Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
13 14 6 component Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;
Exceptions:
throws java.io.IOException
Signature: (Ljava/util/Map<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;>;Lorg/apache/cassandra/io/util/DataOutputPlus;Lorg/apache/cassandra/io/sstable/format/Version;)V
MethodParameters:
Name Flags
components
out
version
public java.util.Map<org.apache.cassandra.io.sstable.metadata.MetadataType, org.apache.cassandra.io.sstable.metadata.MetadataComponent> deserialize(org.apache.cassandra.io.sstable.Descriptor, java.util.EnumSet<org.apache.cassandra.io.sstable.metadata.MetadataType>);
descriptor: (Lorg/apache/cassandra/io/sstable/Descriptor;Ljava/util/EnumSet;)Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=8, args_size=3
start local 0 start local 1 start local 2 0: getstatic org.apache.cassandra.io.sstable.metadata.MetadataSerializer.logger:Lorg/slf4j/Logger;
ldc "Load metadata for {}"
aload 1
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
1: new java.io.File
dup
aload 1
getstatic org.apache.cassandra.io.sstable.Component.STATS:Lorg/apache/cassandra/io/sstable/Component;
invokevirtual org.apache.cassandra.io.sstable.Descriptor.filenameFor:(Lorg/apache/cassandra/io/sstable/Component;)Ljava/lang/String;
invokespecial java.io.File.<init>:(Ljava/lang/String;)V
astore 4
start local 4 2: aload 4
invokevirtual java.io.File.exists:()Z
ifne 7
3: getstatic org.apache.cassandra.io.sstable.metadata.MetadataSerializer.logger:Lorg/slf4j/Logger;
ldc "No sstable stats for {}"
aload 1
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
4: new java.util.EnumMap
dup
ldc Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
invokespecial java.util.EnumMap.<init>:(Ljava/lang/Class;)V
astore 3
start local 3 5: aload 3
getstatic org.apache.cassandra.io.sstable.metadata.MetadataType.STATS:Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
invokestatic org.apache.cassandra.io.sstable.metadata.MetadataCollector.defaultStatsMetadata:()Lorg/apache/cassandra/io/sstable/metadata/StatsMetadata;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
6: goto 16
end local 3 7: StackMap locals: org.apache.cassandra.io.sstable.metadata.MetadataSerializer org.apache.cassandra.io.sstable.Descriptor java.util.EnumSet top java.io.File
StackMap stack:
aconst_null
astore 5
aconst_null
astore 6
8: aload 4
invokestatic org.apache.cassandra.io.util.RandomAccessReader.open:(Ljava/io/File;)Lorg/apache/cassandra/io/util/RandomAccessReader;
astore 7
start local 7 9: aload 0
aload 1
aload 7
aload 2
invokevirtual org.apache.cassandra.io.sstable.metadata.MetadataSerializer.deserialize:(Lorg/apache/cassandra/io/sstable/Descriptor;Lorg/apache/cassandra/io/util/FileDataInput;Ljava/util/EnumSet;)Ljava/util/Map;
astore 3
start local 3 10: aload 7
ifnull 16
aload 7
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.close:()V
goto 16
end local 3 StackMap locals: org.apache.cassandra.io.sstable.metadata.MetadataSerializer org.apache.cassandra.io.sstable.Descriptor java.util.EnumSet top java.io.File java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.RandomAccessReader
StackMap stack: java.lang.Throwable
11: astore 5
aload 7
ifnull 12
aload 7
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.close:()V
end local 7 StackMap locals:
StackMap stack:
12: aload 5
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
13: astore 6
aload 5
ifnonnull 14
aload 6
astore 5
goto 15
StackMap locals:
StackMap stack:
14: aload 5
aload 6
if_acmpeq 15
aload 5
aload 6
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
15: aload 5
athrow
start local 3 16: StackMap locals: org.apache.cassandra.io.sstable.metadata.MetadataSerializer org.apache.cassandra.io.sstable.Descriptor java.util.EnumSet java.util.Map java.io.File
StackMap stack:
aload 3
areturn
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/io/sstable/metadata/MetadataSerializer;
0 17 1 descriptor Lorg/apache/cassandra/io/sstable/Descriptor;
0 17 2 types Ljava/util/EnumSet<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;>;
5 7 3 components Ljava/util/Map<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;>;
10 11 3 components Ljava/util/Map<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;>;
16 17 3 components Ljava/util/Map<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;>;
2 17 4 statsFile Ljava/io/File;
9 12 7 r Lorg/apache/cassandra/io/util/RandomAccessReader;
Exception table:
from to target type
9 10 11 any
8 13 13 any
Exceptions:
throws java.io.IOException
Signature: (Lorg/apache/cassandra/io/sstable/Descriptor;Ljava/util/EnumSet<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;>;)Ljava/util/Map<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;>;
MethodParameters:
Name Flags
descriptor
types
public org.apache.cassandra.io.sstable.metadata.MetadataComponent deserialize(org.apache.cassandra.io.sstable.Descriptor, org.apache.cassandra.io.sstable.metadata.MetadataType);
descriptor: (Lorg/apache/cassandra/io/sstable/Descriptor;Lorg/apache/cassandra/io/sstable/metadata/MetadataType;)Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
invokestatic java.util.EnumSet.of:(Ljava/lang/Enum;)Ljava/util/EnumSet;
invokevirtual org.apache.cassandra.io.sstable.metadata.MetadataSerializer.deserialize:(Lorg/apache/cassandra/io/sstable/Descriptor;Ljava/util/EnumSet;)Ljava/util/Map;
aload 2
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.metadata.MetadataComponent
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/io/sstable/metadata/MetadataSerializer;
0 1 1 descriptor Lorg/apache/cassandra/io/sstable/Descriptor;
0 1 2 type Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
descriptor
type
public java.util.Map<org.apache.cassandra.io.sstable.metadata.MetadataType, org.apache.cassandra.io.sstable.metadata.MetadataComponent> deserialize(org.apache.cassandra.io.sstable.Descriptor, org.apache.cassandra.io.util.FileDataInput, java.util.EnumSet<org.apache.cassandra.io.sstable.metadata.MetadataType>);
descriptor: (Lorg/apache/cassandra/io/sstable/Descriptor;Lorg/apache/cassandra/io/util/FileDataInput;Ljava/util/EnumSet;)Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=12, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new java.util.EnumMap
dup
ldc Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
invokespecial java.util.EnumMap.<init>:(Ljava/lang/Class;)V
astore 4
start local 4 1: aload 2
invokeinterface org.apache.cassandra.io.util.FileDataInput.readInt:()I
istore 5
start local 5 2: new java.util.EnumMap
dup
ldc Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
invokespecial java.util.EnumMap.<init>:(Ljava/lang/Class;)V
astore 6
start local 6 3: invokestatic org.apache.cassandra.io.sstable.metadata.MetadataType.values:()[Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
astore 7
start local 7 4: iconst_0
istore 8
start local 8 5: goto 8
6: StackMap locals: org.apache.cassandra.io.sstable.metadata.MetadataSerializer org.apache.cassandra.io.sstable.Descriptor org.apache.cassandra.io.util.FileDataInput java.util.EnumSet java.util.Map int java.util.Map org.apache.cassandra.io.sstable.metadata.MetadataType[] int
StackMap stack:
aload 6
aload 7
aload 2
invokeinterface org.apache.cassandra.io.util.FileDataInput.readInt:()I
aaload
aload 2
invokeinterface org.apache.cassandra.io.util.FileDataInput.readInt:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
7: iinc 8 1
StackMap locals:
StackMap stack:
8: iload 8
iload 5
if_icmplt 6
end local 8 9: aload 3
invokevirtual java.util.EnumSet.iterator:()Ljava/util/Iterator;
astore 9
goto 16
StackMap locals: org.apache.cassandra.io.sstable.metadata.MetadataSerializer org.apache.cassandra.io.sstable.Descriptor org.apache.cassandra.io.util.FileDataInput java.util.EnumSet java.util.Map int java.util.Map org.apache.cassandra.io.sstable.metadata.MetadataType[] top java.util.Iterator
StackMap stack:
10: aload 9
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.metadata.MetadataType
astore 8
start local 8 11: aload 6
aload 8
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.Integer
astore 10
start local 10 12: aload 10
ifnull 16
13: aload 2
aload 10
invokevirtual java.lang.Integer.intValue:()I
i2l
invokeinterface org.apache.cassandra.io.util.FileDataInput.seek:(J)V
14: aload 8
getfield org.apache.cassandra.io.sstable.metadata.MetadataType.serializer:Lorg/apache/cassandra/io/sstable/metadata/IMetadataComponentSerializer;
aload 1
getfield org.apache.cassandra.io.sstable.Descriptor.version:Lorg/apache/cassandra/io/sstable/format/Version;
aload 2
invokeinterface org.apache.cassandra.io.sstable.metadata.IMetadataComponentSerializer.deserialize:(Lorg/apache/cassandra/io/sstable/format/Version;Lorg/apache/cassandra/io/util/DataInputPlus;)Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;
astore 11
start local 11 15: aload 4
aload 8
aload 11
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 11 end local 10 end local 8 16: StackMap locals:
StackMap stack:
aload 9
invokeinterface java.util.Iterator.hasNext:()Z
ifne 10
17: aload 4
areturn
end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 this Lorg/apache/cassandra/io/sstable/metadata/MetadataSerializer;
0 18 1 descriptor Lorg/apache/cassandra/io/sstable/Descriptor;
0 18 2 in Lorg/apache/cassandra/io/util/FileDataInput;
0 18 3 types Ljava/util/EnumSet<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;>;
1 18 4 components Ljava/util/Map<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;>;
2 18 5 numComponents I
3 18 6 toc Ljava/util/Map<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;Ljava/lang/Integer;>;
4 18 7 values [Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
5 9 8 i I
11 16 8 type Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
12 16 10 offset Ljava/lang/Integer;
15 16 11 component Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;
Exceptions:
throws java.io.IOException
Signature: (Lorg/apache/cassandra/io/sstable/Descriptor;Lorg/apache/cassandra/io/util/FileDataInput;Ljava/util/EnumSet<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;>;)Ljava/util/Map<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;>;
MethodParameters:
Name Flags
descriptor
in
types
public void mutateLevel(org.apache.cassandra.io.sstable.Descriptor, int);
descriptor: (Lorg/apache/cassandra/io/sstable/Descriptor;I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=3
start local 0 start local 1 start local 2 0: getstatic org.apache.cassandra.io.sstable.metadata.MetadataSerializer.logger:Lorg/slf4j/Logger;
ldc "Mutating {} to level {}"
aload 1
getstatic org.apache.cassandra.io.sstable.Component.STATS:Lorg/apache/cassandra/io/sstable/Component;
invokevirtual org.apache.cassandra.io.sstable.Descriptor.filenameFor:(Lorg/apache/cassandra/io/sstable/Component;)Ljava/lang/String;
iload 2
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
1: aload 0
aload 1
ldc Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
invokestatic java.util.EnumSet.allOf:(Ljava/lang/Class;)Ljava/util/EnumSet;
invokevirtual org.apache.cassandra.io.sstable.metadata.MetadataSerializer.deserialize:(Lorg/apache/cassandra/io/sstable/Descriptor;Ljava/util/EnumSet;)Ljava/util/Map;
astore 3
start local 3 2: aload 3
getstatic org.apache.cassandra.io.sstable.metadata.MetadataType.STATS:Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
invokeinterface java.util.Map.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.metadata.StatsMetadata
astore 4
start local 4 3: aload 3
getstatic org.apache.cassandra.io.sstable.metadata.MetadataType.STATS:Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
aload 4
iload 2
invokevirtual org.apache.cassandra.io.sstable.metadata.StatsMetadata.mutateLevel:(I)Lorg/apache/cassandra/io/sstable/metadata/StatsMetadata;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
4: aload 0
aload 1
aload 3
invokevirtual org.apache.cassandra.io.sstable.metadata.MetadataSerializer.rewriteSSTableMetadata:(Lorg/apache/cassandra/io/sstable/Descriptor;Ljava/util/Map;)V
5: return
end local 4 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/io/sstable/metadata/MetadataSerializer;
0 6 1 descriptor Lorg/apache/cassandra/io/sstable/Descriptor;
0 6 2 newLevel I
2 6 3 currentComponents Ljava/util/Map<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;>;
3 6 4 stats Lorg/apache/cassandra/io/sstable/metadata/StatsMetadata;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
descriptor
newLevel
public void mutateRepairedAt(org.apache.cassandra.io.sstable.Descriptor, long);
descriptor: (Lorg/apache/cassandra/io/sstable/Descriptor;J)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=6, args_size=3
start local 0 start local 1 start local 2 0: getstatic org.apache.cassandra.io.sstable.metadata.MetadataSerializer.logger:Lorg/slf4j/Logger;
ldc "Mutating {} to repairedAt time {}"
aload 1
getstatic org.apache.cassandra.io.sstable.Component.STATS:Lorg/apache/cassandra/io/sstable/Component;
invokevirtual org.apache.cassandra.io.sstable.Descriptor.filenameFor:(Lorg/apache/cassandra/io/sstable/Component;)Ljava/lang/String;
lload 2
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
1: aload 0
aload 1
ldc Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
invokestatic java.util.EnumSet.allOf:(Ljava/lang/Class;)Ljava/util/EnumSet;
invokevirtual org.apache.cassandra.io.sstable.metadata.MetadataSerializer.deserialize:(Lorg/apache/cassandra/io/sstable/Descriptor;Ljava/util/EnumSet;)Ljava/util/Map;
astore 4
start local 4 2: aload 4
getstatic org.apache.cassandra.io.sstable.metadata.MetadataType.STATS:Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
invokeinterface java.util.Map.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.metadata.StatsMetadata
astore 5
start local 5 3: aload 4
getstatic org.apache.cassandra.io.sstable.metadata.MetadataType.STATS:Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
aload 5
lload 2
invokevirtual org.apache.cassandra.io.sstable.metadata.StatsMetadata.mutateRepairedAt:(J)Lorg/apache/cassandra/io/sstable/metadata/StatsMetadata;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
4: aload 0
aload 1
aload 4
invokevirtual org.apache.cassandra.io.sstable.metadata.MetadataSerializer.rewriteSSTableMetadata:(Lorg/apache/cassandra/io/sstable/Descriptor;Ljava/util/Map;)V
5: return
end local 5 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/io/sstable/metadata/MetadataSerializer;
0 6 1 descriptor Lorg/apache/cassandra/io/sstable/Descriptor;
0 6 2 newRepairedAt J
2 6 4 currentComponents Ljava/util/Map<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;>;
3 6 5 stats Lorg/apache/cassandra/io/sstable/metadata/StatsMetadata;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
descriptor
newRepairedAt
private void rewriteSSTableMetadata(org.apache.cassandra.io.sstable.Descriptor, java.util.Map<org.apache.cassandra.io.sstable.metadata.MetadataType, org.apache.cassandra.io.sstable.metadata.MetadataComponent>);
descriptor: (Lorg/apache/cassandra/io/sstable/Descriptor;Ljava/util/Map;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=7, args_size=3
start local 0 start local 1 start local 2 0: aload 1
getstatic org.apache.cassandra.io.sstable.Component.STATS:Lorg/apache/cassandra/io/sstable/Component;
invokevirtual org.apache.cassandra.io.sstable.Descriptor.tmpFilenameFor:(Lorg/apache/cassandra/io/sstable/Component;)Ljava/lang/String;
astore 3
start local 3 1: aconst_null
astore 4
aconst_null
astore 5
2: new org.apache.cassandra.io.util.BufferedDataOutputStreamPlus
dup
new java.io.FileOutputStream
dup
aload 3
invokespecial java.io.FileOutputStream.<init>:(Ljava/lang/String;)V
invokespecial org.apache.cassandra.io.util.BufferedDataOutputStreamPlus.<init>:(Ljava/io/FileOutputStream;)V
astore 6
start local 6 3: aload 0
aload 2
aload 6
aload 1
getfield org.apache.cassandra.io.sstable.Descriptor.version:Lorg/apache/cassandra/io/sstable/format/Version;
invokevirtual org.apache.cassandra.io.sstable.metadata.MetadataSerializer.serialize:(Ljava/util/Map;Lorg/apache/cassandra/io/util/DataOutputPlus;Lorg/apache/cassandra/io/sstable/format/Version;)V
4: aload 6
invokevirtual org.apache.cassandra.io.util.DataOutputStreamPlus.flush:()V
5: aload 6
ifnull 11
aload 6
invokevirtual org.apache.cassandra.io.util.DataOutputStreamPlus.close:()V
goto 11
StackMap locals: org.apache.cassandra.io.sstable.metadata.MetadataSerializer org.apache.cassandra.io.sstable.Descriptor java.util.Map java.lang.String java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.DataOutputStreamPlus
StackMap stack: java.lang.Throwable
6: astore 4
aload 6
ifnull 7
aload 6
invokevirtual org.apache.cassandra.io.util.DataOutputStreamPlus.close:()V
end local 6 StackMap locals:
StackMap stack:
7: aload 4
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
8: astore 5
aload 4
ifnonnull 9
aload 5
astore 4
goto 10
StackMap locals:
StackMap stack:
9: aload 4
aload 5
if_acmpeq 10
aload 4
aload 5
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
10: aload 4
athrow
11: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.utils.FBUtilities.isWindows:Z
ifeq 13
12: aload 1
getstatic org.apache.cassandra.io.sstable.Component.STATS:Lorg/apache/cassandra/io/sstable/Component;
invokevirtual org.apache.cassandra.io.sstable.Descriptor.filenameFor:(Lorg/apache/cassandra/io/sstable/Component;)Ljava/lang/String;
invokestatic org.apache.cassandra.io.util.FileUtils.delete:(Ljava/lang/String;)Z
pop
13: StackMap locals:
StackMap stack:
aload 3
aload 1
getstatic org.apache.cassandra.io.sstable.Component.STATS:Lorg/apache/cassandra/io/sstable/Component;
invokevirtual org.apache.cassandra.io.sstable.Descriptor.filenameFor:(Lorg/apache/cassandra/io/sstable/Component;)Ljava/lang/String;
invokestatic org.apache.cassandra.io.util.FileUtils.renameWithConfirm:(Ljava/lang/String;Ljava/lang/String;)V
14: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lorg/apache/cassandra/io/sstable/metadata/MetadataSerializer;
0 15 1 descriptor Lorg/apache/cassandra/io/sstable/Descriptor;
0 15 2 currentComponents Ljava/util/Map<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;>;
1 15 3 filePath Ljava/lang/String;
3 7 6 out Lorg/apache/cassandra/io/util/DataOutputStreamPlus;
Exception table:
from to target type
3 5 6 any
2 8 8 any
Exceptions:
throws java.io.IOException
Signature: (Lorg/apache/cassandra/io/sstable/Descriptor;Ljava/util/Map<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;>;)V
MethodParameters:
Name Flags
descriptor
currentComponents
}
SourceFile: "MetadataSerializer.java"