public class org.apache.cassandra.metrics.CompactionMetrics implements org.apache.cassandra.db.compaction.CompactionManager$CompactionExecutorStatsCollector
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.metrics.CompactionMetrics
super_class: java.lang.Object
{
public static final org.apache.cassandra.metrics.MetricNameFactory factory;
descriptor: Lorg/apache/cassandra/metrics/MetricNameFactory;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
private static final java.util.Set<org.apache.cassandra.db.compaction.CompactionInfo$Holder> compactions;
descriptor: Ljava/util/Set;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Ljava/util/Set<Lorg/apache/cassandra/db/compaction/CompactionInfo$Holder;>;
public final com.codahale.metrics.Gauge<java.lang.Integer> pendingTasks;
descriptor: Lcom/codahale/metrics/Gauge;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Signature: Lcom/codahale/metrics/Gauge<Ljava/lang/Integer;>;
public final com.codahale.metrics.Gauge<java.util.Map<java.lang.String, java.util.Map<java.lang.String, java.lang.Integer>>> pendingTasksByTableName;
descriptor: Lcom/codahale/metrics/Gauge;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Signature: Lcom/codahale/metrics/Gauge<Ljava/util/Map<Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/Integer;>;>;>;
public final com.codahale.metrics.Gauge<java.lang.Long> completedTasks;
descriptor: Lcom/codahale/metrics/Gauge;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Signature: Lcom/codahale/metrics/Gauge<Ljava/lang/Long;>;
public final com.codahale.metrics.Meter totalCompactionsCompleted;
descriptor: Lcom/codahale/metrics/Meter;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
public final com.codahale.metrics.Counter bytesCompacted;
descriptor: Lcom/codahale/metrics/Counter;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=0, args_size=0
0: new org.apache.cassandra.metrics.DefaultNameFactory
dup
ldc "Compaction"
invokespecial org.apache.cassandra.metrics.DefaultNameFactory.<init>:(Ljava/lang/String;)V
putstatic org.apache.cassandra.metrics.CompactionMetrics.factory:Lorg/apache/cassandra/metrics/MetricNameFactory;
1: new java.util.IdentityHashMap
dup
invokespecial java.util.IdentityHashMap.<init>:()V
invokestatic java.util.Collections.newSetFromMap:(Ljava/util/Map;)Ljava/util/Set;
invokestatic java.util.Collections.synchronizedSet:(Ljava/util/Set;)Ljava/util/Set;
putstatic org.apache.cassandra.metrics.CompactionMetrics.compactions:Ljava/util/Set;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(java.util.concurrent.ThreadPoolExecutor[]);
descriptor: ([Ljava/util/concurrent/ThreadPoolExecutor;)V
flags: (0x0081) ACC_PUBLIC, ACC_VARARGS
Code:
stack=7, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
getstatic org.apache.cassandra.metrics.CassandraMetricsRegistry.Metrics:Lorg/apache/cassandra/metrics/CassandraMetricsRegistry;
getstatic org.apache.cassandra.metrics.CompactionMetrics.factory:Lorg/apache/cassandra/metrics/MetricNameFactory;
ldc "PendingTasks"
invokeinterface org.apache.cassandra.metrics.MetricNameFactory.createMetricName:(Ljava/lang/String;)Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$MetricName;
new org.apache.cassandra.metrics.CompactionMetrics$1
dup
aload 0
invokespecial org.apache.cassandra.metrics.CompactionMetrics$1.<init>:(Lorg/apache/cassandra/metrics/CompactionMetrics;)V
invokevirtual org.apache.cassandra.metrics.CassandraMetricsRegistry.register:(Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$MetricName;Lcom/codahale/metrics/Metric;)Lcom/codahale/metrics/Metric;
checkcast com.codahale.metrics.Gauge
putfield org.apache.cassandra.metrics.CompactionMetrics.pendingTasks:Lcom/codahale/metrics/Gauge;
2: aload 0
getstatic org.apache.cassandra.metrics.CassandraMetricsRegistry.Metrics:Lorg/apache/cassandra/metrics/CassandraMetricsRegistry;
getstatic org.apache.cassandra.metrics.CompactionMetrics.factory:Lorg/apache/cassandra/metrics/MetricNameFactory;
ldc "PendingTasksByTableName"
invokeinterface org.apache.cassandra.metrics.MetricNameFactory.createMetricName:(Ljava/lang/String;)Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$MetricName;
3: new org.apache.cassandra.metrics.CompactionMetrics$2
dup
aload 0
invokespecial org.apache.cassandra.metrics.CompactionMetrics$2.<init>:(Lorg/apache/cassandra/metrics/CompactionMetrics;)V
4: invokevirtual org.apache.cassandra.metrics.CassandraMetricsRegistry.register:(Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$MetricName;Lcom/codahale/metrics/Metric;)Lcom/codahale/metrics/Metric;
checkcast com.codahale.metrics.Gauge
putfield org.apache.cassandra.metrics.CompactionMetrics.pendingTasksByTableName:Lcom/codahale/metrics/Gauge;
5: aload 0
getstatic org.apache.cassandra.metrics.CassandraMetricsRegistry.Metrics:Lorg/apache/cassandra/metrics/CassandraMetricsRegistry;
getstatic org.apache.cassandra.metrics.CompactionMetrics.factory:Lorg/apache/cassandra/metrics/MetricNameFactory;
ldc "CompletedTasks"
invokeinterface org.apache.cassandra.metrics.MetricNameFactory.createMetricName:(Ljava/lang/String;)Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$MetricName;
new org.apache.cassandra.metrics.CompactionMetrics$3
dup
aload 0
aload 1
invokespecial org.apache.cassandra.metrics.CompactionMetrics$3.<init>:(Lorg/apache/cassandra/metrics/CompactionMetrics;[Ljava/util/concurrent/ThreadPoolExecutor;)V
invokevirtual org.apache.cassandra.metrics.CassandraMetricsRegistry.register:(Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$MetricName;Lcom/codahale/metrics/Metric;)Lcom/codahale/metrics/Metric;
checkcast com.codahale.metrics.Gauge
putfield org.apache.cassandra.metrics.CompactionMetrics.completedTasks:Lcom/codahale/metrics/Gauge;
6: aload 0
getstatic org.apache.cassandra.metrics.CassandraMetricsRegistry.Metrics:Lorg/apache/cassandra/metrics/CassandraMetricsRegistry;
getstatic org.apache.cassandra.metrics.CompactionMetrics.factory:Lorg/apache/cassandra/metrics/MetricNameFactory;
ldc "TotalCompactionsCompleted"
invokeinterface org.apache.cassandra.metrics.MetricNameFactory.createMetricName:(Ljava/lang/String;)Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$MetricName;
invokevirtual org.apache.cassandra.metrics.CassandraMetricsRegistry.meter:(Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$MetricName;)Lcom/codahale/metrics/Meter;
putfield org.apache.cassandra.metrics.CompactionMetrics.totalCompactionsCompleted:Lcom/codahale/metrics/Meter;
7: aload 0
getstatic org.apache.cassandra.metrics.CassandraMetricsRegistry.Metrics:Lorg/apache/cassandra/metrics/CassandraMetricsRegistry;
getstatic org.apache.cassandra.metrics.CompactionMetrics.factory:Lorg/apache/cassandra/metrics/MetricNameFactory;
ldc "BytesCompacted"
invokeinterface org.apache.cassandra.metrics.MetricNameFactory.createMetricName:(Ljava/lang/String;)Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$MetricName;
invokevirtual org.apache.cassandra.metrics.CassandraMetricsRegistry.counter:(Lorg/apache/cassandra/metrics/CassandraMetricsRegistry$MetricName;)Lcom/codahale/metrics/Counter;
putfield org.apache.cassandra.metrics.CompactionMetrics.bytesCompacted:Lcom/codahale/metrics/Counter;
8: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/apache/cassandra/metrics/CompactionMetrics;
0 9 1 collectors [Ljava/util/concurrent/ThreadPoolExecutor;
MethodParameters:
Name Flags
collectors final
public void beginCompaction(org.apache.cassandra.db.compaction.CompactionInfo$Holder);
descriptor: (Lorg/apache/cassandra/db/compaction/CompactionInfo$Holder;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.metrics.CompactionMetrics.compactions:Ljava/util/Set;
aload 1
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/metrics/CompactionMetrics;
0 2 1 ci Lorg/apache/cassandra/db/compaction/CompactionInfo$Holder;
MethodParameters:
Name Flags
ci
public void finishCompaction(org.apache.cassandra.db.compaction.CompactionInfo$Holder);
descriptor: (Lorg/apache/cassandra/db/compaction/CompactionInfo$Holder;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.metrics.CompactionMetrics.compactions:Ljava/util/Set;
aload 1
invokeinterface java.util.Set.remove:(Ljava/lang/Object;)Z
pop
1: aload 0
getfield org.apache.cassandra.metrics.CompactionMetrics.bytesCompacted:Lcom/codahale/metrics/Counter;
aload 1
invokevirtual org.apache.cassandra.db.compaction.CompactionInfo$Holder.getCompactionInfo:()Lorg/apache/cassandra/db/compaction/CompactionInfo;
invokevirtual org.apache.cassandra.db.compaction.CompactionInfo.getTotal:()J
invokevirtual com.codahale.metrics.Counter.inc:(J)V
2: aload 0
getfield org.apache.cassandra.metrics.CompactionMetrics.totalCompactionsCompleted:Lcom/codahale/metrics/Meter;
invokevirtual com.codahale.metrics.Meter.mark:()V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/metrics/CompactionMetrics;
0 4 1 ci Lorg/apache/cassandra/db/compaction/CompactionInfo$Holder;
MethodParameters:
Name Flags
ci
public static java.util.List<org.apache.cassandra.db.compaction.CompactionInfo$Holder> getCompactions();
descriptor: ()Ljava/util/List;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=0, args_size=0
0: new java.util.ArrayList
dup
getstatic org.apache.cassandra.metrics.CompactionMetrics.compactions:Ljava/util/Set;
invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: ()Ljava/util/List<Lorg/apache/cassandra/db/compaction/CompactionInfo$Holder;>;
}
SourceFile: "CompactionMetrics.java"
NestMembers:
org.apache.cassandra.metrics.CompactionMetrics$1 org.apache.cassandra.metrics.CompactionMetrics$2 org.apache.cassandra.metrics.CompactionMetrics$3
InnerClasses:
public abstract Holder = org.apache.cassandra.db.compaction.CompactionInfo$Holder of org.apache.cassandra.db.compaction.CompactionInfo
public abstract CompactionExecutorStatsCollector = org.apache.cassandra.db.compaction.CompactionManager$CompactionExecutorStatsCollector of org.apache.cassandra.db.compaction.CompactionManager
public MetricName = org.apache.cassandra.metrics.CassandraMetricsRegistry$MetricName of org.apache.cassandra.metrics.CassandraMetricsRegistry
org.apache.cassandra.metrics.CompactionMetrics$1
org.apache.cassandra.metrics.CompactionMetrics$2
org.apache.cassandra.metrics.CompactionMetrics$3