https://cassandra.apache.org: The Apache Cassandra Project develops a highly scalable second-generation distributed database, bringing together Dynamo's fully distributed design and Bigtable's ColumnFamily-based data model.
  • Andres de la Peña
  • Avinash Lakshman
  • Aleksey Yeschenko
  • Aaron Morton
  • Ariel Weisberg
  • Blake Eggleston
  • Benedict Elliott Smith
  • Benjamin Lerer
  • Branimir Lambov
  • Brandon Williams
  • Carl Yeksigian
  • David Brosiusd
  • Dikang Gu
  • Eric Evans
  • Gary Dusbabek
  • Chris Goffinet
  • Alex Petrov
  • Laine Jaakko Olavi
  • T Jake Luciani
  • Jason Brown
  • Jonathan Ellis
  • Jake Farrell
  • Jeff Jirsa
  • Joel Knighton
  • Josh McKenzie
  • Johan Oskarsson
  • Jun Rao
  • Jay Zhuang
  • Sankalp Kohli
  • Marcus Eriksson
  • Michael Semb Wever
  • Mikhail Stepura
  • Michael Shuler
  • Paulo Motta
  • Prashant Malik
  • Robert Stupp
  • Peter Schuller
  • Sam Tunnicliffe
  • Sylvain Lebresne
  • Stefania Alborghetti
  • Tyler Hobbs
  • Vijay Parthasarathy
  • Pavel Yaskevich
  • Yuki Morishita
  • Nate McCall 
class org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor extends org.apache.cassandra.service.AbstractReadExecutor
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor
  super_class: org.apache.cassandra.service.AbstractReadExecutor
{
  private final org.apache.cassandra.db.ColumnFamilyStore cfs;
    descriptor: Lorg/apache/cassandra/db/ColumnFamilyStore;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  public void <init>(org.apache.cassandra.db.Keyspace, org.apache.cassandra.db.ColumnFamilyStore, org.apache.cassandra.db.ReadCommand, org.apache.cassandra.db.ConsistencyLevel, java.util.List<java.net.InetAddress>, );
    descriptor: (Lorg/apache/cassandra/db/Keyspace;Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/db/ConsistencyLevel;Ljava/util/List;J)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=8, args_size=7
        start local 0 // org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor this
        start local 1 // org.apache.cassandra.db.Keyspace keyspace
        start local 2 // org.apache.cassandra.db.ColumnFamilyStore cfs
        start local 3 // org.apache.cassandra.db.ReadCommand command
        start local 4 // org.apache.cassandra.db.ConsistencyLevel consistencyLevel
        start local 5 // java.util.List targetReplicas
        start local 6 // long queryStartNanoTime
         0: .line 321
            aload 0 /* this */
            aload 1 /* keyspace */
            aload 3 /* command */
            aload 4 /* consistencyLevel */
            aload 5 /* targetReplicas */
            lload 6 /* queryStartNanoTime */
            invokespecial org.apache.cassandra.service.AbstractReadExecutor.<init>:(Lorg/apache/cassandra/db/Keyspace;Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/db/ConsistencyLevel;Ljava/util/List;J)V
         1: .line 322
            aload 0 /* this */
            aload 2 /* cfs */
            putfield org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
         2: .line 323
            return
        end local 6 // long queryStartNanoTime
        end local 5 // java.util.List targetReplicas
        end local 4 // org.apache.cassandra.db.ConsistencyLevel consistencyLevel
        end local 3 // org.apache.cassandra.db.ReadCommand command
        end local 2 // org.apache.cassandra.db.ColumnFamilyStore cfs
        end local 1 // org.apache.cassandra.db.Keyspace keyspace
        end local 0 // org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    3     0                this  Lorg/apache/cassandra/service/AbstractReadExecutor$AlwaysSpeculatingReadExecutor;
            0    3     1            keyspace  Lorg/apache/cassandra/db/Keyspace;
            0    3     2                 cfs  Lorg/apache/cassandra/db/ColumnFamilyStore;
            0    3     3             command  Lorg/apache/cassandra/db/ReadCommand;
            0    3     4    consistencyLevel  Lorg/apache/cassandra/db/ConsistencyLevel;
            0    3     5      targetReplicas  Ljava/util/List<Ljava/net/InetAddress;>;
            0    3     6  queryStartNanoTime  J
    Signature: (Lorg/apache/cassandra/db/Keyspace;Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/db/ConsistencyLevel;Ljava/util/List<Ljava/net/InetAddress;>;J)V
    MethodParameters:
                    Name  Flags
      keyspace            
      cfs                 
      command             
      consistencyLevel    
      targetReplicas      
      queryStartNanoTime  

  public void maybeTryAdditionalReplicas();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor this
         0: .line 328
            return
        end local 0 // org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/service/AbstractReadExecutor$AlwaysSpeculatingReadExecutor;

  public java.util.Collection<java.net.InetAddress> getContactedReplicas();
    descriptor: ()Ljava/util/Collection;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor this
         0: .line 332
            aload 0 /* this */
            getfield org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor.targetReplicas:Ljava/util/List;
            areturn
        end local 0 // org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/service/AbstractReadExecutor$AlwaysSpeculatingReadExecutor;
    Signature: ()Ljava/util/Collection<Ljava/net/InetAddress;>;

  public void executeAsync();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=1, args_size=1
        start local 0 // org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor this
         0: .line 338
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor.targetReplicas:Ljava/util/List;
            iconst_0
            aload 0 /* this */
            getfield org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor.targetReplicas:Ljava/util/List;
            invokeinterface java.util.List.size:()I
            iconst_1
            if_icmple 1
            iconst_2
            goto 2
      StackMap locals: org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor
      StackMap stack: org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor java.util.List int
         1: iconst_1
      StackMap locals: org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor
      StackMap stack: org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor java.util.List int int
         2: invokeinterface java.util.List.subList:(II)Ljava/util/List;
            invokevirtual org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor.makeDataRequests:(Ljava/lang/Iterable;)V
         3: .line 339
            aload 0 /* this */
            getfield org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor.targetReplicas:Ljava/util/List;
            invokeinterface java.util.List.size:()I
            iconst_2
            if_icmple 5
         4: .line 340
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor.targetReplicas:Ljava/util/List;
            iconst_2
            aload 0 /* this */
            getfield org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor.targetReplicas:Ljava/util/List;
            invokeinterface java.util.List.size:()I
            invokeinterface java.util.List.subList:(II)Ljava/util/List;
            invokevirtual org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor.makeDigestRequests:(Ljava/lang/Iterable;)V
         5: .line 341
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
            getfield org.apache.cassandra.db.ColumnFamilyStore.metric:Lorg/apache/cassandra/metrics/TableMetrics;
            getfield org.apache.cassandra.metrics.TableMetrics.speculativeRetries:Lcom/codahale/metrics/Counter;
            invokevirtual com.codahale.metrics.Counter.inc:()V
         6: .line 342
            return
        end local 0 // org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Lorg/apache/cassandra/service/AbstractReadExecutor$AlwaysSpeculatingReadExecutor;
}
SourceFile: "AbstractReadExecutor.java"
NestHost: org.apache.cassandra.service.AbstractReadExecutor
InnerClasses:
  private AlwaysSpeculatingReadExecutor = org.apache.cassandra.service.AbstractReadExecutor$AlwaysSpeculatingReadExecutor of org.apache.cassandra.service.AbstractReadExecutor