public class org.apache.cassandra.db.compaction.CompactionLogger
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.db.compaction.CompactionLogger
super_class: java.lang.Object
{
private static final org.codehaus.jackson.node.JsonNodeFactory json;
descriptor: Lorg/codehaus/jackson/node/JsonNodeFactory;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final org.slf4j.Logger logger;
descriptor: Lorg/slf4j/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final org.apache.cassandra.db.compaction.CompactionLogger$Writer serializer;
descriptor: Lorg/apache/cassandra/db/compaction/CompactionLogger$Writer;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final java.lang.ref.WeakReference<org.apache.cassandra.db.ColumnFamilyStore> cfsRef;
descriptor: Ljava/lang/ref/WeakReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/lang/ref/WeakReference<Lorg/apache/cassandra/db/ColumnFamilyStore;>;
private final java.lang.ref.WeakReference<org.apache.cassandra.db.compaction.CompactionStrategyManager> csmRef;
descriptor: Ljava/lang/ref/WeakReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/lang/ref/WeakReference<Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;>;
private final java.util.concurrent.atomic.AtomicInteger identifier;
descriptor: Ljava/util/concurrent/atomic/AtomicInteger;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.Map<org.apache.cassandra.db.compaction.AbstractCompactionStrategy, java.lang.String> compactionStrategyMapping;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;Ljava/lang/String;>;
private final java.util.concurrent.atomic.AtomicBoolean enabled;
descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: getstatic org.codehaus.jackson.node.JsonNodeFactory.instance:Lorg/codehaus/jackson/node/JsonNodeFactory;
putstatic org.apache.cassandra.db.compaction.CompactionLogger.json:Lorg/codehaus/jackson/node/JsonNodeFactory;
1: ldc Lorg/apache/cassandra/db/compaction/CompactionLogger;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic org.apache.cassandra.db.compaction.CompactionLogger.logger:Lorg/slf4j/Logger;
2: new org.apache.cassandra.db.compaction.CompactionLogger$CompactionLogSerializer
dup
invokespecial org.apache.cassandra.db.compaction.CompactionLogger$CompactionLogSerializer.<init>:()V
putstatic org.apache.cassandra.db.compaction.CompactionLogger.serializer:Lorg/apache/cassandra/db/compaction/CompactionLogger$Writer;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(org.apache.cassandra.db.ColumnFamilyStore, org.apache.cassandra.db.compaction.CompactionStrategyManager);
descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.concurrent.atomic.AtomicInteger
dup
iconst_0
invokespecial java.util.concurrent.atomic.AtomicInteger.<init>:(I)V
putfield org.apache.cassandra.db.compaction.CompactionLogger.identifier:Ljava/util/concurrent/atomic/AtomicInteger;
2: aload 0
new com.google.common.collect.MapMaker
dup
invokespecial com.google.common.collect.MapMaker.<init>:()V
invokevirtual com.google.common.collect.MapMaker.weakKeys:()Lcom/google/common/collect/MapMaker;
invokevirtual com.google.common.collect.MapMaker.makeMap:()Ljava/util/concurrent/ConcurrentMap;
putfield org.apache.cassandra.db.compaction.CompactionLogger.compactionStrategyMapping:Ljava/util/Map;
3: aload 0
new java.util.concurrent.atomic.AtomicBoolean
dup
iconst_0
invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
putfield org.apache.cassandra.db.compaction.CompactionLogger.enabled:Ljava/util/concurrent/atomic/AtomicBoolean;
4: aload 0
new java.lang.ref.WeakReference
dup
aload 2
invokespecial java.lang.ref.WeakReference.<init>:(Ljava/lang/Object;)V
putfield org.apache.cassandra.db.compaction.CompactionLogger.csmRef:Ljava/lang/ref/WeakReference;
5: aload 0
new java.lang.ref.WeakReference
dup
aload 1
invokespecial java.lang.ref.WeakReference.<init>:(Ljava/lang/Object;)V
putfield org.apache.cassandra.db.compaction.CompactionLogger.cfsRef:Ljava/lang/ref/WeakReference;
6: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/db/compaction/CompactionLogger;
0 7 1 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
0 7 2 csm Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
MethodParameters:
Name Flags
cfs
csm
private void forEach(java.util.function.Consumer<org.apache.cassandra.db.compaction.AbstractCompactionStrategy>);
descriptor: (Ljava/util/function/Consumer;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionLogger.csmRef:Ljava/lang/ref/WeakReference;
invokevirtual java.lang.ref.WeakReference.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.CompactionStrategyManager
astore 2
start local 2 1: aload 2
ifnonnull 3
2: return
3: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager
StackMap stack:
aload 2
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.getStrategies:()Ljava/util/List;
4: aload 1
invokedynamic accept(Ljava/util/function/Consumer;)Ljava/util/function/Consumer;
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;)V
org/apache/cassandra/db/compaction/CompactionLogger.lambda$0(Ljava/util/function/Consumer;Ljava/util/List;)V (6)
(Ljava/util/List;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
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/CompactionLogger;
0 6 1 consumer Ljava/util/function/Consumer<Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;>;
1 6 2 csm Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
Signature: (Ljava/util/function/Consumer<Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;>;)V
MethodParameters:
Name Flags
consumer
private org.codehaus.jackson.node.ArrayNode compactionStrategyMap(java.util.function.Function<org.apache.cassandra.db.compaction.AbstractCompactionStrategy, org.codehaus.jackson.JsonNode>);
descriptor: (Ljava/util/function/Function;)Lorg/codehaus/jackson/node/ArrayNode;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.db.compaction.CompactionLogger.json:Lorg/codehaus/jackson/node/JsonNodeFactory;
invokevirtual org.codehaus.jackson.node.JsonNodeFactory.arrayNode:()Lorg/codehaus/jackson/node/ArrayNode;
astore 2
start local 2 1: aload 0
aload 2
aload 1
invokedynamic accept(Lorg/codehaus/jackson/node/ArrayNode;Ljava/util/function/Function;)Ljava/util/function/Consumer;
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;)V
org/apache/cassandra/db/compaction/CompactionLogger.lambda$1(Lorg/codehaus/jackson/node/ArrayNode;Ljava/util/function/Function;Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)V (6)
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)V
invokevirtual org.apache.cassandra.db.compaction.CompactionLogger.forEach:(Ljava/util/function/Consumer;)V
2: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/db/compaction/CompactionLogger;
0 3 1 select Ljava/util/function/Function<Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;Lorg/codehaus/jackson/JsonNode;>;
1 3 2 node Lorg/codehaus/jackson/node/ArrayNode;
Signature: (Ljava/util/function/Function<Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;Lorg/codehaus/jackson/JsonNode;>;)Lorg/codehaus/jackson/node/ArrayNode;
MethodParameters:
Name Flags
select
private org.codehaus.jackson.node.ArrayNode sstableMap(java.util.Collection<org.apache.cassandra.io.sstable.format.SSTableReader>, org.apache.cassandra.db.compaction.CompactionLogger$CompactionStrategyAndTableFunction);
descriptor: (Ljava/util/Collection;Lorg/apache/cassandra/db/compaction/CompactionLogger$CompactionStrategyAndTableFunction;)Lorg/codehaus/jackson/node/ArrayNode;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionLogger.csmRef:Ljava/lang/ref/WeakReference;
invokevirtual java.lang.ref.WeakReference.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.CompactionStrategyManager
astore 3
start local 3 1: getstatic org.apache.cassandra.db.compaction.CompactionLogger.json:Lorg/codehaus/jackson/node/JsonNodeFactory;
invokevirtual org.codehaus.jackson.node.JsonNodeFactory.arrayNode:()Lorg/codehaus/jackson/node/ArrayNode;
astore 4
start local 4 2: aload 3
ifnonnull 4
3: aload 4
areturn
4: StackMap locals: org.apache.cassandra.db.compaction.CompactionStrategyManager org.codehaus.jackson.node.ArrayNode
StackMap stack:
aload 1
aload 4
aload 2
aload 3
invokedynamic accept(Lorg/codehaus/jackson/node/ArrayNode;Lorg/apache/cassandra/db/compaction/CompactionLogger$CompactionStrategyAndTableFunction;Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;)Ljava/util/function/Consumer;
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;)V
org/apache/cassandra/db/compaction/CompactionLogger.lambda$2(Lorg/codehaus/jackson/node/ArrayNode;Lorg/apache/cassandra/db/compaction/CompactionLogger$CompactionStrategyAndTableFunction;Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V (6)
(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
invokeinterface java.util.Collection.forEach:(Ljava/util/function/Consumer;)V
5: aload 4
areturn
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/db/compaction/CompactionLogger;
0 6 1 sstables Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
0 6 2 csatf Lorg/apache/cassandra/db/compaction/CompactionLogger$CompactionStrategyAndTableFunction;
1 6 3 csm Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
2 6 4 node Lorg/codehaus/jackson/node/ArrayNode;
Signature: (Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;Lorg/apache/cassandra/db/compaction/CompactionLogger$CompactionStrategyAndTableFunction;)Lorg/codehaus/jackson/node/ArrayNode;
MethodParameters:
Name Flags
sstables
csatf
private java.lang.String getId(org.apache.cassandra.db.compaction.AbstractCompactionStrategy);
descriptor: (Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionLogger.compactionStrategyMapping:Ljava/util/Map;
aload 1
aload 0
invokedynamic apply(Lorg/apache/cassandra/db/compaction/CompactionLogger;)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/CompactionLogger.lambda$3(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Ljava/lang/String; (7)
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Ljava/lang/String;
invokeinterface java.util.Map.computeIfAbsent:(Ljava/lang/Object;Ljava/util/function/Function;)Ljava/lang/Object;
checkcast java.lang.String
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/compaction/CompactionLogger;
0 1 1 strategy Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
MethodParameters:
Name Flags
strategy
private org.codehaus.jackson.JsonNode formatSSTables(org.apache.cassandra.db.compaction.AbstractCompactionStrategy);
descriptor: (Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Lorg/codehaus/jackson/JsonNode;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=7, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.db.compaction.CompactionLogger.json:Lorg/codehaus/jackson/node/JsonNodeFactory;
invokevirtual org.codehaus.jackson.node.JsonNodeFactory.arrayNode:()Lorg/codehaus/jackson/node/ArrayNode;
astore 2
start local 2 1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionLogger.csmRef:Ljava/lang/ref/WeakReference;
invokevirtual java.lang.ref.WeakReference.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.CompactionStrategyManager
astore 3
start local 3 2: aload 0
getfield org.apache.cassandra.db.compaction.CompactionLogger.cfsRef:Ljava/lang/ref/WeakReference;
invokevirtual java.lang.ref.WeakReference.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
astore 4
start local 4 3: aload 3
ifnull 4
aload 4
ifnonnull 5
4: StackMap locals: org.codehaus.jackson.node.ArrayNode org.apache.cassandra.db.compaction.CompactionStrategyManager org.apache.cassandra.db.ColumnFamilyStore
StackMap stack:
aload 2
areturn
5: StackMap locals:
StackMap stack:
aload 4
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getLiveSSTables:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 6
goto 9
StackMap locals: org.apache.cassandra.db.compaction.CompactionLogger org.apache.cassandra.db.compaction.AbstractCompactionStrategy org.codehaus.jackson.node.ArrayNode org.apache.cassandra.db.compaction.CompactionStrategyManager org.apache.cassandra.db.ColumnFamilyStore 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: aload 3
aload 5
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.getCompactionStrategyFor:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
aload 1
if_acmpne 9
8: aload 2
aload 0
aload 1
aload 5
invokevirtual org.apache.cassandra.db.compaction.CompactionLogger.formatSSTable:(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/codehaus/jackson/JsonNode;
invokevirtual org.codehaus.jackson.node.ArrayNode.add:(Lorg/codehaus/jackson/JsonNode;)V
end local 5 9: StackMap locals:
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 6
10: aload 2
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/apache/cassandra/db/compaction/CompactionLogger;
0 11 1 strategy Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
1 11 2 node Lorg/codehaus/jackson/node/ArrayNode;
2 11 3 csm Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
3 11 4 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
7 9 5 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
MethodParameters:
Name Flags
strategy
private org.codehaus.jackson.JsonNode formatSSTable(org.apache.cassandra.db.compaction.AbstractCompactionStrategy, org.apache.cassandra.io.sstable.format.SSTableReader);
descriptor: (Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/codehaus/jackson/JsonNode;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=5, args_size=3
start local 0 start local 1 start local 2 0: getstatic org.apache.cassandra.db.compaction.CompactionLogger.json:Lorg/codehaus/jackson/node/JsonNodeFactory;
invokevirtual org.codehaus.jackson.node.JsonNodeFactory.objectNode:()Lorg/codehaus/jackson/node/ObjectNode;
astore 3
start local 3 1: aload 3
ldc "generation"
aload 2
getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
getfield org.apache.cassandra.io.sstable.Descriptor.generation:I
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;I)V
2: aload 3
ldc "version"
aload 2
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.getVersion:()Ljava/lang/String;
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Ljava/lang/String;)V
3: aload 3
ldc "size"
aload 2
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.onDiskLength:()J
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;J)V
4: aload 1
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.strategyLogger:()Lorg/apache/cassandra/db/compaction/CompactionLogger$Strategy;
aload 2
invokeinterface org.apache.cassandra.db.compaction.CompactionLogger$Strategy.sstable:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/codehaus/jackson/JsonNode;
astore 4
start local 4 5: aload 4
ifnull 7
6: aload 3
ldc "details"
aload 4
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Lorg/codehaus/jackson/JsonNode;)Lorg/codehaus/jackson/JsonNode;
pop
7: StackMap locals: org.codehaus.jackson.node.ObjectNode org.codehaus.jackson.JsonNode
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 8 0 this Lorg/apache/cassandra/db/compaction/CompactionLogger;
0 8 1 strategy Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
0 8 2 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
1 8 3 node Lorg/codehaus/jackson/node/ObjectNode;
5 8 4 logResult Lorg/codehaus/jackson/JsonNode;
MethodParameters:
Name Flags
strategy
sstable
private org.codehaus.jackson.JsonNode startStrategy(org.apache.cassandra.db.compaction.AbstractCompactionStrategy);
descriptor: (Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Lorg/codehaus/jackson/JsonNode;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=8, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.db.compaction.CompactionLogger.json:Lorg/codehaus/jackson/node/JsonNodeFactory;
invokevirtual org.codehaus.jackson.node.JsonNodeFactory.objectNode:()Lorg/codehaus/jackson/node/ObjectNode;
astore 2
start local 2 1: aload 0
getfield org.apache.cassandra.db.compaction.CompactionLogger.csmRef:Ljava/lang/ref/WeakReference;
invokevirtual java.lang.ref.WeakReference.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.compaction.CompactionStrategyManager
astore 3
start local 3 2: aload 3
ifnonnull 4
3: aload 2
areturn
4: StackMap locals: org.codehaus.jackson.node.ObjectNode org.apache.cassandra.db.compaction.CompactionStrategyManager
StackMap stack:
aload 2
ldc "strategyId"
aload 0
aload 1
invokevirtual org.apache.cassandra.db.compaction.CompactionLogger.getId:(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Ljava/lang/String;
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Ljava/lang/String;)V
5: aload 2
ldc "type"
aload 1
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.getName:()Ljava/lang/String;
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Ljava/lang/String;)V
6: aload 2
ldc "tables"
aload 0
aload 1
invokevirtual org.apache.cassandra.db.compaction.CompactionLogger.formatSSTables:(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Lorg/codehaus/jackson/JsonNode;
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Lorg/codehaus/jackson/JsonNode;)Lorg/codehaus/jackson/JsonNode;
pop
7: aload 2
ldc "repaired"
aload 3
aload 1
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.isRepaired:(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Z
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Z)V
8: aload 3
aload 1
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.getStrategyFolders:(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Ljava/util/List;
astore 4
start local 4 9: getstatic org.apache.cassandra.db.compaction.CompactionLogger.json:Lorg/codehaus/jackson/node/JsonNodeFactory;
invokevirtual org.codehaus.jackson.node.JsonNodeFactory.arrayNode:()Lorg/codehaus/jackson/node/ArrayNode;
astore 5
start local 5 10: aload 4
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 7
goto 13
StackMap locals: org.apache.cassandra.db.compaction.CompactionLogger org.apache.cassandra.db.compaction.AbstractCompactionStrategy org.codehaus.jackson.node.ObjectNode org.apache.cassandra.db.compaction.CompactionStrategyManager java.util.List org.codehaus.jackson.node.ArrayNode top java.util.Iterator
StackMap stack:
11: aload 7
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.String
astore 6
start local 6 12: aload 5
aload 6
invokevirtual org.codehaus.jackson.node.ArrayNode.add:(Ljava/lang/String;)V
end local 6 13: StackMap locals:
StackMap stack:
aload 7
invokeinterface java.util.Iterator.hasNext:()Z
ifne 11
14: aload 2
ldc "folders"
aload 5
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Lorg/codehaus/jackson/JsonNode;)Lorg/codehaus/jackson/JsonNode;
pop
15: aload 1
invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionStrategy.strategyLogger:()Lorg/apache/cassandra/db/compaction/CompactionLogger$Strategy;
invokeinterface org.apache.cassandra.db.compaction.CompactionLogger$Strategy.options:()Lorg/codehaus/jackson/JsonNode;
astore 6
start local 6 16: aload 6
ifnull 18
17: aload 2
ldc "options"
aload 6
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Lorg/codehaus/jackson/JsonNode;)Lorg/codehaus/jackson/JsonNode;
pop
18: StackMap locals: org.apache.cassandra.db.compaction.CompactionLogger org.apache.cassandra.db.compaction.AbstractCompactionStrategy org.codehaus.jackson.node.ObjectNode org.apache.cassandra.db.compaction.CompactionStrategyManager java.util.List org.codehaus.jackson.node.ArrayNode org.codehaus.jackson.JsonNode
StackMap stack:
aload 2
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 19 0 this Lorg/apache/cassandra/db/compaction/CompactionLogger;
0 19 1 strategy Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
1 19 2 node Lorg/codehaus/jackson/node/ObjectNode;
2 19 3 csm Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
9 19 4 folders Ljava/util/List<Ljava/lang/String;>;
10 19 5 folderNode Lorg/codehaus/jackson/node/ArrayNode;
12 13 6 folder Ljava/lang/String;
16 19 6 logResult Lorg/codehaus/jackson/JsonNode;
MethodParameters:
Name Flags
strategy
private org.codehaus.jackson.JsonNode shutdownStrategy(org.apache.cassandra.db.compaction.AbstractCompactionStrategy);
descriptor: (Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Lorg/codehaus/jackson/JsonNode;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.db.compaction.CompactionLogger.json:Lorg/codehaus/jackson/node/JsonNodeFactory;
invokevirtual org.codehaus.jackson.node.JsonNodeFactory.objectNode:()Lorg/codehaus/jackson/node/ObjectNode;
astore 2
start local 2 1: aload 2
ldc "strategyId"
aload 0
aload 1
invokevirtual org.apache.cassandra.db.compaction.CompactionLogger.getId:(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Ljava/lang/String;
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Ljava/lang/String;)V
2: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/db/compaction/CompactionLogger;
0 3 1 strategy Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
1 3 2 node Lorg/codehaus/jackson/node/ObjectNode;
MethodParameters:
Name Flags
strategy
private org.codehaus.jackson.JsonNode describeSSTable(org.apache.cassandra.db.compaction.AbstractCompactionStrategy, org.apache.cassandra.io.sstable.format.SSTableReader);
descriptor: (Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/codehaus/jackson/JsonNode;
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: getstatic org.apache.cassandra.db.compaction.CompactionLogger.json:Lorg/codehaus/jackson/node/JsonNodeFactory;
invokevirtual org.codehaus.jackson.node.JsonNodeFactory.objectNode:()Lorg/codehaus/jackson/node/ObjectNode;
astore 3
start local 3 1: aload 3
ldc "strategyId"
aload 0
aload 1
invokevirtual org.apache.cassandra.db.compaction.CompactionLogger.getId:(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Ljava/lang/String;
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Ljava/lang/String;)V
2: aload 3
ldc "table"
aload 0
aload 1
aload 2
invokevirtual org.apache.cassandra.db.compaction.CompactionLogger.formatSSTable:(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/codehaus/jackson/JsonNode;
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Lorg/codehaus/jackson/JsonNode;)Lorg/codehaus/jackson/JsonNode;
pop
3: aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/db/compaction/CompactionLogger;
0 4 1 strategy Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
0 4 2 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
1 4 3 node Lorg/codehaus/jackson/node/ObjectNode;
MethodParameters:
Name Flags
strategy
sstable
private void describeStrategy(org.codehaus.jackson.node.ObjectNode);
descriptor: (Lorg/codehaus/jackson/node/ObjectNode;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionLogger.cfsRef:Ljava/lang/ref/WeakReference;
invokevirtual java.lang.ref.WeakReference.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.ColumnFamilyStore
astore 2
start local 2 1: aload 2
ifnonnull 3
2: return
3: StackMap locals: org.apache.cassandra.db.ColumnFamilyStore
StackMap stack:
aload 1
ldc "keyspace"
aload 2
getfield org.apache.cassandra.db.ColumnFamilyStore.keyspace:Lorg/apache/cassandra/db/Keyspace;
invokevirtual org.apache.cassandra.db.Keyspace.getName:()Ljava/lang/String;
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Ljava/lang/String;)V
4: aload 1
ldc "table"
aload 2
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getTableName:()Ljava/lang/String;
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Ljava/lang/String;)V
5: aload 1
ldc "time"
invokestatic java.lang.System.currentTimeMillis:()J
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;J)V
6: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/db/compaction/CompactionLogger;
0 7 1 node Lorg/codehaus/jackson/node/ObjectNode;
1 7 2 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
MethodParameters:
Name Flags
node
private org.codehaus.jackson.JsonNode startStrategies();
descriptor: ()Lorg/codehaus/jackson/JsonNode;
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=2, args_size=1
start local 0 0: getstatic org.apache.cassandra.db.compaction.CompactionLogger.json:Lorg/codehaus/jackson/node/JsonNodeFactory;
invokevirtual org.codehaus.jackson.node.JsonNodeFactory.objectNode:()Lorg/codehaus/jackson/node/ObjectNode;
astore 1
start local 1 1: aload 1
ldc "type"
ldc "enable"
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Ljava/lang/String;)V
2: aload 0
aload 1
invokevirtual org.apache.cassandra.db.compaction.CompactionLogger.describeStrategy:(Lorg/codehaus/jackson/node/ObjectNode;)V
3: aload 1
ldc "strategies"
aload 0
aload 0
invokedynamic apply(Lorg/apache/cassandra/db/compaction/CompactionLogger;)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/CompactionLogger.startStrategy(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Lorg/codehaus/jackson/JsonNode; (7)
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Lorg/codehaus/jackson/JsonNode;
invokevirtual org.apache.cassandra.db.compaction.CompactionLogger.compactionStrategyMap:(Ljava/util/function/Function;)Lorg/codehaus/jackson/node/ArrayNode;
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Lorg/codehaus/jackson/JsonNode;)Lorg/codehaus/jackson/JsonNode;
pop
4: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/db/compaction/CompactionLogger;
1 5 1 node Lorg/codehaus/jackson/node/ObjectNode;
public void enable();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionLogger.enabled:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_0
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
ifeq 2
1: getstatic org.apache.cassandra.db.compaction.CompactionLogger.serializer:Lorg/apache/cassandra/db/compaction/CompactionLogger$Writer;
aload 0
invokevirtual org.apache.cassandra.db.compaction.CompactionLogger.startStrategies:()Lorg/codehaus/jackson/JsonNode;
aload 0
invokeinterface org.apache.cassandra.db.compaction.CompactionLogger$Writer.writeStart:(Lorg/codehaus/jackson/JsonNode;Ljava/lang/Object;)V
2: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/db/compaction/CompactionLogger;
public void disable();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionLogger.enabled:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_1
iconst_0
invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
ifeq 6
1: getstatic org.apache.cassandra.db.compaction.CompactionLogger.json:Lorg/codehaus/jackson/node/JsonNodeFactory;
invokevirtual org.codehaus.jackson.node.JsonNodeFactory.objectNode:()Lorg/codehaus/jackson/node/ObjectNode;
astore 1
start local 1 2: aload 1
ldc "type"
ldc "disable"
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Ljava/lang/String;)V
3: aload 0
aload 1
invokevirtual org.apache.cassandra.db.compaction.CompactionLogger.describeStrategy:(Lorg/codehaus/jackson/node/ObjectNode;)V
4: aload 1
ldc "strategies"
aload 0
aload 0
invokedynamic apply(Lorg/apache/cassandra/db/compaction/CompactionLogger;)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/CompactionLogger.shutdownStrategy(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Lorg/codehaus/jackson/JsonNode; (7)
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Lorg/codehaus/jackson/JsonNode;
invokevirtual org.apache.cassandra.db.compaction.CompactionLogger.compactionStrategyMap:(Ljava/util/function/Function;)Lorg/codehaus/jackson/node/ArrayNode;
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Lorg/codehaus/jackson/JsonNode;)Lorg/codehaus/jackson/JsonNode;
pop
5: getstatic org.apache.cassandra.db.compaction.CompactionLogger.serializer:Lorg/apache/cassandra/db/compaction/CompactionLogger$Writer;
aload 1
aload 0
invokedynamic getSummary(Lorg/apache/cassandra/db/compaction/CompactionLogger;)Lorg/apache/cassandra/db/compaction/CompactionLogger$StrategySummary;
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:
()Lorg/codehaus/jackson/JsonNode;
org/apache/cassandra/db/compaction/CompactionLogger.startStrategies()Lorg/codehaus/jackson/JsonNode; (7)
()Lorg/codehaus/jackson/JsonNode;
aload 0
invokeinterface org.apache.cassandra.db.compaction.CompactionLogger$Writer.write:(Lorg/codehaus/jackson/JsonNode;Lorg/apache/cassandra/db/compaction/CompactionLogger$StrategySummary;Ljava/lang/Object;)V
end local 1 6: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/db/compaction/CompactionLogger;
2 6 1 node Lorg/codehaus/jackson/node/ObjectNode;
public void flush(java.util.Collection<org.apache.cassandra.io.sstable.format.SSTableReader>);
descriptor: (Ljava/util/Collection;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionLogger.enabled:Ljava/util/concurrent/atomic/AtomicBoolean;
invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
ifeq 6
1: getstatic org.apache.cassandra.db.compaction.CompactionLogger.json:Lorg/codehaus/jackson/node/JsonNodeFactory;
invokevirtual org.codehaus.jackson.node.JsonNodeFactory.objectNode:()Lorg/codehaus/jackson/node/ObjectNode;
astore 2
start local 2 2: aload 2
ldc "type"
ldc "flush"
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Ljava/lang/String;)V
3: aload 0
aload 2
invokevirtual org.apache.cassandra.db.compaction.CompactionLogger.describeStrategy:(Lorg/codehaus/jackson/node/ObjectNode;)V
4: aload 2
ldc "tables"
aload 0
aload 1
aload 0
invokedynamic apply(Lorg/apache/cassandra/db/compaction/CompactionLogger;)Lorg/apache/cassandra/db/compaction/CompactionLogger$CompactionStrategyAndTableFunction;
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:
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/codehaus/jackson/JsonNode;
org/apache/cassandra/db/compaction/CompactionLogger.describeSSTable(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/codehaus/jackson/JsonNode; (7)
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/codehaus/jackson/JsonNode;
invokevirtual org.apache.cassandra.db.compaction.CompactionLogger.sstableMap:(Ljava/util/Collection;Lorg/apache/cassandra/db/compaction/CompactionLogger$CompactionStrategyAndTableFunction;)Lorg/codehaus/jackson/node/ArrayNode;
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Lorg/codehaus/jackson/JsonNode;)Lorg/codehaus/jackson/JsonNode;
pop
5: getstatic org.apache.cassandra.db.compaction.CompactionLogger.serializer:Lorg/apache/cassandra/db/compaction/CompactionLogger$Writer;
aload 2
aload 0
invokedynamic getSummary(Lorg/apache/cassandra/db/compaction/CompactionLogger;)Lorg/apache/cassandra/db/compaction/CompactionLogger$StrategySummary;
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:
()Lorg/codehaus/jackson/JsonNode;
org/apache/cassandra/db/compaction/CompactionLogger.startStrategies()Lorg/codehaus/jackson/JsonNode; (7)
()Lorg/codehaus/jackson/JsonNode;
aload 0
invokeinterface org.apache.cassandra.db.compaction.CompactionLogger$Writer.write:(Lorg/codehaus/jackson/JsonNode;Lorg/apache/cassandra/db/compaction/CompactionLogger$StrategySummary;Ljava/lang/Object;)V
end local 2 6: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/db/compaction/CompactionLogger;
0 7 1 sstables Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
2 6 2 node Lorg/codehaus/jackson/node/ObjectNode;
Signature: (Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;)V
MethodParameters:
Name Flags
sstables
public void compaction(long, java.util.Collection<org.apache.cassandra.io.sstable.format.SSTableReader>, long, java.util.Collection<org.apache.cassandra.io.sstable.format.SSTableReader>);
descriptor: (JLjava/util/Collection;JLjava/util/Collection;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=8, args_size=5
start local 0 start local 1 start local 3 start local 4 start local 6 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionLogger.enabled:Ljava/util/concurrent/atomic/AtomicBoolean;
invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
ifeq 9
1: getstatic org.apache.cassandra.db.compaction.CompactionLogger.json:Lorg/codehaus/jackson/node/JsonNodeFactory;
invokevirtual org.codehaus.jackson.node.JsonNodeFactory.objectNode:()Lorg/codehaus/jackson/node/ObjectNode;
astore 7
start local 7 2: aload 7
ldc "type"
ldc "compaction"
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Ljava/lang/String;)V
3: aload 0
aload 7
invokevirtual org.apache.cassandra.db.compaction.CompactionLogger.describeStrategy:(Lorg/codehaus/jackson/node/ObjectNode;)V
4: aload 7
ldc "start"
lload 1
invokestatic java.lang.String.valueOf:(J)Ljava/lang/String;
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Ljava/lang/String;)V
5: aload 7
ldc "end"
lload 4
invokestatic java.lang.String.valueOf:(J)Ljava/lang/String;
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Ljava/lang/String;)V
6: aload 7
ldc "input"
aload 0
aload 3
aload 0
invokedynamic apply(Lorg/apache/cassandra/db/compaction/CompactionLogger;)Lorg/apache/cassandra/db/compaction/CompactionLogger$CompactionStrategyAndTableFunction;
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:
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/codehaus/jackson/JsonNode;
org/apache/cassandra/db/compaction/CompactionLogger.describeSSTable(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/codehaus/jackson/JsonNode; (7)
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/codehaus/jackson/JsonNode;
invokevirtual org.apache.cassandra.db.compaction.CompactionLogger.sstableMap:(Ljava/util/Collection;Lorg/apache/cassandra/db/compaction/CompactionLogger$CompactionStrategyAndTableFunction;)Lorg/codehaus/jackson/node/ArrayNode;
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Lorg/codehaus/jackson/JsonNode;)Lorg/codehaus/jackson/JsonNode;
pop
7: aload 7
ldc "output"
aload 0
aload 6
aload 0
invokedynamic apply(Lorg/apache/cassandra/db/compaction/CompactionLogger;)Lorg/apache/cassandra/db/compaction/CompactionLogger$CompactionStrategyAndTableFunction;
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:
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/codehaus/jackson/JsonNode;
org/apache/cassandra/db/compaction/CompactionLogger.describeSSTable(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/codehaus/jackson/JsonNode; (7)
(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/codehaus/jackson/JsonNode;
invokevirtual org.apache.cassandra.db.compaction.CompactionLogger.sstableMap:(Ljava/util/Collection;Lorg/apache/cassandra/db/compaction/CompactionLogger$CompactionStrategyAndTableFunction;)Lorg/codehaus/jackson/node/ArrayNode;
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Lorg/codehaus/jackson/JsonNode;)Lorg/codehaus/jackson/JsonNode;
pop
8: getstatic org.apache.cassandra.db.compaction.CompactionLogger.serializer:Lorg/apache/cassandra/db/compaction/CompactionLogger$Writer;
aload 7
aload 0
invokedynamic getSummary(Lorg/apache/cassandra/db/compaction/CompactionLogger;)Lorg/apache/cassandra/db/compaction/CompactionLogger$StrategySummary;
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:
()Lorg/codehaus/jackson/JsonNode;
org/apache/cassandra/db/compaction/CompactionLogger.startStrategies()Lorg/codehaus/jackson/JsonNode; (7)
()Lorg/codehaus/jackson/JsonNode;
aload 0
invokeinterface org.apache.cassandra.db.compaction.CompactionLogger$Writer.write:(Lorg/codehaus/jackson/JsonNode;Lorg/apache/cassandra/db/compaction/CompactionLogger$StrategySummary;Ljava/lang/Object;)V
end local 7 9: StackMap locals:
StackMap stack:
return
end local 6 end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/apache/cassandra/db/compaction/CompactionLogger;
0 10 1 startTime J
0 10 3 input Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
0 10 4 endTime J
0 10 6 output Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
2 9 7 node Lorg/codehaus/jackson/node/ObjectNode;
Signature: (JLjava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;JLjava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;)V
MethodParameters:
Name Flags
startTime
input
endTime
output
public void pending(org.apache.cassandra.db.compaction.AbstractCompactionStrategy, int);
descriptor: (Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: iload 2
ifeq 7
aload 0
getfield org.apache.cassandra.db.compaction.CompactionLogger.enabled:Ljava/util/concurrent/atomic/AtomicBoolean;
invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
ifeq 7
1: getstatic org.apache.cassandra.db.compaction.CompactionLogger.json:Lorg/codehaus/jackson/node/JsonNodeFactory;
invokevirtual org.codehaus.jackson.node.JsonNodeFactory.objectNode:()Lorg/codehaus/jackson/node/ObjectNode;
astore 3
start local 3 2: aload 3
ldc "type"
ldc "pending"
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Ljava/lang/String;)V
3: aload 0
aload 3
invokevirtual org.apache.cassandra.db.compaction.CompactionLogger.describeStrategy:(Lorg/codehaus/jackson/node/ObjectNode;)V
4: aload 3
ldc "strategyId"
aload 0
aload 1
invokevirtual org.apache.cassandra.db.compaction.CompactionLogger.getId:(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Ljava/lang/String;
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;Ljava/lang/String;)V
5: aload 3
ldc "pending"
iload 2
invokevirtual org.codehaus.jackson.node.ObjectNode.put:(Ljava/lang/String;I)V
6: getstatic org.apache.cassandra.db.compaction.CompactionLogger.serializer:Lorg/apache/cassandra/db/compaction/CompactionLogger$Writer;
aload 3
aload 0
invokedynamic getSummary(Lorg/apache/cassandra/db/compaction/CompactionLogger;)Lorg/apache/cassandra/db/compaction/CompactionLogger$StrategySummary;
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:
()Lorg/codehaus/jackson/JsonNode;
org/apache/cassandra/db/compaction/CompactionLogger.startStrategies()Lorg/codehaus/jackson/JsonNode; (7)
()Lorg/codehaus/jackson/JsonNode;
aload 0
invokeinterface org.apache.cassandra.db.compaction.CompactionLogger$Writer.write:(Lorg/codehaus/jackson/JsonNode;Lorg/apache/cassandra/db/compaction/CompactionLogger$StrategySummary;Ljava/lang/Object;)V
end local 3 7: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/apache/cassandra/db/compaction/CompactionLogger;
0 8 1 strategy Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
0 8 2 remaining I
2 7 3 node Lorg/codehaus/jackson/node/ObjectNode;
MethodParameters:
Name Flags
strategy
remaining
private static void lambda$0(java.util.function.Consumer, java.util.List);
descriptor: (Ljava/util/function/Consumer;Ljava/util/List;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 1
aload 0
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 l Ljava/util/List<Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;>;
private static void lambda$1(org.codehaus.jackson.node.ArrayNode, java.util.function.Function, org.apache.cassandra.db.compaction.AbstractCompactionStrategy);
descriptor: (Lorg/codehaus/jackson/node/ArrayNode;Ljava/util/function/Function;Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 2 0: aload 0
aload 1
aload 2
invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.codehaus.jackson.JsonNode
invokevirtual org.codehaus.jackson.node.ArrayNode.add:(Lorg/codehaus/jackson/JsonNode;)V
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 1 2 acs Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
private static void lambda$2(org.codehaus.jackson.node.ArrayNode, org.apache.cassandra.db.compaction.CompactionLogger$CompactionStrategyAndTableFunction, org.apache.cassandra.db.compaction.CompactionStrategyManager, org.apache.cassandra.io.sstable.format.SSTableReader);
descriptor: (Lorg/codehaus/jackson/node/ArrayNode;Lorg/apache/cassandra/db/compaction/CompactionLogger$CompactionStrategyAndTableFunction;Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=4
start local 3 0: aload 0
aload 1
aload 2
aload 3
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.getCompactionStrategyFor:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
aload 3
invokeinterface org.apache.cassandra.db.compaction.CompactionLogger$CompactionStrategyAndTableFunction.apply:(Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Lorg/codehaus/jackson/JsonNode;
invokevirtual org.codehaus.jackson.node.ArrayNode.add:(Lorg/codehaus/jackson/JsonNode;)V
return
end local 3 LocalVariableTable:
Start End Slot Name Signature
0 1 3 t Lorg/apache/cassandra/io/sstable/format/SSTableReader;
private java.lang.String lambda$3(org.apache.cassandra.db.compaction.AbstractCompactionStrategy);
descriptor: (Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;)Ljava/lang/String;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.compaction.CompactionLogger.identifier:Ljava/util/concurrent/atomic/AtomicInteger;
invokevirtual java.util.concurrent.atomic.AtomicInteger.getAndIncrement:()I
invokestatic java.lang.String.valueOf:(I)Ljava/lang/String;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/compaction/CompactionLogger;
0 1 1 s Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;
}
SourceFile: "CompactionLogger.java"
NestMembers:
org.apache.cassandra.db.compaction.CompactionLogger$CompactionLogSerializer org.apache.cassandra.db.compaction.CompactionLogger$CompactionStrategyAndTableFunction org.apache.cassandra.db.compaction.CompactionLogger$Strategy org.apache.cassandra.db.compaction.CompactionLogger$Strategy$1 org.apache.cassandra.db.compaction.CompactionLogger$StrategySummary org.apache.cassandra.db.compaction.CompactionLogger$Writer
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
private CompactionLogSerializer = org.apache.cassandra.db.compaction.CompactionLogger$CompactionLogSerializer of org.apache.cassandra.db.compaction.CompactionLogger
private abstract CompactionStrategyAndTableFunction = org.apache.cassandra.db.compaction.CompactionLogger$CompactionStrategyAndTableFunction of org.apache.cassandra.db.compaction.CompactionLogger
public abstract Strategy = org.apache.cassandra.db.compaction.CompactionLogger$Strategy of org.apache.cassandra.db.compaction.CompactionLogger
public abstract StrategySummary = org.apache.cassandra.db.compaction.CompactionLogger$StrategySummary of org.apache.cassandra.db.compaction.CompactionLogger
public abstract Writer = org.apache.cassandra.db.compaction.CompactionLogger$Writer of org.apache.cassandra.db.compaction.CompactionLogger