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.streaming.StreamReceiveTask$OnCompletionRunnable implements java.lang.Runnable
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable
  super_class: java.lang.Object
{
  private final org.apache.cassandra.streaming.StreamReceiveTask task;
    descriptor: Lorg/apache/cassandra/streaming/StreamReceiveTask;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  public void <init>(org.apache.cassandra.streaming.StreamReceiveTask);
    descriptor: (Lorg/apache/cassandra/streaming/StreamReceiveTask;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable this
        start local 1 // org.apache.cassandra.streaming.StreamReceiveTask task
         0: .line 178
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 180
            aload 0 /* this */
            aload 1 /* task */
            putfield org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable.task:Lorg/apache/cassandra/streaming/StreamReceiveTask;
         2: .line 181
            return
        end local 1 // org.apache.cassandra.streaming.StreamReceiveTask task
        end local 0 // org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/apache/cassandra/streaming/StreamReceiveTask$OnCompletionRunnable;
            0    3     1  task  Lorg/apache/cassandra/streaming/StreamReceiveTask;
    MethodParameters:
      Name  Flags
      task  

  public void run();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=20, args_size=1
        start local 0 // org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable this
         0: .line 185
            iconst_0
            istore 1 /* hasViews */
        start local 1 // boolean hasViews
         1: .line 186
            iconst_0
            istore 2 /* hasCDC */
        start local 2 // boolean hasCDC
         2: .line 187
            aconst_null
            astore 3 /* cfs */
        start local 3 // org.apache.cassandra.db.ColumnFamilyStore cfs
         3: .line 190
            getstatic org.apache.cassandra.config.Schema.instance:Lorg/apache/cassandra/config/Schema;
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable.task:Lorg/apache/cassandra/streaming/StreamReceiveTask;
            getfield org.apache.cassandra.streaming.StreamReceiveTask.cfId:Ljava/util/UUID;
            invokevirtual org.apache.cassandra.config.Schema.getCF:(Ljava/util/UUID;)Lorg/apache/cassandra/utils/Pair;
            astore 4 /* kscf */
        start local 4 // org.apache.cassandra.utils.Pair kscf
         4: .line 191
            aload 4 /* kscf */
            ifnonnull 13
         5: .line 194
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable.task:Lorg/apache/cassandra/streaming/StreamReceiveTask;
            getfield org.apache.cassandra.streaming.StreamReceiveTask.sstables:Ljava/util/Collection;
            invokeinterface java.util.Collection.clear:()V
         6: .line 195
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable.task:Lorg/apache/cassandra/streaming/StreamReceiveTask;
            invokevirtual org.apache.cassandra.streaming.StreamReceiveTask.abortTransaction:()V
         7: .line 196
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable.task:Lorg/apache/cassandra/streaming/StreamReceiveTask;
            getfield org.apache.cassandra.streaming.StreamReceiveTask.session:Lorg/apache/cassandra/streaming/StreamSession;
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable.task:Lorg/apache/cassandra/streaming/StreamReceiveTask;
            invokevirtual org.apache.cassandra.streaming.StreamSession.taskCompleted:(Lorg/apache/cassandra/streaming/StreamReceiveTask;)V
         8: .line 287
            iload 1 /* hasViews */
            ifne 9
            iload 2 /* hasCDC */
            ifeq 12
         9: .line 289
      StackMap locals: org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable int int org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.utils.Pair
      StackMap stack:
            aload 3 /* cfs */
            ifnull 11
        10: .line 290
            aload 3 /* cfs */
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.forceBlockingFlush:()Lorg/apache/cassandra/db/commitlog/CommitLogPosition;
            pop
        11: .line 291
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable.task:Lorg/apache/cassandra/streaming/StreamReceiveTask;
            invokevirtual org.apache.cassandra.streaming.StreamReceiveTask.abortTransaction:()V
        12: .line 197
      StackMap locals:
      StackMap stack:
            return
        13: .line 199
      StackMap locals:
      StackMap stack:
            aload 4 /* kscf */
            getfield org.apache.cassandra.utils.Pair.left:Ljava/lang/Object;
            checkcast java.lang.String
            invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
            aload 4 /* kscf */
            getfield org.apache.cassandra.utils.Pair.right:Ljava/lang/Object;
            checkcast java.lang.String
            invokevirtual org.apache.cassandra.db.Keyspace.getColumnFamilyStore:(Ljava/lang/String;)Lorg/apache/cassandra/db/ColumnFamilyStore;
            astore 3 /* cfs */
        14: .line 200
            aload 4 /* kscf */
            getfield org.apache.cassandra.utils.Pair.left:Ljava/lang/Object;
            checkcast java.lang.String
            aload 4 /* kscf */
            getfield org.apache.cassandra.utils.Pair.right:Ljava/lang/Object;
            checkcast java.lang.String
            invokestatic org.apache.cassandra.db.view.View.findAll:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Iterable;
            invokestatic com.google.common.collect.Iterables.isEmpty:(Ljava/lang/Iterable;)Z
            ifeq 15
            iconst_0
            goto 16
      StackMap locals:
      StackMap stack:
        15: iconst_1
      StackMap locals:
      StackMap stack: int
        16: istore 1 /* hasViews */
        17: .line 201
            aload 3 /* cfs */
            getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
            getfield org.apache.cassandra.config.CFMetaData.params:Lorg/apache/cassandra/schema/TableParams;
            getfield org.apache.cassandra.schema.TableParams.cdc:Z
            istore 2 /* hasCDC */
        18: .line 203
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable.task:Lorg/apache/cassandra/streaming/StreamReceiveTask;
            getfield org.apache.cassandra.streaming.StreamReceiveTask.sstables:Ljava/util/Collection;
            astore 5 /* readers */
        start local 5 // java.util.Collection readers
        19: .line 205
            aconst_null
            astore 6
            aconst_null
            astore 7
        20: aload 5 /* readers */
            invokestatic org.apache.cassandra.utils.concurrent.Refs.ref:(Ljava/lang/Iterable;)Lorg/apache/cassandra/utils/concurrent/Refs;
            astore 8 /* refs */
        start local 8 // org.apache.cassandra.utils.concurrent.Refs refs
        21: .line 216
            iload 1 /* hasViews */
            ifne 22
            iload 2 /* hasCDC */
            ifeq 47
        22: .line 218
      StackMap locals: org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable int int org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.utils.Pair java.util.Collection java.lang.Throwable java.lang.Throwable org.apache.cassandra.utils.concurrent.Refs
      StackMap stack:
            aload 5 /* readers */
            invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
            astore 10
            goto 45
      StackMap locals: org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable int int org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.utils.Pair java.util.Collection java.lang.Throwable java.lang.Throwable org.apache.cassandra.utils.concurrent.Refs top java.util.Iterator
      StackMap stack:
        23: aload 10
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.io.sstable.format.SSTableReader
            astore 9 /* reader */
        start local 9 // org.apache.cassandra.io.sstable.format.SSTableReader reader
        24: .line 220
            aload 9 /* reader */
            invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getKeyspaceName:()Ljava/lang/String;
            invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
            astore 11 /* ks */
        start local 11 // org.apache.cassandra.db.Keyspace ks
        25: .line 221
            aconst_null
            astore 12
            aconst_null
            astore 13
        26: aload 9 /* reader */
            invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getScanner:()Lorg/apache/cassandra/io/sstable/ISSTableScanner;
            astore 14 /* scanner */
        start local 14 // org.apache.cassandra.io.sstable.ISSTableScanner scanner
        27: .line 223
            goto 38
        28: .line 225
      StackMap locals: org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable int int org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.utils.Pair java.util.Collection java.lang.Throwable java.lang.Throwable org.apache.cassandra.utils.concurrent.Refs org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator org.apache.cassandra.db.Keyspace java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.sstable.ISSTableScanner
      StackMap stack:
            aconst_null
            astore 15
            aconst_null
            astore 16
        29: aload 14 /* scanner */
            invokeinterface org.apache.cassandra.io.sstable.ISSTableScanner.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.db.rows.UnfilteredRowIterator
            astore 17 /* rowIterator */
        start local 17 // org.apache.cassandra.db.rows.UnfilteredRowIterator rowIterator
        30: .line 227
            new org.apache.cassandra.db.Mutation
            dup
            aload 17 /* rowIterator */
            aload 3 /* cfs */
            getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
            invokestatic org.apache.cassandra.db.filter.ColumnFilter.all:(Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/db/filter/ColumnFilter;
            invokestatic org.apache.cassandra.db.partitions.PartitionUpdate.fromIterator:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/db/filter/ColumnFilter;)Lorg/apache/cassandra/db/partitions/PartitionUpdate;
            invokespecial org.apache.cassandra.db.Mutation.<init>:(Lorg/apache/cassandra/db/partitions/PartitionUpdate;)V
            astore 18 /* m */
        start local 18 // org.apache.cassandra.db.Mutation m
        31: .line 234
            aload 11 /* ks */
            aload 18 /* m */
            iload 2 /* hasCDC */
            iconst_1
            iconst_0
            invokevirtual org.apache.cassandra.db.Keyspace.apply:(Lorg/apache/cassandra/db/Mutation;ZZZ)V
        end local 18 // org.apache.cassandra.db.Mutation m
        32: .line 235
            aload 17 /* rowIterator */
            ifnull 38
            aload 17 /* rowIterator */
            invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
            goto 38
      StackMap locals: org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable int int org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.utils.Pair java.util.Collection java.lang.Throwable java.lang.Throwable org.apache.cassandra.utils.concurrent.Refs org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator org.apache.cassandra.db.Keyspace java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.sstable.ISSTableScanner java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.rows.UnfilteredRowIterator
      StackMap stack: java.lang.Throwable
        33: astore 15
            aload 17 /* rowIterator */
            ifnull 34
            aload 17 /* rowIterator */
            invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
        end local 17 // org.apache.cassandra.db.rows.UnfilteredRowIterator rowIterator
      StackMap locals:
      StackMap stack:
        34: aload 15
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        35: astore 16
            aload 15
            ifnonnull 36
            aload 16
            astore 15
            goto 37
      StackMap locals:
      StackMap stack:
        36: aload 15
            aload 16
            if_acmpeq 37
            aload 15
            aload 16
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        37: aload 15
            athrow
        38: .line 223
      StackMap locals:
      StackMap stack:
            aload 14 /* scanner */
            invokeinterface org.apache.cassandra.io.sstable.ISSTableScanner.hasNext:()Z
            ifne 28
        39: .line 237
            aload 14 /* scanner */
            ifnull 45
            aload 14 /* scanner */
            invokeinterface org.apache.cassandra.io.sstable.ISSTableScanner.close:()V
            goto 45
      StackMap locals:
      StackMap stack: java.lang.Throwable
        40: astore 12
            aload 14 /* scanner */
            ifnull 41
            aload 14 /* scanner */
            invokeinterface org.apache.cassandra.io.sstable.ISSTableScanner.close:()V
        end local 14 // org.apache.cassandra.io.sstable.ISSTableScanner scanner
      StackMap locals:
      StackMap stack:
        41: aload 12
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        42: astore 13
            aload 12
            ifnonnull 43
            aload 13
            astore 12
            goto 44
      StackMap locals:
      StackMap stack:
        43: aload 12
            aload 13
            if_acmpeq 44
            aload 12
            aload 13
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        44: aload 12
            athrow
        end local 11 // org.apache.cassandra.db.Keyspace ks
        end local 9 // org.apache.cassandra.io.sstable.format.SSTableReader reader
        45: .line 218
      StackMap locals: org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable int int org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.utils.Pair java.util.Collection java.lang.Throwable java.lang.Throwable org.apache.cassandra.utils.concurrent.Refs top java.util.Iterator
      StackMap stack:
            aload 10
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 23
        46: .line 239
            goto 69
        47: .line 242
      StackMap locals: org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable int int org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.utils.Pair java.util.Collection java.lang.Throwable java.lang.Throwable org.apache.cassandra.utils.concurrent.Refs
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable.task:Lorg/apache/cassandra/streaming/StreamReceiveTask;
            invokevirtual org.apache.cassandra.streaming.StreamReceiveTask.finishTransaction:()V
        48: .line 244
            getstatic org.apache.cassandra.streaming.StreamReceiveTask.logger:Lorg/slf4j/Logger;
            ldc "[Stream #{}] Received {} sstables from {} ({})"
            iconst_4
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable.task:Lorg/apache/cassandra/streaming/StreamReceiveTask;
            getfield org.apache.cassandra.streaming.StreamReceiveTask.session:Lorg/apache/cassandra/streaming/StreamSession;
            invokevirtual org.apache.cassandra.streaming.StreamSession.planId:()Ljava/util/UUID;
            aastore
            dup
            iconst_1
            aload 5 /* readers */
            invokeinterface java.util.Collection.size:()I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_2
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable.task:Lorg/apache/cassandra/streaming/StreamReceiveTask;
            getfield org.apache.cassandra.streaming.StreamReceiveTask.session:Lorg/apache/cassandra/streaming/StreamSession;
            getfield org.apache.cassandra.streaming.StreamSession.peer:Ljava/net/InetAddress;
            aastore
            dup
            iconst_3
            aload 5 /* readers */
            aastore
            invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
        49: .line 246
            aload 3 /* cfs */
            aload 5 /* readers */
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.addSSTables:(Ljava/util/Collection;)V
        50: .line 247
            aload 3 /* cfs */
            getfield org.apache.cassandra.db.ColumnFamilyStore.indexManager:Lorg/apache/cassandra/index/SecondaryIndexManager;
            aload 5 /* readers */
            invokevirtual org.apache.cassandra.index.SecondaryIndexManager.buildAllIndexesBlocking:(Ljava/util/Collection;)V
        51: .line 250
            aload 3 /* cfs */
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.isRowCacheEnabled:()Z
            ifne 52
            aload 3 /* cfs */
            getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
            invokevirtual org.apache.cassandra.config.CFMetaData.isCounter:()Z
            ifeq 69
        52: .line 252
      StackMap locals:
      StackMap stack:
            new java.util.ArrayList
            dup
            aload 5 /* readers */
            invokeinterface java.util.Collection.size:()I
            invokespecial java.util.ArrayList.<init>:(I)V
            astore 9 /* boundsToInvalidate */
        start local 9 // java.util.List boundsToInvalidate
        53: .line 253
            aload 5 /* readers */
            aload 9 /* boundsToInvalidate */
            invokedynamic accept(Ljava/util/List;)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/streaming/StreamReceiveTask$OnCompletionRunnable.lambda$0(Ljava/util/List;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
        54: .line 254
            aload 9 /* boundsToInvalidate */
            invokestatic org.apache.cassandra.dht.Bounds.getNonOverlappingBounds:(Ljava/lang/Iterable;)Ljava/util/Set;
            astore 10 /* nonOverlappingBounds */
        start local 10 // java.util.Set nonOverlappingBounds
        55: .line 256
            aload 3 /* cfs */
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.isRowCacheEnabled:()Z
            ifeq 62
        56: .line 258
            aload 3 /* cfs */
            aload 10 /* nonOverlappingBounds */
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.invalidateRowCache:(Ljava/util/Collection;)I
            istore 11 /* invalidatedKeys */
        start local 11 // int invalidatedKeys
        57: .line 259
            iload 11 /* invalidatedKeys */
            ifle 62
        58: .line 260
            getstatic org.apache.cassandra.streaming.StreamReceiveTask.logger:Lorg/slf4j/Logger;
            ldc "[Stream #{}] Invalidated {} row cache entries on table {}.{} after stream receive task completed."
            iconst_4
            anewarray java.lang.Object
            dup
            iconst_0
        59: .line 261
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable.task:Lorg/apache/cassandra/streaming/StreamReceiveTask;
            getfield org.apache.cassandra.streaming.StreamReceiveTask.session:Lorg/apache/cassandra/streaming/StreamSession;
            invokevirtual org.apache.cassandra.streaming.StreamSession.planId:()Ljava/util/UUID;
            aastore
            dup
            iconst_1
            iload 11 /* invalidatedKeys */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_2
        60: .line 262
            aload 3 /* cfs */
            getfield org.apache.cassandra.db.ColumnFamilyStore.keyspace:Lorg/apache/cassandra/db/Keyspace;
            invokevirtual org.apache.cassandra.db.Keyspace.getName:()Ljava/lang/String;
            aastore
            dup
            iconst_3
            aload 3 /* cfs */
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getTableName:()Ljava/lang/String;
            aastore
        61: .line 260
            invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
        end local 11 // int invalidatedKeys
        62: .line 265
      StackMap locals: java.util.List java.util.Set
      StackMap stack:
            aload 3 /* cfs */
            getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
            invokevirtual org.apache.cassandra.config.CFMetaData.isCounter:()Z
            ifeq 69
        63: .line 267
            aload 3 /* cfs */
            aload 10 /* nonOverlappingBounds */
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.invalidateCounterCache:(Ljava/util/Collection;)I
            istore 11 /* invalidatedKeys */
        start local 11 // int invalidatedKeys
        64: .line 268
            iload 11 /* invalidatedKeys */
            ifle 69
        65: .line 269
            getstatic org.apache.cassandra.streaming.StreamReceiveTask.logger:Lorg/slf4j/Logger;
            ldc "[Stream #{}] Invalidated {} counter cache entries on table {}.{} after stream receive task completed."
            iconst_4
            anewarray java.lang.Object
            dup
            iconst_0
        66: .line 270
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable.task:Lorg/apache/cassandra/streaming/StreamReceiveTask;
            getfield org.apache.cassandra.streaming.StreamReceiveTask.session:Lorg/apache/cassandra/streaming/StreamSession;
            invokevirtual org.apache.cassandra.streaming.StreamSession.planId:()Ljava/util/UUID;
            aastore
            dup
            iconst_1
            iload 11 /* invalidatedKeys */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_2
        67: .line 271
            aload 3 /* cfs */
            getfield org.apache.cassandra.db.ColumnFamilyStore.keyspace:Lorg/apache/cassandra/db/Keyspace;
            invokevirtual org.apache.cassandra.db.Keyspace.getName:()Ljava/lang/String;
            aastore
            dup
            iconst_3
            aload 3 /* cfs */
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getTableName:()Ljava/lang/String;
            aastore
        68: .line 269
            invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
        end local 11 // int invalidatedKeys
        end local 10 // java.util.Set nonOverlappingBounds
        end local 9 // java.util.List boundsToInvalidate
        69: .line 275
      StackMap locals:
      StackMap stack:
            aload 8 /* refs */
            ifnull 75
            aload 8 /* refs */
            invokevirtual org.apache.cassandra.utils.concurrent.Refs.close:()V
            goto 75
      StackMap locals:
      StackMap stack: java.lang.Throwable
        70: astore 6
            aload 8 /* refs */
            ifnull 71
            aload 8 /* refs */
            invokevirtual org.apache.cassandra.utils.concurrent.Refs.close:()V
        end local 8 // org.apache.cassandra.utils.concurrent.Refs refs
      StackMap locals:
      StackMap stack:
        71: aload 6
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        72: astore 7
            aload 6
            ifnonnull 73
            aload 7
            astore 6
            goto 74
      StackMap locals:
      StackMap stack:
        73: aload 6
            aload 7
            if_acmpeq 74
            aload 6
            aload 7
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        74: aload 6
            athrow
        75: .line 276
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable.task:Lorg/apache/cassandra/streaming/StreamReceiveTask;
            getfield org.apache.cassandra.streaming.StreamReceiveTask.session:Lorg/apache/cassandra/streaming/StreamSession;
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable.task:Lorg/apache/cassandra/streaming/StreamReceiveTask;
            invokevirtual org.apache.cassandra.streaming.StreamSession.taskCompleted:(Lorg/apache/cassandra/streaming/StreamReceiveTask;)V
        end local 5 // java.util.Collection readers
        end local 4 // org.apache.cassandra.utils.Pair kscf
        76: .line 277
            goto 90
        77: .line 278
      StackMap locals: org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable int int org.apache.cassandra.db.ColumnFamilyStore
      StackMap stack: java.lang.Throwable
            astore 4 /* t */
        start local 4 // java.lang.Throwable t
        78: .line 280
            aload 4 /* t */
            invokestatic org.apache.cassandra.utils.JVMStabilityInspector.inspectThrowable:(Ljava/lang/Throwable;)V
        79: .line 281
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable.task:Lorg/apache/cassandra/streaming/StreamReceiveTask;
            getfield org.apache.cassandra.streaming.StreamReceiveTask.session:Lorg/apache/cassandra/streaming/StreamSession;
            aload 4 /* t */
            invokevirtual org.apache.cassandra.streaming.StreamSession.onError:(Ljava/lang/Throwable;)V
        end local 4 // java.lang.Throwable t
        80: .line 287
            iload 1 /* hasViews */
            ifne 81
            iload 2 /* hasCDC */
            ifeq 94
        81: .line 289
      StackMap locals:
      StackMap stack:
            aload 3 /* cfs */
            ifnull 83
        82: .line 290
            aload 3 /* cfs */
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.forceBlockingFlush:()Lorg/apache/cassandra/db/commitlog/CommitLogPosition;
            pop
        83: .line 291
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable.task:Lorg/apache/cassandra/streaming/StreamReceiveTask;
            invokevirtual org.apache.cassandra.streaming.StreamReceiveTask.abortTransaction:()V
            goto 94
        84: .line 284
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 19
        85: .line 287
            iload 1 /* hasViews */
            ifne 86
            iload 2 /* hasCDC */
            ifeq 89
        86: .line 289
      StackMap locals: org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable int int org.apache.cassandra.db.ColumnFamilyStore top top top top top top top top top top top top top top top java.lang.Throwable
      StackMap stack:
            aload 3 /* cfs */
            ifnull 88
        87: .line 290
            aload 3 /* cfs */
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.forceBlockingFlush:()Lorg/apache/cassandra/db/commitlog/CommitLogPosition;
            pop
        88: .line 291
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable.task:Lorg/apache/cassandra/streaming/StreamReceiveTask;
            invokevirtual org.apache.cassandra.streaming.StreamReceiveTask.abortTransaction:()V
        89: .line 293
      StackMap locals:
      StackMap stack:
            aload 19
            athrow
        90: .line 287
      StackMap locals: org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable int int org.apache.cassandra.db.ColumnFamilyStore
      StackMap stack:
            iload 1 /* hasViews */
            ifne 91
            iload 2 /* hasCDC */
            ifeq 94
        91: .line 289
      StackMap locals:
      StackMap stack:
            aload 3 /* cfs */
            ifnull 93
        92: .line 290
            aload 3 /* cfs */
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.forceBlockingFlush:()Lorg/apache/cassandra/db/commitlog/CommitLogPosition;
            pop
        93: .line 291
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable.task:Lorg/apache/cassandra/streaming/StreamReceiveTask;
            invokevirtual org.apache.cassandra.streaming.StreamReceiveTask.abortTransaction:()V
        94: .line 294
      StackMap locals:
      StackMap stack:
            return
        end local 3 // org.apache.cassandra.db.ColumnFamilyStore cfs
        end local 2 // boolean hasCDC
        end local 1 // boolean hasViews
        end local 0 // org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable this
      LocalVariableTable:
        Start  End  Slot                  Name  Signature
            0   95     0                  this  Lorg/apache/cassandra/streaming/StreamReceiveTask$OnCompletionRunnable;
            1   95     1              hasViews  Z
            2   95     2                hasCDC  Z
            3   95     3                   cfs  Lorg/apache/cassandra/db/ColumnFamilyStore;
            4   76     4                  kscf  Lorg/apache/cassandra/utils/Pair<Ljava/lang/String;Ljava/lang/String;>;
           19   76     5               readers  Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
           21   71     8                  refs  Lorg/apache/cassandra/utils/concurrent/Refs<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
           24   45     9                reader  Lorg/apache/cassandra/io/sstable/format/SSTableReader;
           25   45    11                    ks  Lorg/apache/cassandra/db/Keyspace;
           27   41    14               scanner  Lorg/apache/cassandra/io/sstable/ISSTableScanner;
           30   34    17           rowIterator  Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
           31   32    18                     m  Lorg/apache/cassandra/db/Mutation;
           53   69     9    boundsToInvalidate  Ljava/util/List<Lorg/apache/cassandra/dht/Bounds<Lorg/apache/cassandra/dht/Token;>;>;
           55   69    10  nonOverlappingBounds  Ljava/util/Set<Lorg/apache/cassandra/dht/Bounds<Lorg/apache/cassandra/dht/Token;>;>;
           57   62    11       invalidatedKeys  I
           64   69    11       invalidatedKeys  I
           78   80     4                     t  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
          30    32      33  any
          29    35      35  any
          27    39      40  any
          26    42      42  any
          21    69      70  any
          20    72      72  any
           3     8      77  Class java.lang.Throwable
          13    76      77  Class java.lang.Throwable
           3     8      84  any
          13    80      84  any

  private static void lambda$0(java.util.List, org.apache.cassandra.io.sstable.format.SSTableReader);
    descriptor: (Ljava/util/List;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=5, locals=2, args_size=2
        start local 1 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
         0: .line 253
            aload 0
            new org.apache.cassandra.dht.Bounds
            dup
            aload 1 /* sstable */
            getfield org.apache.cassandra.io.sstable.format.SSTableReader.first:Lorg/apache/cassandra/db/DecoratedKey;
            invokevirtual org.apache.cassandra.db.DecoratedKey.getToken:()Lorg/apache/cassandra/dht/Token;
            aload 1 /* sstable */
            getfield org.apache.cassandra.io.sstable.format.SSTableReader.last:Lorg/apache/cassandra/db/DecoratedKey;
            invokevirtual org.apache.cassandra.db.DecoratedKey.getToken:()Lorg/apache/cassandra/dht/Token;
            invokespecial org.apache.cassandra.dht.Bounds.<init>:(Lorg/apache/cassandra/dht/RingPosition;Lorg/apache/cassandra/dht/RingPosition;)V
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            return
        end local 1 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     1  sstable  Lorg/apache/cassandra/io/sstable/format/SSTableReader;
}
SourceFile: "StreamReceiveTask.java"
NestHost: org.apache.cassandra.streaming.StreamReceiveTask
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  private OnCompletionRunnable = org.apache.cassandra.streaming.StreamReceiveTask$OnCompletionRunnable of org.apache.cassandra.streaming.StreamReceiveTask