class org.apache.cassandra.utils.CoalescingStrategies$DisabledCoalescingStrategy extends org.apache.cassandra.utils.CoalescingStrategies$CoalescingStrategy
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: org.apache.cassandra.utils.CoalescingStrategies$DisabledCoalescingStrategy
super_class: org.apache.cassandra.utils.CoalescingStrategies$CoalescingStrategy
{
public void <init>(int, org.apache.cassandra.utils.CoalescingStrategies$Parker, org.slf4j.Logger, java.lang.String);
descriptor: (ILorg/apache/cassandra/utils/CoalescingStrategies$Parker;Lorg/slf4j/Logger;Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 2
aload 3
aload 4
invokespecial org.apache.cassandra.utils.CoalescingStrategies$CoalescingStrategy.<init>:(Lorg/apache/cassandra/utils/CoalescingStrategies$Parker;Lorg/slf4j/Logger;Ljava/lang/String;)V
1: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/utils/CoalescingStrategies$DisabledCoalescingStrategy;
0 2 1 coalesceWindowMicros I
0 2 2 parker Lorg/apache/cassandra/utils/CoalescingStrategies$Parker;
0 2 3 logger Lorg/slf4j/Logger;
0 2 4 displayName Ljava/lang/String;
MethodParameters:
Name Flags
coalesceWindowMicros
parker
logger
displayName
protected <C extends org.apache.cassandra.utils.CoalescingStrategies$Coalescable> void coalesceInternal(java.util.concurrent.BlockingQueue<C>, java.util.List<C>, );
descriptor: (Ljava/util/concurrent/BlockingQueue;Ljava/util/List;I)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
aload 2
iload 3
invokeinterface java.util.concurrent.BlockingQueue.drainTo:(Ljava/util/Collection;I)I
ifne 3
1: aload 2
aload 1
invokeinterface java.util.concurrent.BlockingQueue.take:()Ljava/lang/Object;
checkcast org.apache.cassandra.utils.CoalescingStrategies$Coalescable
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
2: aload 1
aload 2
iload 3
iconst_1
isub
invokeinterface java.util.concurrent.BlockingQueue.drainTo:(Ljava/util/Collection;I)I
pop
3: StackMap locals:
StackMap stack:
aload 0
aload 2
invokevirtual org.apache.cassandra.utils.CoalescingStrategies$DisabledCoalescingStrategy.debugTimestamps:(Ljava/util/Collection;)V
4: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/utils/CoalescingStrategies$DisabledCoalescingStrategy;
0 5 1 input Ljava/util/concurrent/BlockingQueue<TC;>;
0 5 2 out Ljava/util/List<TC;>;
0 5 3 maxItems I
Exceptions:
throws java.lang.InterruptedException
Signature: <C::Lorg/apache/cassandra/utils/CoalescingStrategies$Coalescable;>(Ljava/util/concurrent/BlockingQueue<TC;>;Ljava/util/List<TC;>;I)V
MethodParameters:
Name Flags
input
out
maxItems
public java.lang.String toString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: ldc "Disabled"
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/utils/CoalescingStrategies$DisabledCoalescingStrategy;
}
SourceFile: "CoalescingStrategies.java"
NestHost: org.apache.cassandra.utils.CoalescingStrategies
InnerClasses:
public abstract Coalescable = org.apache.cassandra.utils.CoalescingStrategies$Coalescable of org.apache.cassandra.utils.CoalescingStrategies
public abstract CoalescingStrategy = org.apache.cassandra.utils.CoalescingStrategies$CoalescingStrategy of org.apache.cassandra.utils.CoalescingStrategies
DisabledCoalescingStrategy = org.apache.cassandra.utils.CoalescingStrategies$DisabledCoalescingStrategy of org.apache.cassandra.utils.CoalescingStrategies
abstract Parker = org.apache.cassandra.utils.CoalescingStrategies$Parker of org.apache.cassandra.utils.CoalescingStrategies
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()