public class org.apache.cassandra.service.DataResolver extends org.apache.cassandra.service.ResponseResolver
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.cassandra.service.DataResolver
  super_class: org.apache.cassandra.service.ResponseResolver
{
  private static final boolean DROP_OVERSIZED_READ_REPAIR_MUTATIONS;
    descriptor: Z
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  final java.util.List<org.apache.cassandra.net.AsyncOneResponse> repairResults;
    descriptor: Ljava/util/List;
    flags: (0x0010) ACC_FINAL
    Signature: Ljava/util/List<Lorg/apache/cassandra/net/AsyncOneResponse;>;
    RuntimeInvisibleAnnotations: 
      com.google.common.annotations.VisibleForTesting()

  private final long queryStartNanoTime;
    descriptor: J
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final boolean enforceStrictLiveness;
    descriptor: Z
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 48
            ldc "cassandra.drop_oversized_readrepair_mutations"
            invokestatic java.lang.Boolean.getBoolean:(Ljava/lang/String;)Z
         1: .line 47
            putstatic org.apache.cassandra.service.DataResolver.DROP_OVERSIZED_READ_REPAIR_MUTATIONS:Z
         2: .line 48
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  void <init>(org.apache.cassandra.db.Keyspace, org.apache.cassandra.db.ReadCommand, org.apache.cassandra.db.ConsistencyLevel, int, long);
    descriptor: (Lorg/apache/cassandra/db/Keyspace;Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/db/ConsistencyLevel;IJ)V
    flags: (0x0000) 
    Code:
      stack=5, locals=7, args_size=6
        start local 0 // org.apache.cassandra.service.DataResolver this
        start local 1 // org.apache.cassandra.db.Keyspace keyspace
        start local 2 // org.apache.cassandra.db.ReadCommand command
        start local 3 // org.apache.cassandra.db.ConsistencyLevel consistency
        start local 4 // int maxResponseCount
        start local 5 // long queryStartNanoTime
         0: .line 57
            aload 0 /* this */
            aload 1 /* keyspace */
            aload 2 /* command */
            aload 3 /* consistency */
            iload 4 /* maxResponseCount */
            invokespecial org.apache.cassandra.service.ResponseResolver.<init>:(Lorg/apache/cassandra/db/Keyspace;Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/db/ConsistencyLevel;I)V
         1: .line 51
            aload 0 /* this */
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            invokestatic java.util.Collections.synchronizedList:(Ljava/util/List;)Ljava/util/List;
            putfield org.apache.cassandra.service.DataResolver.repairResults:Ljava/util/List;
         2: .line 58
            aload 0 /* this */
            lload 5 /* queryStartNanoTime */
            putfield org.apache.cassandra.service.DataResolver.queryStartNanoTime:J
         3: .line 59
            aload 0 /* this */
            aload 2 /* command */
            invokevirtual org.apache.cassandra.db.ReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
            invokevirtual org.apache.cassandra.config.CFMetaData.enforceStrictLiveness:()Z
            putfield org.apache.cassandra.service.DataResolver.enforceStrictLiveness:Z
         4: .line 60
            return
        end local 5 // long queryStartNanoTime
        end local 4 // int maxResponseCount
        end local 3 // org.apache.cassandra.db.ConsistencyLevel consistency
        end local 2 // org.apache.cassandra.db.ReadCommand command
        end local 1 // org.apache.cassandra.db.Keyspace keyspace
        end local 0 // org.apache.cassandra.service.DataResolver this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    5     0                this  Lorg/apache/cassandra/service/DataResolver;
            0    5     1            keyspace  Lorg/apache/cassandra/db/Keyspace;
            0    5     2             command  Lorg/apache/cassandra/db/ReadCommand;
            0    5     3         consistency  Lorg/apache/cassandra/db/ConsistencyLevel;
            0    5     4    maxResponseCount  I
            0    5     5  queryStartNanoTime  J
    MethodParameters:
                    Name  Flags
      keyspace            
      command             
      consistency         
      maxResponseCount    
      queryStartNanoTime  

  public org.apache.cassandra.db.partitions.PartitionIterator getData();
    descriptor: ()Lorg/apache/cassandra/db/partitions/PartitionIterator;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // org.apache.cassandra.service.DataResolver this
         0: .line 64
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.responses:Lorg/apache/cassandra/utils/concurrent/Accumulator;
            invokevirtual org.apache.cassandra.utils.concurrent.Accumulator.iterator:()Ljava/util/Iterator;
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.net.MessageIn
            getfield org.apache.cassandra.net.MessageIn.payload:Ljava/lang/Object;
            checkcast org.apache.cassandra.db.ReadResponse
            astore 1 /* response */
        start local 1 // org.apache.cassandra.db.ReadResponse response
         1: .line 65
            aload 1 /* response */
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadResponse.makeIterator:(Lorg/apache/cassandra/db/ReadCommand;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.nowInSec:()I
            invokestatic org.apache.cassandra.db.partitions.UnfilteredPartitionIterators.filter:(Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;I)Lorg/apache/cassandra/db/partitions/PartitionIterator;
            areturn
        end local 1 // org.apache.cassandra.db.ReadResponse response
        end local 0 // org.apache.cassandra.service.DataResolver this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lorg/apache/cassandra/service/DataResolver;
            1    2     1  response  Lorg/apache/cassandra/db/ReadResponse;

  public boolean isDataPresent();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.service.DataResolver this
         0: .line 70
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.responses:Lorg/apache/cassandra/utils/concurrent/Accumulator;
            invokevirtual org.apache.cassandra.utils.concurrent.Accumulator.isEmpty:()Z
            ifeq 1
            iconst_0
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_1
      StackMap locals:
      StackMap stack: int
         2: ireturn
        end local 0 // org.apache.cassandra.service.DataResolver this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/apache/cassandra/service/DataResolver;

  public void compareResponses();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=1
        start local 0 // org.apache.cassandra.service.DataResolver this
         0: .line 76
            aconst_null
            astore 1
            aconst_null
            astore 2
         1: aload 0 /* this */
            invokevirtual org.apache.cassandra.service.DataResolver.resolve:()Lorg/apache/cassandra/db/partitions/PartitionIterator;
            astore 3 /* iterator */
        start local 3 // org.apache.cassandra.db.partitions.PartitionIterator iterator
         2: .line 78
            aload 3 /* iterator */
            invokestatic org.apache.cassandra.db.partitions.PartitionIterators.consume:(Lorg/apache/cassandra/db/partitions/PartitionIterator;)V
         3: .line 79
            aload 3 /* iterator */
            ifnull 9
            aload 3 /* iterator */
            invokeinterface org.apache.cassandra.db.partitions.PartitionIterator.close:()V
            goto 9
      StackMap locals: org.apache.cassandra.service.DataResolver java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.partitions.PartitionIterator
      StackMap stack: java.lang.Throwable
         4: astore 1
            aload 3 /* iterator */
            ifnull 5
            aload 3 /* iterator */
            invokeinterface org.apache.cassandra.db.partitions.PartitionIterator.close:()V
        end local 3 // org.apache.cassandra.db.partitions.PartitionIterator iterator
      StackMap locals:
      StackMap stack:
         5: aload 1
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
         6: astore 2
            aload 1
            ifnonnull 7
            aload 2
            astore 1
            goto 8
      StackMap locals:
      StackMap stack:
         7: aload 1
            aload 2
            if_acmpeq 8
            aload 1
            aload 2
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
         8: aload 1
            athrow
         9: .line 80
      StackMap locals:
      StackMap stack:
            return
        end local 0 // org.apache.cassandra.service.DataResolver this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   10     0      this  Lorg/apache/cassandra/service/DataResolver;
            2    5     3  iterator  Lorg/apache/cassandra/db/partitions/PartitionIterator;
      Exception table:
        from    to  target  type
           2     3       4  any
           1     6       6  any

  public org.apache.cassandra.db.partitions.PartitionIterator resolve();
    descriptor: ()Lorg/apache/cassandra/db/partitions/PartitionIterator;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=8, args_size=1
        start local 0 // org.apache.cassandra.service.DataResolver this
         0: .line 86
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.responses:Lorg/apache/cassandra/utils/concurrent/Accumulator;
            invokevirtual org.apache.cassandra.utils.concurrent.Accumulator.size:()I
            istore 1 /* count */
        start local 1 // int count
         1: .line 87
            new java.util.ArrayList
            dup
            iload 1 /* count */
            invokespecial java.util.ArrayList.<init>:(I)V
            astore 2 /* iters */
        start local 2 // java.util.List iters
         2: .line 88
            iload 1 /* count */
            anewarray java.net.InetAddress
            astore 3 /* sources */
        start local 3 // java.net.InetAddress[] sources
         3: .line 89
            iconst_0
            istore 4 /* i */
        start local 4 // int i
         4: goto 9
         5: .line 91
      StackMap locals: org.apache.cassandra.service.DataResolver int java.util.List java.net.InetAddress[] int
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.responses:Lorg/apache/cassandra/utils/concurrent/Accumulator;
            iload 4 /* i */
            invokevirtual org.apache.cassandra.utils.concurrent.Accumulator.get:(I)Ljava/lang/Object;
            checkcast org.apache.cassandra.net.MessageIn
            astore 5 /* msg */
        start local 5 // org.apache.cassandra.net.MessageIn msg
         6: .line 92
            aload 2 /* iters */
            aload 5 /* msg */
            getfield org.apache.cassandra.net.MessageIn.payload:Ljava/lang/Object;
            checkcast org.apache.cassandra.db.ReadResponse
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadResponse.makeIterator:(Lorg/apache/cassandra/db/ReadCommand;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
         7: .line 93
            aload 3 /* sources */
            iload 4 /* i */
            aload 5 /* msg */
            getfield org.apache.cassandra.net.MessageIn.from:Ljava/net/InetAddress;
            aastore
        end local 5 // org.apache.cassandra.net.MessageIn msg
         8: .line 89
            iinc 4 /* i */ 1
      StackMap locals:
      StackMap stack:
         9: iload 4 /* i */
            iload 1 /* count */
            if_icmplt 5
        end local 4 // int i
        10: .line 111
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.nowInSec:()I
            iconst_1
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.selectsFullPartition:()Z
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.enforceStrictLiveness:Z
            invokevirtual org.apache.cassandra.db.filter.DataLimits.newCounter:(IZZZ)Lorg/apache/cassandra/db/filter/DataLimits$Counter;
        11: .line 110
            astore 4 /* mergedResultCounter */
        start local 4 // org.apache.cassandra.db.filter.DataLimits$Counter mergedResultCounter
        12: .line 113
            aload 0 /* this */
            aload 2 /* iters */
            aload 3 /* sources */
            aload 4 /* mergedResultCounter */
            invokevirtual org.apache.cassandra.service.DataResolver.mergeWithShortReadProtection:(Ljava/util/List;[Ljava/net/InetAddress;Lorg/apache/cassandra/db/filter/DataLimits$Counter;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
            astore 5 /* merged */
        start local 5 // org.apache.cassandra.db.partitions.UnfilteredPartitionIterator merged
        13: .line 115
            aload 5 /* merged */
            new org.apache.cassandra.db.transform.Filter
            dup
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.nowInSec:()I
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
            invokevirtual org.apache.cassandra.config.CFMetaData.enforceStrictLiveness:()Z
            invokespecial org.apache.cassandra.db.transform.Filter.<init>:(IZ)V
            invokestatic org.apache.cassandra.db.transform.FilteredPartitions.filter:(Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;Lorg/apache/cassandra/db/transform/Filter;)Lorg/apache/cassandra/db/transform/FilteredPartitions;
        14: .line 114
            astore 6 /* filtered */
        start local 6 // org.apache.cassandra.db.transform.FilteredPartitions filtered
        15: .line 116
            aload 6 /* filtered */
            aload 4 /* mergedResultCounter */
            invokestatic org.apache.cassandra.db.transform.Transformation.apply:(Lorg/apache/cassandra/db/partitions/PartitionIterator;Lorg/apache/cassandra/db/transform/Transformation;)Lorg/apache/cassandra/db/partitions/PartitionIterator;
            astore 7 /* counted */
        start local 7 // org.apache.cassandra.db.partitions.PartitionIterator counted
        16: .line 118
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.isForThrift:()Z
            ifeq 18
        17: .line 119
            aload 7 /* counted */
            goto 19
        18: .line 120
      StackMap locals: org.apache.cassandra.service.DataResolver int java.util.List java.net.InetAddress[] org.apache.cassandra.db.filter.DataLimits$Counter org.apache.cassandra.db.partitions.UnfilteredPartitionIterator org.apache.cassandra.db.transform.FilteredPartitions org.apache.cassandra.db.partitions.PartitionIterator
      StackMap stack:
            aload 7 /* counted */
            new org.apache.cassandra.db.transform.EmptyPartitionsDiscarder
            dup
            invokespecial org.apache.cassandra.db.transform.EmptyPartitionsDiscarder.<init>:()V
            invokestatic org.apache.cassandra.db.transform.Transformation.apply:(Lorg/apache/cassandra/db/partitions/PartitionIterator;Lorg/apache/cassandra/db/transform/Transformation;)Lorg/apache/cassandra/db/partitions/PartitionIterator;
        19: .line 118
      StackMap locals:
      StackMap stack: org.apache.cassandra.db.partitions.PartitionIterator
            areturn
        end local 7 // org.apache.cassandra.db.partitions.PartitionIterator counted
        end local 6 // org.apache.cassandra.db.transform.FilteredPartitions filtered
        end local 5 // org.apache.cassandra.db.partitions.UnfilteredPartitionIterator merged
        end local 4 // org.apache.cassandra.db.filter.DataLimits$Counter mergedResultCounter
        end local 3 // java.net.InetAddress[] sources
        end local 2 // java.util.List iters
        end local 1 // int count
        end local 0 // org.apache.cassandra.service.DataResolver this
      LocalVariableTable:
        Start  End  Slot                 Name  Signature
            0   20     0                 this  Lorg/apache/cassandra/service/DataResolver;
            1   20     1                count  I
            2   20     2                iters  Ljava/util/List<Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;>;
            3   20     3              sources  [Ljava/net/InetAddress;
            4   10     4                    i  I
            6    8     5                  msg  Lorg/apache/cassandra/net/MessageIn<Lorg/apache/cassandra/db/ReadResponse;>;
           12   20     4  mergedResultCounter  Lorg/apache/cassandra/db/filter/DataLimits$Counter;
           13   20     5               merged  Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
           15   20     6             filtered  Lorg/apache/cassandra/db/transform/FilteredPartitions;
           16   20     7              counted  Lorg/apache/cassandra/db/partitions/PartitionIterator;

  private org.apache.cassandra.db.partitions.UnfilteredPartitionIterator mergeWithShortReadProtection(java.util.List<org.apache.cassandra.db.partitions.UnfilteredPartitionIterator>, java.net.InetAddress[], org.apache.cassandra.db.filter.DataLimits$Counter);
    descriptor: (Ljava/util/List;[Ljava/net/InetAddress;Lorg/apache/cassandra/db/filter/DataLimits$Counter;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=6, locals=5, args_size=4
        start local 0 // org.apache.cassandra.service.DataResolver this
        start local 1 // java.util.List results
        start local 2 // java.net.InetAddress[] sources
        start local 3 // org.apache.cassandra.db.filter.DataLimits$Counter mergedResultCounter
         0: .line 128
            aload 1 /* results */
            invokeinterface java.util.List.size:()I
            iconst_1
            if_icmpne 2
         1: .line 129
            aload 1 /* results */
            iconst_0
            invokeinterface java.util.List.get:(I)Ljava/lang/Object;
            checkcast org.apache.cassandra.db.partitions.UnfilteredPartitionIterator
            areturn
         2: .line 135
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
            invokevirtual org.apache.cassandra.db.filter.DataLimits.isUnlimited:()Z
            ifne 8
         3: .line 136
            iconst_0
            istore 4 /* i */
        start local 4 // int i
         4: goto 7
         5: .line 137
      StackMap locals: int
      StackMap stack:
            aload 1 /* results */
            iload 4 /* i */
            aload 0 /* this */
            aload 1 /* results */
            iload 4 /* i */
            invokeinterface java.util.List.get:(I)Ljava/lang/Object;
            checkcast org.apache.cassandra.db.partitions.UnfilteredPartitionIterator
            aload 2 /* sources */
            iload 4 /* i */
            aaload
            aload 3 /* mergedResultCounter */
            invokevirtual org.apache.cassandra.service.DataResolver.extendWithShortReadProtection:(Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;Ljava/net/InetAddress;Lorg/apache/cassandra/db/filter/DataLimits$Counter;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
            invokeinterface java.util.List.set:(ILjava/lang/Object;)Ljava/lang/Object;
            pop
         6: .line 136
            iinc 4 /* i */ 1
      StackMap locals:
      StackMap stack:
         7: iload 4 /* i */
            aload 1 /* results */
            invokeinterface java.util.List.size:()I
            if_icmplt 5
        end local 4 // int i
         8: .line 139
      StackMap locals:
      StackMap stack:
            aload 1 /* results */
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.nowInSec:()I
            new org.apache.cassandra.service.DataResolver$RepairMergeListener
            dup
            aload 0 /* this */
            aload 2 /* sources */
            invokespecial org.apache.cassandra.service.DataResolver$RepairMergeListener.<init>:(Lorg/apache/cassandra/service/DataResolver;[Ljava/net/InetAddress;)V
            invokestatic org.apache.cassandra.db.partitions.UnfilteredPartitionIterators.merge:(Ljava/util/List;ILorg/apache/cassandra/db/partitions/UnfilteredPartitionIterators$MergeListener;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
            areturn
        end local 3 // org.apache.cassandra.db.filter.DataLimits$Counter mergedResultCounter
        end local 2 // java.net.InetAddress[] sources
        end local 1 // java.util.List results
        end local 0 // org.apache.cassandra.service.DataResolver this
      LocalVariableTable:
        Start  End  Slot                 Name  Signature
            0    9     0                 this  Lorg/apache/cassandra/service/DataResolver;
            0    9     1              results  Ljava/util/List<Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;>;
            0    9     2              sources  [Ljava/net/InetAddress;
            0    9     3  mergedResultCounter  Lorg/apache/cassandra/db/filter/DataLimits$Counter;
            4    8     4                    i  I
    Signature: (Ljava/util/List<Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;>;[Ljava/net/InetAddress;Lorg/apache/cassandra/db/filter/DataLimits$Counter;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
    MethodParameters:
                     Name  Flags
      results              
      sources              
      mergedResultCounter  

  private org.apache.cassandra.db.partitions.UnfilteredPartitionIterator extendWithShortReadProtection(org.apache.cassandra.db.partitions.UnfilteredPartitionIterator, java.net.InetAddress, org.apache.cassandra.db.filter.DataLimits$Counter);
    descriptor: (Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;Ljava/net/InetAddress;Lorg/apache/cassandra/db/filter/DataLimits$Counter;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=8, locals=6, args_size=4
        start local 0 // org.apache.cassandra.service.DataResolver this
        start local 1 // org.apache.cassandra.db.partitions.UnfilteredPartitionIterator partitions
        start local 2 // java.net.InetAddress source
        start local 3 // org.apache.cassandra.db.filter.DataLimits$Counter mergedResultCounter
         0: .line 528
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.nowInSec:()I
            iconst_0
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.selectsFullPartition:()Z
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.enforceStrictLiveness:Z
            invokevirtual org.apache.cassandra.db.filter.DataLimits.newCounter:(IZZZ)Lorg/apache/cassandra/db/filter/DataLimits$Counter;
            invokevirtual org.apache.cassandra.db.filter.DataLimits$Counter.onlyCount:()Lorg/apache/cassandra/db/filter/DataLimits$Counter;
         1: .line 527
            astore 4 /* singleResultCounter */
        start local 4 // org.apache.cassandra.db.filter.DataLimits$Counter singleResultCounter
         2: .line 531
            new org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection
            dup
            aload 0 /* this */
            aload 2 /* source */
            aload 4 /* singleResultCounter */
            aload 3 /* mergedResultCounter */
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.queryStartNanoTime:J
            invokespecial org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection.<init>:(Lorg/apache/cassandra/service/DataResolver;Ljava/net/InetAddress;Lorg/apache/cassandra/db/filter/DataLimits$Counter;Lorg/apache/cassandra/db/filter/DataLimits$Counter;J)V
         3: .line 530
            astore 5 /* protection */
        start local 5 // org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection protection
         4: .line 546
            aload 0 /* this */
            getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
            invokevirtual org.apache.cassandra.db.ReadCommand.isLimitedToOnePartition:()Z
            ifne 6
         5: .line 547
            aload 1 /* partitions */
            aload 5 /* protection */
            invokestatic org.apache.cassandra.db.transform.MorePartitions.extend:(Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;Lorg/apache/cassandra/db/transform/MorePartitions;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
            astore 1 /* partitions */
         6: .line 549
      StackMap locals: org.apache.cassandra.db.filter.DataLimits$Counter org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection
      StackMap stack:
            aload 1 /* partitions */
            aload 5 /* protection */
            invokestatic org.apache.cassandra.db.transform.Transformation.apply:(Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;Lorg/apache/cassandra/db/transform/Transformation;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
            astore 1 /* partitions */
         7: .line 550
            aload 1 /* partitions */
            aload 4 /* singleResultCounter */
            invokestatic org.apache.cassandra.db.transform.Transformation.apply:(Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;Lorg/apache/cassandra/db/transform/Transformation;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
            astore 1 /* partitions */
         8: .line 552
            aload 1 /* partitions */
            areturn
        end local 5 // org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection protection
        end local 4 // org.apache.cassandra.db.filter.DataLimits$Counter singleResultCounter
        end local 3 // org.apache.cassandra.db.filter.DataLimits$Counter mergedResultCounter
        end local 2 // java.net.InetAddress source
        end local 1 // org.apache.cassandra.db.partitions.UnfilteredPartitionIterator partitions
        end local 0 // org.apache.cassandra.service.DataResolver this
      LocalVariableTable:
        Start  End  Slot                 Name  Signature
            0    9     0                 this  Lorg/apache/cassandra/service/DataResolver;
            0    9     1           partitions  Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
            0    9     2               source  Ljava/net/InetAddress;
            0    9     3  mergedResultCounter  Lorg/apache/cassandra/db/filter/DataLimits$Counter;
            2    9     4  singleResultCounter  Lorg/apache/cassandra/db/filter/DataLimits$Counter;
            4    9     5           protection  Lorg/apache/cassandra/service/DataResolver$ShortReadPartitionsProtection;
    MethodParameters:
                     Name  Flags
      partitions           
      source               
      mergedResultCounter  
}
SourceFile: "DataResolver.java"
NestMembers:
  org.apache.cassandra.service.DataResolver$RepairMergeListener  org.apache.cassandra.service.DataResolver$RepairMergeListener$MergeListener  org.apache.cassandra.service.DataResolver$RepairMergeListener$MergeListener$1  org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection  org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection$ShortReadRowsProtection
InnerClasses:
  public abstract Counter = org.apache.cassandra.db.filter.DataLimits$Counter of org.apache.cassandra.db.filter.DataLimits
  public abstract MergeListener = org.apache.cassandra.db.partitions.UnfilteredPartitionIterators$MergeListener of org.apache.cassandra.db.partitions.UnfilteredPartitionIterators
  private RepairMergeListener = org.apache.cassandra.service.DataResolver$RepairMergeListener of org.apache.cassandra.service.DataResolver
  private ShortReadPartitionsProtection = org.apache.cassandra.service.DataResolver$ShortReadPartitionsProtection of org.apache.cassandra.service.DataResolver