org.apache.cassandra/cassandra-all/3.11.5 : org/apache/cassandra/db/compaction/CompactionManager$12.class

CompactionManager$12
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.
The Apache Software License, Version 2.0
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.db.compaction.CompactionManager$12 extends org.apache.cassandra.utils.WrappedRunnable
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.apache.cassandra.db.compaction.CompactionManager$12
  super_class: org.apache.cassandra.utils.WrappedRunnable
{
  final org.apache.cassandra.db.compaction.CompactionManager this$0;
    descriptor: Lorg/apache/cassandra/db/compaction/CompactionManager;
    flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC

  private final java.util.Collection val$dataFiles;
    descriptor: Ljava/util/Collection;
    flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC

  private final org.apache.cassandra.db.ColumnFamilyStore val$cfs;
    descriptor: Lorg/apache/cassandra/db/ColumnFamilyStore;
    flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC

  private final int val$gcBefore;
    descriptor: I
    flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC

  void <init>(org.apache.cassandra.db.compaction.CompactionManager, java.util.Collection, org.apache.cassandra.db.ColumnFamilyStore, int);
    descriptor: (Lorg/apache/cassandra/db/compaction/CompactionManager;Ljava/util/Collection;Lorg/apache/cassandra/db/ColumnFamilyStore;I)V
    flags: (0x0000) 
    Code:
      stack=2, locals=5, args_size=5
        start local 0 // org.apache.cassandra.db.compaction.CompactionManager$12 this
         0: .line 939
            aload 0 /* this */
            aload 1
            putfield org.apache.cassandra.db.compaction.CompactionManager$12.this$0:Lorg/apache/cassandra/db/compaction/CompactionManager;
            aload 0 /* this */
            aload 2
            putfield org.apache.cassandra.db.compaction.CompactionManager$12.val$dataFiles:Ljava/util/Collection;
            aload 0 /* this */
            aload 3
            putfield org.apache.cassandra.db.compaction.CompactionManager$12.val$cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
            aload 0 /* this */
            iload 4
            putfield org.apache.cassandra.db.compaction.CompactionManager$12.val$gcBefore:I
            aload 0 /* this */
            invokespecial org.apache.cassandra.utils.WrappedRunnable.<init>:()V
            return
        end local 0 // org.apache.cassandra.db.compaction.CompactionManager$12 this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/db/compaction/CompactionManager$12;
    MethodParameters:
               Name  Flags
      this$0         final
      val$dataFiles  final
      val$cfs        final
      val$gcBefore   final

  protected void runMayThrow();
    descriptor: ()V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=3, locals=6, args_size=1
        start local 0 // org.apache.cassandra.db.compaction.CompactionManager$12 this
         0: .line 945
            new java.util.ArrayList
            dup
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.CompactionManager$12.val$dataFiles:Ljava/util/Collection;
            invokeinterface java.util.Collection.size:()I
            invokespecial java.util.ArrayList.<init>:(I)V
            astore 1 /* sstables */
        start local 1 // java.util.Collection sstables
         1: .line 946
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.CompactionManager$12.val$dataFiles:Ljava/util/Collection;
            invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
            astore 3
            goto 8
      StackMap locals: org.apache.cassandra.db.compaction.CompactionManager$12 java.util.Collection top java.util.Iterator
      StackMap stack:
         2: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.io.sstable.Descriptor
            astore 2 /* desc */
        start local 2 // org.apache.cassandra.io.sstable.Descriptor desc
         3: .line 949
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.CompactionManager$12.this$0:Lorg/apache/cassandra/db/compaction/CompactionManager;
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.CompactionManager$12.val$cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
            aload 2 /* desc */
            invokevirtual org.apache.cassandra.db.compaction.CompactionManager.lookupSSTable:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/io/sstable/Descriptor;)Lorg/apache/cassandra/io/sstable/format/SSTableReader;
            astore 4 /* sstable */
        start local 4 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
         4: .line 950
            aload 4 /* sstable */
            ifnonnull 7
         5: .line 952
            getstatic org.apache.cassandra.db.compaction.CompactionManager.logger:Lorg/slf4j/Logger;
            ldc "Will not compact {}: it is not an active sstable"
            aload 2 /* desc */
            invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;)V
         6: .line 953
            goto 8
         7: .line 956
      StackMap locals: org.apache.cassandra.db.compaction.CompactionManager$12 java.util.Collection org.apache.cassandra.io.sstable.Descriptor java.util.Iterator org.apache.cassandra.io.sstable.format.SSTableReader
      StackMap stack:
            aload 1 /* sstables */
            aload 4 /* sstable */
            invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
            pop
        end local 4 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
        end local 2 // org.apache.cassandra.io.sstable.Descriptor desc
         8: .line 946
      StackMap locals: org.apache.cassandra.db.compaction.CompactionManager$12 java.util.Collection top java.util.Iterator
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 2
         9: .line 960
            aload 1 /* sstables */
            invokeinterface java.util.Collection.isEmpty:()Z
            ifeq 12
        10: .line 962
            getstatic org.apache.cassandra.db.compaction.CompactionManager.logger:Lorg/slf4j/Logger;
            ldc "No files to compact for user defined compaction"
            invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;)V
        11: .line 963
            goto 23
        12: .line 966
      StackMap locals: org.apache.cassandra.db.compaction.CompactionManager$12 java.util.Collection
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.CompactionManager$12.val$cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getCompactionStrategyManager:()Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
            aload 1 /* sstables */
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.CompactionManager$12.val$gcBefore:I
            invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.getUserDefinedTasks:(Ljava/util/Collection;I)Ljava/util/List;
            astore 2 /* tasks */
        start local 2 // java.util.List tasks
        13: .line 969
            aload 2 /* tasks */
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 4
            goto 17
      StackMap locals: org.apache.cassandra.db.compaction.CompactionManager$12 java.util.Collection java.util.List top java.util.Iterator
      StackMap stack:
        14: aload 4
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.db.compaction.AbstractCompactionTask
            astore 3 /* task */
        start local 3 // org.apache.cassandra.db.compaction.AbstractCompactionTask task
        15: .line 971
            aload 3 /* task */
            ifnull 17
        16: .line 972
            aload 3 /* task */
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.CompactionManager$12.this$0:Lorg/apache/cassandra/db/compaction/CompactionManager;
            getfield org.apache.cassandra.db.compaction.CompactionManager.metrics:Lorg/apache/cassandra/metrics/CompactionMetrics;
            invokevirtual org.apache.cassandra.db.compaction.AbstractCompactionTask.execute:(Lorg/apache/cassandra/db/compaction/CompactionManager$CompactionExecutorStatsCollector;)I
            pop
        end local 3 // org.apache.cassandra.db.compaction.AbstractCompactionTask task
        17: .line 969
      StackMap locals:
      StackMap stack:
            aload 4
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 14
        18: .line 974
            goto 22
        19: .line 976
      StackMap locals: org.apache.cassandra.db.compaction.CompactionManager$12 java.util.Collection java.util.List
      StackMap stack: java.lang.Throwable
            astore 5
        20: .line 977
            aload 2 /* tasks */
            invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
            invokedynamic apply()Ljava/util/function/Function;
              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;)Ljava/lang/Object;
                  org/apache/cassandra/db/compaction/CompactionManager$12.lambda$0(Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;)Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction; (6)
                  (Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;)Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;
            invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
            invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
            invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
            checkcast java.util.Collection
            invokestatic org.apache.cassandra.utils.FBUtilities.closeAll:(Ljava/util/Collection;)V
        21: .line 978
            aload 5
            athrow
        22: .line 977
      StackMap locals:
      StackMap stack:
            aload 2 /* tasks */
            invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
            invokedynamic apply()Ljava/util/function/Function;
              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;)Ljava/lang/Object;
                  org/apache/cassandra/db/compaction/CompactionManager$12.lambda$0(Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;)Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction; (6)
                  (Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;)Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;
            invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
            invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
            invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
            checkcast java.util.Collection
            invokestatic org.apache.cassandra.utils.FBUtilities.closeAll:(Ljava/util/Collection;)V
        end local 2 // java.util.List tasks
        23: .line 980
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.util.Collection sstables
        end local 0 // org.apache.cassandra.db.compaction.CompactionManager$12 this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   24     0      this  Lorg/apache/cassandra/db/compaction/CompactionManager$12;
            1   24     1  sstables  Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
            3    8     2      desc  Lorg/apache/cassandra/io/sstable/Descriptor;
            4    8     4   sstable  Lorg/apache/cassandra/io/sstable/format/SSTableReader;
           13   23     2     tasks  Ljava/util/List<Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;>;
           15   17     3      task  Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;
      Exception table:
        from    to  target  type
          13    19      19  any
    Exceptions:
      throws java.lang.Exception

  private static org.apache.cassandra.db.lifecycle.LifecycleTransaction lambda$0(org.apache.cassandra.db.compaction.AbstractCompactionTask);
    descriptor: (Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;)Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.db.compaction.AbstractCompactionTask task
         0: .line 977
            aload 0 /* task */
            getfield org.apache.cassandra.db.compaction.AbstractCompactionTask.transaction:Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;
            areturn
        end local 0 // org.apache.cassandra.db.compaction.AbstractCompactionTask task
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  task  Lorg/apache/cassandra/db/compaction/AbstractCompactionTask;
}
SourceFile: "CompactionManager.java"
EnclosingMethod: org.apache.cassandra.db.compaction.CompactionManager.submitUserDefined:(Lorg/apache/cassandra/db/ColumnFamilyStore;Ljava/util/Collection;I)Ljava/util/concurrent/Future;
NestHost: org.apache.cassandra.db.compaction.CompactionManager
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  org.apache.cassandra.db.compaction.CompactionManager$12
  public abstract CompactionExecutorStatsCollector = org.apache.cassandra.db.compaction.CompactionManager$CompactionExecutorStatsCollector of org.apache.cassandra.db.compaction.CompactionManager
/

org.apache.cassandra/ cassandra-all/ 3.11.5/ org/apache/cassandra/db/compaction/CompactionManager$12.class
