public class org.apache.cassandra.io.sstable.IndexSummaryRedistribution extends org.apache.cassandra.db.compaction.CompactionInfo$Holder
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.io.sstable.IndexSummaryRedistribution
super_class: org.apache.cassandra.db.compaction.CompactionInfo$Holder
{
private static final org.slf4j.Logger logger;
descriptor: Lorg/slf4j/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
static final double UPSAMPLE_THRESHOLD;
descriptor: D
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: 1.5
static final double DOWNSAMPLE_THESHOLD;
descriptor: D
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: 0.75
private final java.util.List<org.apache.cassandra.io.sstable.format.SSTableReader> compacting;
descriptor: Ljava/util/List;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
private final java.util.Map<java.util.UUID, org.apache.cassandra.db.lifecycle.LifecycleTransaction> transactions;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Ljava/util/UUID;Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;>;
private final long memoryPoolBytes;
descriptor: J
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.UUID compactionId;
descriptor: Ljava/util/UUID;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private volatile long remainingSpace;
descriptor: J
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/io/sstable/IndexSummaryRedistribution;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic org.apache.cassandra.io.sstable.IndexSummaryRedistribution.logger:Lorg/slf4j/Logger;
1: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(java.util.List<org.apache.cassandra.io.sstable.format.SSTableReader>, java.util.Map<java.util.UUID, org.apache.cassandra.db.lifecycle.LifecycleTransaction>, );
descriptor: (Ljava/util/List;Ljava/util/Map;J)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokespecial org.apache.cassandra.db.compaction.CompactionInfo$Holder.<init>:()V
1: aload 0
aload 1
putfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.compacting:Ljava/util/List;
2: aload 0
aload 2
putfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.transactions:Ljava/util/Map;
3: aload 0
lload 3
putfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.memoryPoolBytes:J
4: aload 0
invokestatic java.util.UUID.randomUUID:()Ljava/util/UUID;
putfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.compactionId:Ljava/util/UUID;
5: return
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/IndexSummaryRedistribution;
0 6 1 compacting Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
0 6 2 transactions Ljava/util/Map<Ljava/util/UUID;Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;>;
0 6 3 memoryPoolBytes J
Signature: (Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;Ljava/util/Map<Ljava/util/UUID;Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;>;J)V
MethodParameters:
Name Flags
compacting
transactions
memoryPoolBytes
public java.util.List<org.apache.cassandra.io.sstable.format.SSTableReader> redistributeSummaries();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=9, locals=17, args_size=1
start local 0 0: getstatic org.apache.cassandra.io.sstable.IndexSummaryRedistribution.logger:Lorg/slf4j/Logger;
ldc "Redistributing index summaries"
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;)V
1: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 1
start local 1 2: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 2
start local 2 3: aload 0
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.transactions:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 4
goto 13
StackMap locals: org.apache.cassandra.io.sstable.IndexSummaryRedistribution java.util.List java.util.List top java.util.Iterator
StackMap stack:
4: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.lifecycle.LifecycleTransaction
astore 3
start local 3 5: aload 3
invokevirtual org.apache.cassandra.db.lifecycle.LifecycleTransaction.originals:()Ljava/util/Set;
invokestatic com.google.common.collect.ImmutableList.copyOf:(Ljava/util/Collection;)Lcom/google/common/collect/ImmutableList;
invokevirtual com.google.common.collect.ImmutableList.iterator:()Ljava/util/Iterator;
astore 6
goto 11
StackMap locals: org.apache.cassandra.io.sstable.IndexSummaryRedistribution java.util.List java.util.List org.apache.cassandra.db.lifecycle.LifecycleTransaction java.util.Iterator top java.util.Iterator
StackMap stack:
6: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 5
start local 5 7: getstatic org.apache.cassandra.io.sstable.IndexSummaryRedistribution.logger:Lorg/slf4j/Logger;
ldc "SSTable {} cannot be re-sampled due to old sstable format"
aload 5
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
8: aload 5
getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
getfield org.apache.cassandra.io.sstable.Descriptor.version:Lorg/apache/cassandra/io/sstable/format/Version;
invokevirtual org.apache.cassandra.io.sstable.format.Version.hasSamplingLevel:()Z
ifne 11
9: aload 1
aload 5
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
10: aload 3
aload 5
invokevirtual org.apache.cassandra.db.lifecycle.LifecycleTransaction.cancel:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
end local 5 11: StackMap locals:
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 6
12: aload 2
aload 3
invokevirtual org.apache.cassandra.db.lifecycle.LifecycleTransaction.originals:()Ljava/util/Set;
invokeinterface java.util.List.addAll:(Ljava/util/Collection;)Z
pop
end local 3 13: StackMap locals: org.apache.cassandra.io.sstable.IndexSummaryRedistribution java.util.List java.util.List top java.util.Iterator
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
14: lconst_0
lstore 3
start local 3 15: aload 0
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.compacting:Ljava/util/List;
aload 2
invokestatic com.google.common.collect.Iterables.concat:(Ljava/lang/Iterable;Ljava/lang/Iterable;)Ljava/lang/Iterable;
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 6
goto 18
StackMap locals: org.apache.cassandra.io.sstable.IndexSummaryRedistribution java.util.List java.util.List long top java.util.Iterator
StackMap stack:
16: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 5
start local 5 17: lload 3
aload 5
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getIndexSummaryOffHeapSize:()J
ladd
lstore 3
end local 5 18: StackMap locals:
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 16
19: getstatic org.apache.cassandra.io.sstable.IndexSummaryRedistribution.logger:Lorg/slf4j/Logger;
ldc "Beginning redistribution of index summaries for {} sstables with memory pool size {} MB; current spaced used is {} MB"
iconst_3
anewarray java.lang.Object
dup
iconst_0
20: aload 2
invokeinterface java.util.List.size:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
aload 0
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.memoryPoolBytes:J
ldc 1024
ldiv
ldc 1024
ldiv
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
dup
iconst_2
lload 3
l2d
ldc 1024.0
ddiv
ldc 1024.0
ddiv
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
aastore
21: invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;[Ljava/lang/Object;)V
22: new java.util.HashMap
dup
aload 2
invokeinterface java.util.List.size:()I
invokespecial java.util.HashMap.<init>:(I)V
astore 5
start local 5 23: dconst_0
dstore 6
start local 6 24: aload 2
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 9
goto 32
StackMap locals: org.apache.cassandra.io.sstable.IndexSummaryRedistribution java.util.List java.util.List long java.util.Map double top java.util.Iterator
StackMap stack:
25: aload 9
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 8
start local 8 26: aload 0
invokevirtual org.apache.cassandra.io.sstable.IndexSummaryRedistribution.isStopRequested:()Z
ifeq 28
27: new org.apache.cassandra.db.compaction.CompactionInterruptedException
dup
aload 0
invokevirtual org.apache.cassandra.io.sstable.IndexSummaryRedistribution.getCompactionInfo:()Lorg/apache/cassandra/db/compaction/CompactionInfo;
invokespecial org.apache.cassandra.db.compaction.CompactionInterruptedException.<init>:(Lorg/apache/cassandra/db/compaction/CompactionInfo;)V
athrow
28: StackMap locals: org.apache.cassandra.io.sstable.IndexSummaryRedistribution java.util.List java.util.List long java.util.Map double org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator
StackMap stack:
aload 8
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getReadMeter:()Lorg/apache/cassandra/metrics/RestorableMeter;
ifnull 32
29: aload 8
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getReadMeter:()Lorg/apache/cassandra/metrics/RestorableMeter;
invokevirtual org.apache.cassandra.metrics.RestorableMeter.fifteenMinuteRate:()D
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
astore 10
start local 10 30: dload 6
aload 10
invokevirtual java.lang.Double.doubleValue:()D
dadd
dstore 6
31: aload 5
aload 8
aload 10
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 10 end local 8 32: StackMap locals: org.apache.cassandra.io.sstable.IndexSummaryRedistribution java.util.List java.util.List long java.util.Map double top java.util.Iterator
StackMap stack:
aload 9
invokeinterface java.util.Iterator.hasNext:()Z
ifne 25
33: getstatic org.apache.cassandra.io.sstable.IndexSummaryRedistribution.logger:Lorg/slf4j/Logger;
ldc "Total reads/sec across all sstables in index summary resize process: {}"
dload 6
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
34: new java.util.ArrayList
dup
aload 2
invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
astore 8
start local 8 35: aload 8
new org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ReadRateComparator
dup
aload 5
invokespecial org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ReadRateComparator.<init>:(Ljava/util/Map;)V
invokestatic java.util.Collections.sort:(Ljava/util/List;Ljava/util/Comparator;)V
36: aload 0
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.memoryPoolBytes:J
lstore 9
start local 9 37: aload 0
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.compacting:Ljava/util/List;
aload 1
invokestatic com.google.common.collect.Iterables.concat:(Ljava/lang/Iterable;Ljava/lang/Iterable;)Ljava/lang/Iterable;
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 12
goto 40
StackMap locals: org.apache.cassandra.io.sstable.IndexSummaryRedistribution java.util.List java.util.List long java.util.Map double java.util.List long top java.util.Iterator
StackMap stack:
38: aload 12
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 11
start local 11 39: lload 9
aload 11
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getIndexSummaryOffHeapSize:()J
lsub
lstore 9
end local 11 40: StackMap locals:
StackMap stack:
aload 12
invokeinterface java.util.Iterator.hasNext:()Z
ifne 38
41: getstatic org.apache.cassandra.io.sstable.IndexSummaryRedistribution.logger:Lorg/slf4j/Logger;
ldc "Index summaries for compacting SSTables are using {} MB of space"
42: aload 0
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.memoryPoolBytes:J
lload 9
lsub
l2d
ldc 1024.0
ddiv
ldc 1024.0
ddiv
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
43: invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
44: aconst_null
astore 12
aconst_null
astore 13
45: aload 8
invokestatic org.apache.cassandra.utils.concurrent.Refs.ref:(Ljava/lang/Iterable;)Lorg/apache/cassandra/utils/concurrent/Refs;
astore 14
start local 14 46: aload 0
aload 8
aload 0
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.transactions:Ljava/util/Map;
dload 6
lload 9
invokevirtual org.apache.cassandra.io.sstable.IndexSummaryRedistribution.adjustSamplingLevels:(Ljava/util/List;Ljava/util/Map;DJ)Ljava/util/List;
astore 11
start local 11 47: aload 0
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.transactions:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 16
goto 50
StackMap locals: org.apache.cassandra.io.sstable.IndexSummaryRedistribution java.util.List java.util.List long java.util.Map double java.util.List long java.util.List java.lang.Throwable java.lang.Throwable org.apache.cassandra.utils.concurrent.Refs top java.util.Iterator
StackMap stack:
48: aload 16
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.lifecycle.LifecycleTransaction
astore 15
start local 15 49: aload 15
invokevirtual org.apache.cassandra.db.lifecycle.LifecycleTransaction.finish:()Ljava/lang/Object;
pop
end local 15 50: StackMap locals:
StackMap stack:
aload 16
invokeinterface java.util.Iterator.hasNext:()Z
ifne 48
51: aload 14
ifnull 57
aload 14
invokevirtual org.apache.cassandra.utils.concurrent.Refs.close:()V
goto 57
end local 11 StackMap locals: org.apache.cassandra.io.sstable.IndexSummaryRedistribution java.util.List java.util.List long java.util.Map double java.util.List long top java.lang.Throwable java.lang.Throwable org.apache.cassandra.utils.concurrent.Refs
StackMap stack: java.lang.Throwable
52: astore 12
aload 14
ifnull 53
aload 14
invokevirtual org.apache.cassandra.utils.concurrent.Refs.close:()V
end local 14 StackMap locals:
StackMap stack:
53: aload 12
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
54: astore 13
aload 12
ifnonnull 55
aload 13
astore 12
goto 56
StackMap locals:
StackMap stack:
55: aload 12
aload 13
if_acmpeq 56
aload 12
aload 13
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
56: aload 12
athrow
start local 11 57: StackMap locals: org.apache.cassandra.io.sstable.IndexSummaryRedistribution java.util.List java.util.List long java.util.Map double java.util.List long java.util.List
StackMap stack:
lconst_0
lstore 3
58: aload 0
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.compacting:Ljava/util/List;
aload 1
aload 11
invokestatic com.google.common.collect.Iterables.concat:(Ljava/lang/Iterable;Ljava/lang/Iterable;Ljava/lang/Iterable;)Ljava/lang/Iterable;
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 13
goto 61
StackMap locals: org.apache.cassandra.io.sstable.IndexSummaryRedistribution java.util.List java.util.List long java.util.Map double java.util.List long java.util.List top java.util.Iterator
StackMap stack:
59: aload 13
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 12
start local 12 60: lload 3
aload 12
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getIndexSummaryOffHeapSize:()J
ladd
lstore 3
end local 12 61: StackMap locals:
StackMap stack:
aload 13
invokeinterface java.util.Iterator.hasNext:()Z
ifne 59
62: getstatic org.apache.cassandra.io.sstable.IndexSummaryRedistribution.logger:Lorg/slf4j/Logger;
ldc "Completed resizing of index summaries; current approximate memory used: {}"
63: lload 3
invokestatic org.apache.cassandra.utils.FBUtilities.prettyPrintMemory:(J)Ljava/lang/String;
64: invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
65: aload 11
areturn
end local 11 end local 9 end local 8 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 66 0 this Lorg/apache/cassandra/io/sstable/IndexSummaryRedistribution;
2 66 1 oldFormatSSTables Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
3 66 2 redistribute Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
5 13 3 txn Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;
7 11 5 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
15 66 3 total J
17 18 5 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
23 66 5 readRates Ljava/util/Map<Lorg/apache/cassandra/io/sstable/format/SSTableReader;Ljava/lang/Double;>;
24 66 6 totalReadsPerSec D
26 32 8 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
30 32 10 readRate Ljava/lang/Double;
35 66 8 sstablesByHotness Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
37 66 9 remainingBytes J
39 40 11 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
47 52 11 newSSTables Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
57 66 11 newSSTables Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
46 53 14 refs Lorg/apache/cassandra/utils/concurrent/Refs<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
49 50 15 txn Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;
60 61 12 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
Exception table:
from to target type
46 51 52 any
45 54 54 any
Exceptions:
throws java.io.IOException
Signature: ()Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
private java.util.List<org.apache.cassandra.io.sstable.format.SSTableReader> adjustSamplingLevels(java.util.List<org.apache.cassandra.io.sstable.format.SSTableReader>, java.util.Map<java.util.UUID, org.apache.cassandra.db.lifecycle.LifecycleTransaction>, double, long);
descriptor: (Ljava/util/List;Ljava/util/Map;DJ)Ljava/util/List;
flags: (0x0002) ACC_PRIVATE
Code:
stack=9, locals=33, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 5 0: new java.util.ArrayList
dup
aload 1
invokeinterface java.util.List.size:()I
iconst_4
idiv
invokespecial java.util.ArrayList.<init>:(I)V
astore 7
start local 7 1: new java.util.ArrayList
dup
aload 1
invokeinterface java.util.List.size:()I
iconst_4
idiv
invokespecial java.util.ArrayList.<init>:(I)V
astore 8
start local 8 2: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 9
start local 9 3: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 10
start local 10 4: new java.util.ArrayList
dup
aload 1
invokeinterface java.util.List.size:()I
invokespecial java.util.ArrayList.<init>:(I)V
astore 11
start local 11 5: aload 0
lload 5
putfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.remainingSpace:J
6: aload 1
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 13
goto 71
StackMap locals: org.apache.cassandra.io.sstable.IndexSummaryRedistribution java.util.List java.util.Map double long java.util.List java.util.List java.util.List java.util.List java.util.List top java.util.Iterator
StackMap stack:
7: aload 13
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 12
start local 12 8: aload 0
invokevirtual org.apache.cassandra.io.sstable.IndexSummaryRedistribution.isStopRequested:()Z
ifeq 10
9: new org.apache.cassandra.db.compaction.CompactionInterruptedException
dup
aload 0
invokevirtual org.apache.cassandra.io.sstable.IndexSummaryRedistribution.getCompactionInfo:()Lorg/apache/cassandra/db/compaction/CompactionInfo;
invokespecial org.apache.cassandra.db.compaction.CompactionInterruptedException.<init>:(Lorg/apache/cassandra/db/compaction/CompactionInfo;)V
athrow
10: StackMap locals: org.apache.cassandra.io.sstable.IndexSummaryRedistribution java.util.List java.util.Map double long java.util.List java.util.List java.util.List java.util.List java.util.List org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator
StackMap stack:
aload 12
getfield org.apache.cassandra.io.sstable.format.SSTableReader.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.params:Lorg/apache/cassandra/schema/TableParams;
getfield org.apache.cassandra.schema.TableParams.minIndexInterval:I
istore 14
start local 14 11: aload 12
getfield org.apache.cassandra.io.sstable.format.SSTableReader.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.params:Lorg/apache/cassandra/schema/TableParams;
getfield org.apache.cassandra.schema.TableParams.maxIndexInterval:I
istore 15
start local 15 12: aload 12
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getReadMeter:()Lorg/apache/cassandra/metrics/RestorableMeter;
ifnonnull 13
dconst_0
goto 14
StackMap locals: int int
StackMap stack:
13: aload 12
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getReadMeter:()Lorg/apache/cassandra/metrics/RestorableMeter;
invokevirtual org.apache.cassandra.metrics.RestorableMeter.fifteenMinuteRate:()D
StackMap locals:
StackMap stack: double
14: dstore 16
start local 16 15: aload 0
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.remainingSpace:J
l2d
dload 16
dload 3
ddiv
dmul
invokestatic java.lang.Math.round:(D)J
lstore 18
start local 18 16: aload 12
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getIndexSummarySize:()I
istore 20
start local 20 17: aload 12
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getIndexSummaryOffHeapSize:()J
l2d
iload 20
i2d
ddiv
dstore 21
start local 21 18: lconst_1
lload 18
l2d
dload 21
ddiv
invokestatic java.lang.Math.round:(D)J
invokestatic java.lang.Math.max:(JJ)J
lstore 23
start local 23 19: aload 12
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getIndexSummarySamplingLevel:()I
istore 25
start local 25 20: aload 12
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getMaxIndexSummarySize:()I
istore 26
start local 26 21: aload 12
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getMinIndexInterval:()I
iload 14
if_icmpeq 28
22: iload 25
i2d
iload 14
i2d
aload 12
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getMinIndexInterval:()I
i2d
ddiv
dmul
invokestatic java.lang.Math.round:(D)J
l2i
istore 27
start local 27 23: iload 26
i2d
aload 12
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getMinIndexInterval:()I
i2d
iload 14
i2d
ddiv
dmul
invokestatic java.lang.Math.round:(D)J
l2i
istore 26
24: getstatic org.apache.cassandra.io.sstable.IndexSummaryRedistribution.logger:Lorg/slf4j/Logger;
ldc "min_index_interval changed from {} to {}, so the current sampling level for {} is effectively now {} (was {})"
iconst_5
anewarray java.lang.Object
dup
iconst_0
25: aload 12
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getMinIndexInterval:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
iload 14
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_2
aload 12
aastore
dup
iconst_3
iload 27
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_4
iload 25
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
26: invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;[Ljava/lang/Object;)V
27: iload 27
istore 25
end local 27 28: StackMap locals: org.apache.cassandra.io.sstable.IndexSummaryRedistribution java.util.List java.util.Map double long java.util.List java.util.List java.util.List java.util.List java.util.List org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator int int double long int double long int int
StackMap stack:
iload 25
iload 20
lload 23
29: iload 14
iload 15
30: invokestatic org.apache.cassandra.io.sstable.IndexSummaryBuilder.calculateSamplingLevel:(IIJII)I
istore 27
start local 27 31: iload 27
iload 26
invokestatic org.apache.cassandra.io.sstable.IndexSummaryBuilder.entriesAtSamplingLevel:(II)I
istore 28
start local 28 32: aload 12
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getEffectiveIndexInterval:()D
dstore 29
start local 29 33: getstatic org.apache.cassandra.io.sstable.IndexSummaryRedistribution.logger:Lorg/slf4j/Logger;
ldc "{} has {} reads/sec; ideal space for index summary: {} ({} entries); considering moving from level {} ({} entries, {}) to level {} ({} entries, {})"
bipush 10
anewarray java.lang.Object
dup
iconst_0
34: aload 12
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getFilename:()Ljava/lang/String;
aastore
dup
iconst_1
dload 16
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
aastore
dup
iconst_2
lload 18
invokestatic org.apache.cassandra.utils.FBUtilities.prettyPrintMemory:(J)Ljava/lang/String;
aastore
dup
iconst_3
lload 23
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
dup
iconst_4
35: iload 25
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_5
iload 20
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
bipush 6
iload 20
i2d
dload 21
dmul
d2l
invokestatic org.apache.cassandra.utils.FBUtilities.prettyPrintMemory:(J)Ljava/lang/String;
aastore
dup
bipush 7
36: iload 27
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
bipush 8
iload 28
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
bipush 9
iload 28
i2d
dload 21
dmul
d2l
invokestatic org.apache.cassandra.utils.FBUtilities.prettyPrintMemory:(J)Ljava/lang/String;
aastore
37: invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;[Ljava/lang/Object;)V
38: dload 29
iload 14
i2d
dcmpg
ifge 46
39: getstatic org.apache.cassandra.io.sstable.IndexSummaryRedistribution.logger:Lorg/slf4j/Logger;
ldc "Forcing resample of {} because the current index interval ({}) is below min_index_interval ({})"
iconst_3
anewarray java.lang.Object
dup
iconst_0
40: aload 12
aastore
dup
iconst_1
dload 29
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
aastore
dup
iconst_2
iload 14
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
41: invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;[Ljava/lang/Object;)V
42: dload 21
iload 28
i2d
dmul
invokestatic java.lang.Math.ceil:(D)D
d2l
lstore 31
start local 31 43: aload 9
new org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry
dup
aload 12
lload 31
iload 27
invokespecial org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry.<init>:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;JI)V
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
44: aload 0
dup
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.remainingSpace:J
lload 31
lsub
putfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.remainingSpace:J
end local 31 45: goto 70
46: StackMap locals: int int double
StackMap stack:
dload 29
iload 15
i2d
dcmpl
ifle 56
47: getstatic org.apache.cassandra.io.sstable.IndexSummaryRedistribution.logger:Lorg/slf4j/Logger;
ldc "Forcing upsample of {} because the current index interval ({}) is above max_index_interval ({})"
iconst_3
anewarray java.lang.Object
dup
iconst_0
48: aload 12
aastore
dup
iconst_1
dload 29
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
aastore
dup
iconst_2
iload 15
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
49: invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;[Ljava/lang/Object;)V
50: iconst_1
sipush 128
iload 14
imul
iload 15
idiv
invokestatic java.lang.Math.max:(II)I
istore 27
51: iload 27
aload 12
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getMaxIndexSummarySize:()I
invokestatic org.apache.cassandra.io.sstable.IndexSummaryBuilder.entriesAtSamplingLevel:(II)I
istore 28
52: dload 21
iload 28
i2d
dmul
invokestatic java.lang.Math.ceil:(D)D
d2l
lstore 31
start local 31 53: aload 10
new org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry
dup
aload 12
lload 31
iload 27
invokespecial org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry.<init>:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;JI)V
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
54: aload 0
dup
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.remainingSpace:J
l2d
dload 21
iload 28
i2d
dmul
dsub
d2l
putfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.remainingSpace:J
end local 31 55: goto 70
56: StackMap locals:
StackMap stack:
lload 23
l2d
iload 20
i2d
ldc 1.5
dmul
dcmpl
iflt 61
iload 27
iload 25
if_icmple 61
57: dload 21
iload 28
i2d
dmul
invokestatic java.lang.Math.ceil:(D)D
d2l
lstore 31
start local 31 58: aload 8
new org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry
dup
aload 12
lload 31
iload 27
invokespecial org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry.<init>:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;JI)V
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
59: aload 0
dup
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.remainingSpace:J
l2d
dload 21
iload 28
i2d
dmul
dsub
d2l
putfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.remainingSpace:J
end local 31 60: goto 70
61: StackMap locals:
StackMap stack:
lload 23
l2d
iload 20
i2d
ldc 0.75
dmul
dcmpg
ifge 66
iload 27
iload 25
if_icmpge 66
62: dload 21
iload 28
i2d
dmul
invokestatic java.lang.Math.ceil:(D)D
d2l
lstore 31
start local 31 63: aload 7
new org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry
dup
aload 12
lload 31
iload 27
invokespecial org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry.<init>:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;JI)V
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
64: aload 0
dup
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.remainingSpace:J
lload 31
lsub
putfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.remainingSpace:J
end local 31 65: goto 70
66: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.io.sstable.IndexSummaryRedistribution.logger:Lorg/slf4j/Logger;
ldc "SSTable {} is within thresholds of ideal sampling"
aload 12
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
67: aload 0
dup
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.remainingSpace:J
aload 12
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getIndexSummaryOffHeapSize:()J
lsub
putfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.remainingSpace:J
68: aload 11
aload 12
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
69: aload 2
aload 12
getfield org.apache.cassandra.io.sstable.format.SSTableReader.metadata:Lorg/apache/cassandra/config/CFMetaData;
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.lifecycle.LifecycleTransaction
aload 12
invokevirtual org.apache.cassandra.db.lifecycle.LifecycleTransaction.cancel:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
70: StackMap locals:
StackMap stack:
dload 3
dload 16
dsub
dstore 3
end local 29 end local 28 end local 27 end local 26 end local 25 end local 23 end local 21 end local 20 end local 18 end local 16 end local 15 end local 14 end local 12 71: StackMap locals: org.apache.cassandra.io.sstable.IndexSummaryRedistribution java.util.List java.util.Map double long java.util.List java.util.List java.util.List java.util.List java.util.List top java.util.Iterator
StackMap stack:
aload 13
invokeinterface java.util.Iterator.hasNext:()Z
ifne 7
72: aload 0
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.remainingSpace:J
lconst_0
lcmp
ifle 80
73: aload 7
aload 0
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.remainingSpace:J
invokestatic org.apache.cassandra.io.sstable.IndexSummaryRedistribution.distributeRemainingSpace:(Ljava/util/List;J)Lorg/apache/cassandra/utils/Pair;
astore 12
start local 12 74: aload 12
getfield org.apache.cassandra.utils.Pair.right:Ljava/lang/Object;
checkcast java.util.List
astore 7
75: aload 11
aload 12
getfield org.apache.cassandra.utils.Pair.left:Ljava/lang/Object;
checkcast java.util.Collection
invokeinterface java.util.List.addAll:(Ljava/util/Collection;)Z
pop
76: aload 12
getfield org.apache.cassandra.utils.Pair.left:Ljava/lang/Object;
checkcast java.util.List
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 14
goto 79
StackMap locals: org.apache.cassandra.io.sstable.IndexSummaryRedistribution java.util.List java.util.Map double long java.util.List java.util.List java.util.List java.util.List java.util.List org.apache.cassandra.utils.Pair top java.util.Iterator
StackMap stack:
77: aload 14
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 13
start local 13 78: aload 2
aload 13
getfield org.apache.cassandra.io.sstable.format.SSTableReader.metadata:Lorg/apache/cassandra/config/CFMetaData;
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.lifecycle.LifecycleTransaction
aload 13
invokevirtual org.apache.cassandra.db.lifecycle.LifecycleTransaction.cancel:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
end local 13 79: StackMap locals:
StackMap stack:
aload 14
invokeinterface java.util.Iterator.hasNext:()Z
ifne 77
end local 12 80: StackMap locals: org.apache.cassandra.io.sstable.IndexSummaryRedistribution java.util.List java.util.Map double long java.util.List java.util.List java.util.List java.util.List java.util.List
StackMap stack:
aload 7
aload 9
invokeinterface java.util.List.addAll:(Ljava/util/Collection;)Z
pop
81: aload 7
aload 8
invokeinterface java.util.List.addAll:(Ljava/util/Collection;)Z
pop
82: aload 7
aload 10
invokeinterface java.util.List.addAll:(Ljava/util/Collection;)Z
pop
83: aload 7
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 13
goto 96
StackMap locals: org.apache.cassandra.io.sstable.IndexSummaryRedistribution java.util.List java.util.Map double long java.util.List java.util.List java.util.List java.util.List java.util.List top java.util.Iterator
StackMap stack:
84: aload 13
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry
astore 12
start local 12 85: aload 0
invokevirtual org.apache.cassandra.io.sstable.IndexSummaryRedistribution.isStopRequested:()Z
ifeq 87
86: new org.apache.cassandra.db.compaction.CompactionInterruptedException
dup
aload 0
invokevirtual org.apache.cassandra.io.sstable.IndexSummaryRedistribution.getCompactionInfo:()Lorg/apache/cassandra/db/compaction/CompactionInfo;
invokespecial org.apache.cassandra.db.compaction.CompactionInterruptedException.<init>:(Lorg/apache/cassandra/db/compaction/CompactionInfo;)V
athrow
87: StackMap locals: org.apache.cassandra.io.sstable.IndexSummaryRedistribution java.util.List java.util.Map double long java.util.List java.util.List java.util.List java.util.List java.util.List org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry java.util.Iterator
StackMap stack:
aload 12
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
astore 14
start local 14 88: getstatic org.apache.cassandra.io.sstable.IndexSummaryRedistribution.logger:Lorg/slf4j/Logger;
ldc "Re-sampling index summary for {} from {}/{} to {}/{} of the original number of entries"
iconst_5
anewarray java.lang.Object
dup
iconst_0
89: aload 14
aastore
dup
iconst_1
aload 14
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getIndexSummarySamplingLevel:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_2
sipush 128
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_3
90: aload 12
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry.newSamplingLevel:I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_4
sipush 128
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
91: invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;[Ljava/lang/Object;)V
92: aload 14
getfield org.apache.cassandra.io.sstable.format.SSTableReader.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.ksName:Ljava/lang/String;
invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
aload 14
getfield org.apache.cassandra.io.sstable.format.SSTableReader.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
invokevirtual org.apache.cassandra.db.Keyspace.getColumnFamilyStore:(Ljava/util/UUID;)Lorg/apache/cassandra/db/ColumnFamilyStore;
astore 15
start local 15 93: aload 14
aload 15
aload 12
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry.newSamplingLevel:I
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.cloneWithNewSummarySamplingLevel:(Lorg/apache/cassandra/db/ColumnFamilyStore;I)Lorg/apache/cassandra/io/sstable/format/SSTableReader;
astore 16
start local 16 94: aload 11
aload 16
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
95: aload 2
aload 14
getfield org.apache.cassandra.io.sstable.format.SSTableReader.metadata:Lorg/apache/cassandra/config/CFMetaData;
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.lifecycle.LifecycleTransaction
aload 16
iconst_1
invokevirtual org.apache.cassandra.db.lifecycle.LifecycleTransaction.update:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;Z)V
end local 16 end local 15 end local 14 end local 12 96: StackMap locals: org.apache.cassandra.io.sstable.IndexSummaryRedistribution java.util.List java.util.Map double long java.util.List java.util.List java.util.List java.util.List java.util.List top java.util.Iterator
StackMap stack:
aload 13
invokeinterface java.util.Iterator.hasNext:()Z
ifne 84
97: aload 11
areturn
end local 11 end local 10 end local 9 end local 8 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 98 0 this Lorg/apache/cassandra/io/sstable/IndexSummaryRedistribution;
0 98 1 sstables Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
0 98 2 transactions Ljava/util/Map<Ljava/util/UUID;Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;>;
0 98 3 totalReadsPerSec D
0 98 5 memoryPoolCapacity J
1 98 7 toDownsample Ljava/util/List<Lorg/apache/cassandra/io/sstable/IndexSummaryRedistribution$ResampleEntry;>;
2 98 8 toUpsample Ljava/util/List<Lorg/apache/cassandra/io/sstable/IndexSummaryRedistribution$ResampleEntry;>;
3 98 9 forceResample Ljava/util/List<Lorg/apache/cassandra/io/sstable/IndexSummaryRedistribution$ResampleEntry;>;
4 98 10 forceUpsample Ljava/util/List<Lorg/apache/cassandra/io/sstable/IndexSummaryRedistribution$ResampleEntry;>;
5 98 11 newSSTables Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
8 71 12 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
11 71 14 minIndexInterval I
12 71 15 maxIndexInterval I
15 71 16 readsPerSec D
16 71 18 idealSpace J
17 71 20 currentNumEntries I
18 71 21 avgEntrySize D
19 71 23 targetNumEntries J
20 71 25 currentSamplingLevel I
21 71 26 maxSummarySize I
23 28 27 effectiveSamplingLevel I
31 71 27 newSamplingLevel I
32 71 28 numEntriesAtNewSamplingLevel I
33 71 29 effectiveIndexInterval D
43 45 31 spaceUsed J
53 55 31 spaceUsed J
58 60 31 spaceUsed J
63 65 31 spaceUsed J
74 80 12 result Lorg/apache/cassandra/utils/Pair<Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;Ljava/util/List<Lorg/apache/cassandra/io/sstable/IndexSummaryRedistribution$ResampleEntry;>;>;
78 79 13 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
85 96 12 entry Lorg/apache/cassandra/io/sstable/IndexSummaryRedistribution$ResampleEntry;
88 96 14 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
93 96 15 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
94 96 16 replacement Lorg/apache/cassandra/io/sstable/format/SSTableReader;
Exceptions:
throws java.io.IOException
Signature: (Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;Ljava/util/Map<Ljava/util/UUID;Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;>;DJ)Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
MethodParameters:
Name Flags
sstables
transactions
totalReadsPerSec
memoryPoolCapacity
static org.apache.cassandra.utils.Pair<java.util.List<org.apache.cassandra.io.sstable.format.SSTableReader>, java.util.List<org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry>> distributeRemainingSpace(java.util.List<org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry>, long);
descriptor: (Ljava/util/List;J)Lorg/apache/cassandra/utils/Pair;
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=8, args_size=2
start local 0 start local 1 0: aload 0
new org.apache.cassandra.io.sstable.IndexSummaryRedistribution$1
dup
invokespecial org.apache.cassandra.io.sstable.IndexSummaryRedistribution$1.<init>:()V
invokestatic java.util.Collections.sort:(Ljava/util/List;Ljava/util/Comparator;)V
1: iconst_0
istore 3
start local 3 2: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 4
start local 4 3: goto 13
4: StackMap locals: int java.util.List
StackMap stack:
aload 0
iload 3
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry
astore 5
start local 5 5: aload 5
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getIndexSummaryOffHeapSize:()J
aload 5
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry.newSpaceUsed:J
lsub
lstore 6
start local 6 6: lload 6
lload 1
lcmp
ifgt 14
7: getstatic org.apache.cassandra.io.sstable.IndexSummaryRedistribution.logger:Lorg/slf4j/Logger;
ldc "Using leftover space to keep {} at the current sampling level ({})"
8: aload 5
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
aload 5
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getIndexSummarySamplingLevel:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
9: invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
10: aload 4
aload 5
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
11: lload 1
lload 6
lsub
lstore 1
12: iinc 3 1
end local 6 end local 5 13: StackMap locals:
StackMap stack:
lload 1
lconst_0
lcmp
ifle 14
iload 3
aload 0
invokeinterface java.util.List.size:()I
if_icmplt 4
14: StackMap locals:
StackMap stack:
aload 4
aload 0
iload 3
aload 0
invokeinterface java.util.List.size:()I
invokeinterface java.util.List.subList:(II)Ljava/util/List;
invokestatic org.apache.cassandra.utils.Pair.create:(Ljava/lang/Object;Ljava/lang/Object;)Lorg/apache/cassandra/utils/Pair;
areturn
end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 toDownsample Ljava/util/List<Lorg/apache/cassandra/io/sstable/IndexSummaryRedistribution$ResampleEntry;>;
0 15 1 remainingSpace J
2 15 3 noDownsampleCutoff I
3 15 4 willNotDownsample Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
5 13 5 entry Lorg/apache/cassandra/io/sstable/IndexSummaryRedistribution$ResampleEntry;
6 13 6 extraSpaceRequired J
Signature: (Ljava/util/List<Lorg/apache/cassandra/io/sstable/IndexSummaryRedistribution$ResampleEntry;>;J)Lorg/apache/cassandra/utils/Pair<Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;Ljava/util/List<Lorg/apache/cassandra/io/sstable/IndexSummaryRedistribution$ResampleEntry;>;>;
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
RuntimeInvisibleTypeAnnotations:
METHOD_RETURN
com.google.common.annotations.VisibleForTesting()
MethodParameters:
Name Flags
toDownsample
remainingSpace
public org.apache.cassandra.db.compaction.CompactionInfo getCompactionInfo();
descriptor: ()Lorg/apache/cassandra/db/compaction/CompactionInfo;
flags: (0x0001) ACC_PUBLIC
Code:
stack=9, locals=1, args_size=1
start local 0 0: new org.apache.cassandra.db.compaction.CompactionInfo
dup
getstatic org.apache.cassandra.db.compaction.OperationType.INDEX_SUMMARY:Lorg/apache/cassandra/db/compaction/OperationType;
aload 0
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.memoryPoolBytes:J
aload 0
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.remainingSpace:J
lsub
aload 0
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.memoryPoolBytes:J
getstatic org.apache.cassandra.db.compaction.CompactionInfo$Unit.BYTES:Lorg/apache/cassandra/db/compaction/CompactionInfo$Unit;
aload 0
getfield org.apache.cassandra.io.sstable.IndexSummaryRedistribution.compactionId:Ljava/util/UUID;
invokespecial org.apache.cassandra.db.compaction.CompactionInfo.<init>:(Lorg/apache/cassandra/db/compaction/OperationType;JJLorg/apache/cassandra/db/compaction/CompactionInfo$Unit;Ljava/util/UUID;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/io/sstable/IndexSummaryRedistribution;
}
SourceFile: "IndexSummaryRedistribution.java"
NestMembers:
org.apache.cassandra.io.sstable.IndexSummaryRedistribution$1 org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ReadRateComparator org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry
InnerClasses:
public abstract Holder = org.apache.cassandra.db.compaction.CompactionInfo$Holder of org.apache.cassandra.db.compaction.CompactionInfo
public final Unit = org.apache.cassandra.db.compaction.CompactionInfo$Unit of org.apache.cassandra.db.compaction.CompactionInfo
org.apache.cassandra.io.sstable.IndexSummaryRedistribution$1
private ReadRateComparator = org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ReadRateComparator of org.apache.cassandra.io.sstable.IndexSummaryRedistribution
private ResampleEntry = org.apache.cassandra.io.sstable.IndexSummaryRedistribution$ResampleEntry of org.apache.cassandra.io.sstable.IndexSummaryRedistribution