class org.apache.cassandra.db.compaction.CompactionManager$8 implements org.apache.cassandra.db.compaction.CompactionManager$OneSSTableOperation
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: org.apache.cassandra.db.compaction.CompactionManager$8
super_class: java.lang.Object
{
private final org.apache.cassandra.db.DiskBoundaries val$diskBoundaries;
descriptor: Lorg/apache/cassandra/db/DiskBoundaries;
flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC
final org.apache.cassandra.db.compaction.CompactionManager this$0;
descriptor: Lorg/apache/cassandra/db/compaction/CompactionManager;
flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC
private final org.apache.cassandra.db.ColumnFamilyStore val$cfs;
descriptor: Lorg/apache/cassandra/db/ColumnFamilyStore;
flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC
void <init>(org.apache.cassandra.db.compaction.CompactionManager, org.apache.cassandra.db.DiskBoundaries, org.apache.cassandra.db.ColumnFamilyStore);
descriptor: (Lorg/apache/cassandra/db/compaction/CompactionManager;Lorg/apache/cassandra/db/DiskBoundaries;Lorg/apache/cassandra/db/ColumnFamilyStore;)V
flags: (0x0000)
Code:
stack=2, locals=4, args_size=4
start local 0 0: aload 0
aload 1
putfield org.apache.cassandra.db.compaction.CompactionManager$8.this$0:Lorg/apache/cassandra/db/compaction/CompactionManager;
aload 0
aload 2
putfield org.apache.cassandra.db.compaction.CompactionManager$8.val$diskBoundaries:Lorg/apache/cassandra/db/DiskBoundaries;
aload 0
aload 3
putfield org.apache.cassandra.db.compaction.CompactionManager$8.val$cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
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/compaction/CompactionManager$8;
MethodParameters:
Name Flags
this$0 final
val$diskBoundaries final
val$cfs final
public java.lang.Iterable<org.apache.cassandra.io.sstable.format.SSTableReader> filterSSTables(org.apache.cassandra.db.lifecycle.LifecycleTransaction);
descriptor: (Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;)Ljava/lang/Iterable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=10, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual org.apache.cassandra.db.lifecycle.LifecycleTransaction.originals:()Ljava/util/Set;
invokestatic com.google.common.collect.Sets.newHashSet:(Ljava/lang/Iterable;)Ljava/util/HashSet;
astore 2
start local 2 1: aload 2
invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
aload 0
invokedynamic test(Lorg/apache/cassandra/db/compaction/CompactionManager$8;)Ljava/util/function/Predicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Z
org/apache/cassandra/db/compaction/CompactionManager$8.lambda$0(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Z (7)
(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
invokestatic java.util.stream.Collectors.toSet:()Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.Set
astore 3
start local 3 2: aload 1
aload 2
aload 3
invokestatic com.google.common.collect.Sets.difference:(Ljava/util/Set;Ljava/util/Set;)Lcom/google/common/collect/Sets$SetView;
invokevirtual org.apache.cassandra.db.lifecycle.LifecycleTransaction.cancel:(Ljava/lang/Iterable;)V
3: aload 0
aload 3
invokevirtual org.apache.cassandra.db.compaction.CompactionManager$8.groupByDiskIndex:(Ljava/util/Set;)Ljava/util/Map;
astore 4
start local 4 4: iconst_0
istore 5
start local 5 5: aload 4
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 7
goto 8
StackMap locals: org.apache.cassandra.db.compaction.CompactionManager$8 org.apache.cassandra.db.lifecycle.LifecycleTransaction java.util.Set java.util.Set java.util.Map int top java.util.Iterator
StackMap stack:
6: aload 7
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.List
astore 6
start local 6 7: iload 5
aload 6
invokeinterface java.util.List.size:()I
invokestatic java.lang.Math.max:(II)I
istore 5
end local 6 8: StackMap locals:
StackMap stack:
aload 7
invokeinterface java.util.Iterator.hasNext:()Z
ifne 6
9: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 6
start local 6 10: iconst_0
istore 7
start local 7 11: goto 18
12: StackMap locals: org.apache.cassandra.db.compaction.CompactionManager$8 org.apache.cassandra.db.lifecycle.LifecycleTransaction java.util.Set java.util.Set java.util.Map int java.util.List int
StackMap stack:
aload 4
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 9
goto 16
StackMap locals: org.apache.cassandra.db.compaction.CompactionManager$8 org.apache.cassandra.db.lifecycle.LifecycleTransaction java.util.Set java.util.Set java.util.Map int java.util.List int top java.util.Iterator
StackMap stack:
13: aload 9
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.List
astore 8
start local 8 14: iload 7
aload 8
invokeinterface java.util.List.size:()I
if_icmpge 16
15: aload 6
aload 8
iload 7
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 8 16: StackMap locals:
StackMap stack:
aload 9
invokeinterface java.util.Iterator.hasNext:()Z
ifne 13
17: iinc 7 1
StackMap locals: org.apache.cassandra.db.compaction.CompactionManager$8 org.apache.cassandra.db.lifecycle.LifecycleTransaction java.util.Set java.util.Set java.util.Map int java.util.List int
StackMap stack:
18: iload 7
iload 5
if_icmplt 12
end local 7 19: aload 6
areturn
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 this Lorg/apache/cassandra/db/compaction/CompactionManager$8;
0 20 1 transaction Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;
1 20 2 originals Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
2 20 3 needsRelocation Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
4 20 4 groupedByDisk Ljava/util/Map<Ljava/lang/Integer;Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;>;
5 20 5 maxSize I
7 8 6 diskSSTables Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
10 20 6 mixedSSTables Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
11 19 7 i I
14 16 8 diskSSTables Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
Signature: (Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;)Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
MethodParameters:
Name Flags
transaction
public java.util.Map<java.lang.Integer, java.util.List<org.apache.cassandra.io.sstable.format.SSTableReader>> groupByDiskIndex(java.util.Set<org.apache.cassandra.io.sstable.format.SSTableReader>);
descriptor: (Ljava/util/Set;)Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
aload 0
getfield org.apache.cassandra.db.compaction.CompactionManager$8.val$diskBoundaries:Lorg/apache/cassandra/db/DiskBoundaries;
invokedynamic apply(Lorg/apache/cassandra/db/DiskBoundaries;)Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
org/apache/cassandra/db/compaction/CompactionManager$8.lambda$1(Lorg/apache/cassandra/db/DiskBoundaries;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Ljava/lang/Integer; (6)
(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Ljava/lang/Integer;
invokestatic java.util.stream.Collectors.groupingBy:(Ljava/util/function/Function;)Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.Map
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/compaction/CompactionManager$8;
0 1 1 needsRelocation Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
Signature: (Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;)Ljava/util/Map<Ljava/lang/Integer;Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;>;
MethodParameters:
Name Flags
needsRelocation
private boolean inCorrectLocation(org.apache.cassandra.io.sstable.format.SSTableReader);
descriptor: (Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionManager$8.val$cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getPartitioner:()Lorg/apache/cassandra/dht/IPartitioner;
invokeinterface org.apache.cassandra.dht.IPartitioner.splitter:()Ljava/util/Optional;
invokevirtual java.util.Optional.isPresent:()Z
ifne 2
1: iconst_1
ireturn
2: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.CompactionManager$8.val$diskBoundaries:Lorg/apache/cassandra/db/DiskBoundaries;
aload 1
invokevirtual org.apache.cassandra.db.DiskBoundaries.getDiskIndex:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)I
istore 2
start local 2 3: aload 0
getfield org.apache.cassandra.db.compaction.CompactionManager$8.val$diskBoundaries:Lorg/apache/cassandra/db/DiskBoundaries;
getfield org.apache.cassandra.db.DiskBoundaries.directories:Ljava/util/List;
iload 2
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.Directories$DataDirectory
getfield org.apache.cassandra.db.Directories$DataDirectory.location:Ljava/io/File;
astore 3
start local 3 4: aload 0
getfield org.apache.cassandra.db.compaction.CompactionManager$8.val$diskBoundaries:Lorg/apache/cassandra/db/DiskBoundaries;
getfield org.apache.cassandra.db.DiskBoundaries.positions:Lcom/google/common/collect/ImmutableList;
iload 2
invokevirtual com.google.common.collect.ImmutableList.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.PartitionPosition
astore 4
start local 4 5: aload 1
getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
getfield org.apache.cassandra.io.sstable.Descriptor.directory:Ljava/io/File;
invokevirtual java.io.File.getAbsolutePath:()Ljava/lang/String;
aload 3
invokevirtual java.io.File.getAbsolutePath:()Ljava/lang/String;
invokevirtual java.lang.String.startsWith:(Ljava/lang/String;)Z
ifeq 6
aload 1
getfield org.apache.cassandra.io.sstable.format.SSTableReader.last:Lorg/apache/cassandra/db/DecoratedKey;
aload 4
invokevirtual org.apache.cassandra.db.DecoratedKey.compareTo:(Lorg/apache/cassandra/db/PartitionPosition;)I
ifgt 6
iconst_1
ireturn
StackMap locals: int java.io.File org.apache.cassandra.db.PartitionPosition
StackMap stack:
6: iconst_0
ireturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/db/compaction/CompactionManager$8;
0 7 1 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
3 7 2 diskIndex I
4 7 3 diskLocation Ljava/io/File;
5 7 4 diskLast Lorg/apache/cassandra/db/PartitionPosition;
MethodParameters:
Name Flags
sstable
public void execute(org.apache.cassandra.db.lifecycle.LifecycleTransaction);
descriptor: (Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.db.compaction.CompactionManager.logger:Lorg/slf4j/Logger;
ldc "Relocating {}"
aload 1
invokevirtual org.apache.cassandra.db.lifecycle.LifecycleTransaction.originals:()Ljava/util/Set;
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;)V
1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionManager$8.val$cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getCompactionStrategyManager:()Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
aload 1
ldc -2147483648
ldc 9223372036854775807
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.getCompactionTask:(Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;IJ)Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;
astore 2
start local 2 2: aload 2
iconst_1
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionTask.setUserDefined:(Z)Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;
pop
3: aload 2
getstatic org.apache.cassandra.db.compaction.OperationType.RELOCATE:Lorg/apache/cassandra/db/compaction/OperationType;
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionTask.setCompactionType:(Lorg/apache/cassandra/db/compaction/OperationType;)Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;
pop
4: aload 2
aload 0
getfield org.apache.cassandra.db.compaction.CompactionManager$8.this$0:Lorg/apache/cassandra/db/compaction/CompactionManager;
getfield org.apache.cassandra.db.compaction.CompactionManager.metrics:Lorg/apache/cassandra/metrics/CompactionMetrics;
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionTask.execute:(Lorg/apache/cassandra/db/compaction/CompactionManager$CompactionExecutorStatsCollector;)I
pop
5: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/db/compaction/CompactionManager$8;
0 6 1 txn Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;
2 6 2 task Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;
MethodParameters:
Name Flags
txn
private boolean lambda$0(org.apache.cassandra.io.sstable.format.SSTableReader);
descriptor: (Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Z
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual org.apache.cassandra.db.compaction.CompactionManager$8.inCorrectLocation:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Z
ifeq 1
iconst_0
goto 2
StackMap locals:
StackMap stack:
1: iconst_1
StackMap locals:
StackMap stack: int
2: ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/db/compaction/CompactionManager$8;
0 3 1 s Lorg/apache/cassandra/io/sstable/format/SSTableReader;
private static java.lang.Integer lambda$1(org.apache.cassandra.db.DiskBoundaries, org.apache.cassandra.io.sstable.format.SSTableReader);
descriptor: (Lorg/apache/cassandra/db/DiskBoundaries;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Ljava/lang/Integer;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
aload 1
invokevirtual org.apache.cassandra.db.DiskBoundaries.getDiskIndex:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
areturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 s Lorg/apache/cassandra/io/sstable/format/SSTableReader;
}
SourceFile: "CompactionManager.java"
EnclosingMethod: org.apache.cassandra.db.compaction.CompactionManager.relocateSSTables:(Lorg/apache/cassandra/db/ColumnFamilyStore;I)Lorg/apache/cassandra/db/compaction/CompactionManager$AllSSTableOpStatus;
NestHost: org.apache.cassandra.db.compaction.CompactionManager
InnerClasses:
public abstract SetView = com.google.common.collect.Sets$SetView of com.google.common.collect.Sets
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public DataDirectory = org.apache.cassandra.db.Directories$DataDirectory of org.apache.cassandra.db.Directories
org.apache.cassandra.db.compaction.CompactionManager$8
public final AllSSTableOpStatus = org.apache.cassandra.db.compaction.CompactionManager$AllSSTableOpStatus of org.apache.cassandra.db.compaction.CompactionManager
public abstract CompactionExecutorStatsCollector = org.apache.cassandra.db.compaction.CompactionManager$CompactionExecutorStatsCollector of org.apache.cassandra.db.compaction.CompactionManager
private abstract OneSSTableOperation = org.apache.cassandra.db.compaction.CompactionManager$OneSSTableOperation of org.apache.cassandra.db.compaction.CompactionManager