org.apache.cassandra/cassandra-all/3.11.5 : org/apache/cassandra/db/compaction/writers/MaxSSTableSizeWriter.class

MaxSSTableSizeWriter
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
public class org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter extends org.apache.cassandra.db.compaction.writers.CompactionAwareWriter
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter
  super_class: org.apache.cassandra.db.compaction.writers.CompactionAwareWriter
{
  private final long maxSSTableSize;
    descriptor: J
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final int level;
    descriptor: I
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

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

  private final java.util.Set<org.apache.cassandra.io.sstable.format.SSTableReader> allSSTables;
    descriptor: Ljava/util/Set;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;

  private org.apache.cassandra.db.Directories$DataDirectory sstableDirectory;
    descriptor: Lorg/apache/cassandra/db/Directories$DataDirectory;
    flags: (0x0002) ACC_PRIVATE

  public void <init>(org.apache.cassandra.db.ColumnFamilyStore, org.apache.cassandra.db.Directories, org.apache.cassandra.db.lifecycle.LifecycleTransaction, java.util.Set<org.apache.cassandra.io.sstable.format.SSTableReader>, long, );
    descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/Directories;Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;Ljava/util/Set;JI)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=9, locals=8, args_size=7
        start local 0 // org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter this
        start local 1 // org.apache.cassandra.db.ColumnFamilyStore cfs
        start local 2 // org.apache.cassandra.db.Directories directories
        start local 3 // org.apache.cassandra.db.lifecycle.LifecycleTransaction txn
        start local 4 // java.util.Set nonExpiredSSTables
        start local 5 // long maxSSTableSize
        start local 7 // int level
         0: .line 49
            aload 0 /* this */
            aload 1 /* cfs */
            aload 2 /* directories */
            aload 3 /* txn */
            aload 4 /* nonExpiredSSTables */
            lload 5 /* maxSSTableSize */
            iload 7 /* level */
            iconst_0
            invokespecial org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.<init>:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/Directories;Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;Ljava/util/Set;JIZ)V
         1: .line 50
            return
        end local 7 // int level
        end local 5 // long maxSSTableSize
        end local 4 // java.util.Set nonExpiredSSTables
        end local 3 // org.apache.cassandra.db.lifecycle.LifecycleTransaction txn
        end local 2 // org.apache.cassandra.db.Directories directories
        end local 1 // org.apache.cassandra.db.ColumnFamilyStore cfs
        end local 0 // org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    2     0                this  Lorg/apache/cassandra/db/compaction/writers/MaxSSTableSizeWriter;
            0    2     1                 cfs  Lorg/apache/cassandra/db/ColumnFamilyStore;
            0    2     2         directories  Lorg/apache/cassandra/db/Directories;
            0    2     3                 txn  Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;
            0    2     4  nonExpiredSSTables  Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
            0    2     5      maxSSTableSize  J
            0    2     7               level  I
    Signature: (Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/Directories;Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;JI)V
    MethodParameters:
                    Name  Flags
      cfs                 
      directories         
      txn                 
      nonExpiredSSTables  
      maxSSTableSize      
      level               

  public void <init>(org.apache.cassandra.db.ColumnFamilyStore, org.apache.cassandra.db.Directories, org.apache.cassandra.db.lifecycle.LifecycleTransaction, java.util.Set<org.apache.cassandra.io.sstable.format.SSTableReader>, long, int, boolean, );
    descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/Directories;Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;Ljava/util/Set;JIZZ)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=9, locals=10, args_size=9
        start local 0 // org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter this
        start local 1 // org.apache.cassandra.db.ColumnFamilyStore cfs
        start local 2 // org.apache.cassandra.db.Directories directories
        start local 3 // org.apache.cassandra.db.lifecycle.LifecycleTransaction txn
        start local 4 // java.util.Set nonExpiredSSTables
        start local 5 // long maxSSTableSize
        start local 7 // int level
        start local 8 // boolean offline
        start local 9 // boolean keepOriginals
         0: .line 62
            aload 0 /* this */
            aload 1 /* cfs */
            aload 2 /* directories */
            aload 3 /* txn */
            aload 4 /* nonExpiredSSTables */
            lload 5 /* maxSSTableSize */
            iload 7 /* level */
            iload 9 /* keepOriginals */
            invokespecial org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.<init>:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/Directories;Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;Ljava/util/Set;JIZ)V
         1: .line 63
            return
        end local 9 // boolean keepOriginals
        end local 8 // boolean offline
        end local 7 // int level
        end local 5 // long maxSSTableSize
        end local 4 // java.util.Set nonExpiredSSTables
        end local 3 // org.apache.cassandra.db.lifecycle.LifecycleTransaction txn
        end local 2 // org.apache.cassandra.db.Directories directories
        end local 1 // org.apache.cassandra.db.ColumnFamilyStore cfs
        end local 0 // org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    2     0                this  Lorg/apache/cassandra/db/compaction/writers/MaxSSTableSizeWriter;
            0    2     1                 cfs  Lorg/apache/cassandra/db/ColumnFamilyStore;
            0    2     2         directories  Lorg/apache/cassandra/db/Directories;
            0    2     3                 txn  Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;
            0    2     4  nonExpiredSSTables  Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
            0    2     5      maxSSTableSize  J
            0    2     7               level  I
            0    2     8             offline  Z
            0    2     9       keepOriginals  Z
    Signature: (Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/Directories;Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;JIZZ)V
    RuntimeVisibleAnnotations: 
      java.lang.Deprecated()
    MethodParameters:
                    Name  Flags
      cfs                 
      directories         
      txn                 
      nonExpiredSSTables  
      maxSSTableSize      
      level               
      offline             
      keepOriginals       

  public void <init>(org.apache.cassandra.db.ColumnFamilyStore, org.apache.cassandra.db.Directories, org.apache.cassandra.db.lifecycle.LifecycleTransaction, java.util.Set<org.apache.cassandra.io.sstable.format.SSTableReader>, long, int, );
    descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/Directories;Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;Ljava/util/Set;JIZ)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=11, args_size=8
        start local 0 // org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter this
        start local 1 // org.apache.cassandra.db.ColumnFamilyStore cfs
        start local 2 // org.apache.cassandra.db.Directories directories
        start local 3 // org.apache.cassandra.db.lifecycle.LifecycleTransaction txn
        start local 4 // java.util.Set nonExpiredSSTables
        start local 5 // long maxSSTableSize
        start local 7 // int level
        start local 8 // boolean keepOriginals
         0: .line 73
            aload 0 /* this */
            aload 1 /* cfs */
            aload 2 /* directories */
            aload 3 /* txn */
            aload 4 /* nonExpiredSSTables */
            iload 8 /* keepOriginals */
            invokespecial org.apache.cassandra.db.compaction.writers.CompactionAwareWriter.<init>:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/Directories;Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;Ljava/util/Set;Z)V
         1: .line 74
            aload 0 /* this */
            aload 3 /* txn */
            invokevirtual org.apache.cassandra.db.lifecycle.LifecycleTransaction.originals:()Ljava/util/Set;
            putfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.allSSTables:Ljava/util/Set;
         2: .line 75
            aload 0 /* this */
            iload 7 /* level */
            putfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.level:I
         3: .line 76
            aload 0 /* this */
            lload 5 /* maxSSTableSize */
            putfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.maxSSTableSize:J
         4: .line 78
            aload 4 /* nonExpiredSSTables */
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.estimatedTotalKeys:J
            aload 1 /* cfs */
            aload 3 /* txn */
            invokevirtual org.apache.cassandra.db.lifecycle.LifecycleTransaction.opType:()Lorg/apache/cassandra/db/compaction/OperationType;
            invokestatic org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.getTotalWriteSize:(Ljava/lang/Iterable;JLorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/compaction/OperationType;)J
            lstore 9 /* totalSize */
        start local 9 // long totalSize
         5: .line 79
            aload 0 /* this */
            lconst_1
            lload 9 /* totalSize */
            lload 5 /* maxSSTableSize */
            ldiv
            invokestatic java.lang.Math.max:(JJ)J
            putfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.estimatedSSTables:J
         6: .line 80
            return
        end local 9 // long totalSize
        end local 8 // boolean keepOriginals
        end local 7 // int level
        end local 5 // long maxSSTableSize
        end local 4 // java.util.Set nonExpiredSSTables
        end local 3 // org.apache.cassandra.db.lifecycle.LifecycleTransaction txn
        end local 2 // org.apache.cassandra.db.Directories directories
        end local 1 // org.apache.cassandra.db.ColumnFamilyStore cfs
        end local 0 // org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    7     0                this  Lorg/apache/cassandra/db/compaction/writers/MaxSSTableSizeWriter;
            0    7     1                 cfs  Lorg/apache/cassandra/db/ColumnFamilyStore;
            0    7     2         directories  Lorg/apache/cassandra/db/Directories;
            0    7     3                 txn  Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;
            0    7     4  nonExpiredSSTables  Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
            0    7     5      maxSSTableSize  J
            0    7     7               level  I
            0    7     8       keepOriginals  Z
            5    7     9           totalSize  J
    Signature: (Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/Directories;Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;Ljava/util/Set<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;JIZ)V
    MethodParameters:
                    Name  Flags
      cfs                 
      directories         
      txn                 
      nonExpiredSSTables  
      maxSSTableSize      
      level               
      keepOriginals       

  private static long getTotalWriteSize(java.lang.Iterable<org.apache.cassandra.io.sstable.format.SSTableReader>, long, org.apache.cassandra.db.ColumnFamilyStore, org.apache.cassandra.db.compaction.OperationType);
    descriptor: (Ljava/lang/Iterable;JLorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/compaction/OperationType;)J
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=5, locals=9, args_size=4
        start local 0 // java.lang.Iterable nonExpiredSSTables
        start local 1 // long estimatedTotalKeys
        start local 3 // org.apache.cassandra.db.ColumnFamilyStore cfs
        start local 4 // org.apache.cassandra.db.compaction.OperationType compactionType
         0: .line 87
            lconst_0
            lstore 5 /* estimatedKeysBeforeCompaction */
        start local 5 // long estimatedKeysBeforeCompaction
         1: .line 88
            aload 0 /* nonExpiredSSTables */
            invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
            astore 8
            goto 4
      StackMap locals: java.lang.Iterable long org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.compaction.OperationType long top java.util.Iterator
      StackMap stack:
         2: aload 8
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.io.sstable.format.SSTableReader
            astore 7 /* sstable */
        start local 7 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
         3: .line 89
            lload 5 /* estimatedKeysBeforeCompaction */
            aload 7 /* sstable */
            invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.estimatedKeys:()J
            ladd
            lstore 5 /* estimatedKeysBeforeCompaction */
        end local 7 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
         4: .line 88
      StackMap locals:
      StackMap stack:
            aload 8
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 2
         5: .line 90
            lconst_1
            lload 5 /* estimatedKeysBeforeCompaction */
            invokestatic java.lang.Math.max:(JJ)J
            lstore 5 /* estimatedKeysBeforeCompaction */
         6: .line 91
            lload 1 /* estimatedTotalKeys */
            l2d
            lload 5 /* estimatedKeysBeforeCompaction */
            l2d
            ddiv
            dstore 7 /* estimatedCompactionRatio */
        start local 7 // double estimatedCompactionRatio
         7: .line 93
            dload 7 /* estimatedCompactionRatio */
            aload 3 /* cfs */
            aload 0 /* nonExpiredSSTables */
            aload 4 /* compactionType */
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getExpectedCompactedFileSize:(Ljava/lang/Iterable;Lorg/apache/cassandra/db/compaction/OperationType;)J
            l2d
            dmul
            invokestatic java.lang.Math.round:(D)J
            lreturn
        end local 7 // double estimatedCompactionRatio
        end local 5 // long estimatedKeysBeforeCompaction
        end local 4 // org.apache.cassandra.db.compaction.OperationType compactionType
        end local 3 // org.apache.cassandra.db.ColumnFamilyStore cfs
        end local 1 // long estimatedTotalKeys
        end local 0 // java.lang.Iterable nonExpiredSSTables
      LocalVariableTable:
        Start  End  Slot                           Name  Signature
            0    8     0             nonExpiredSSTables  Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
            0    8     1             estimatedTotalKeys  J
            0    8     3                            cfs  Lorg/apache/cassandra/db/ColumnFamilyStore;
            0    8     4                 compactionType  Lorg/apache/cassandra/db/compaction/OperationType;
            1    8     5  estimatedKeysBeforeCompaction  J
            3    4     7                        sstable  Lorg/apache/cassandra/io/sstable/format/SSTableReader;
            7    8     7       estimatedCompactionRatio  D
    Signature: (Ljava/lang/Iterable<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;JLorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/compaction/OperationType;)J
    MethodParameters:
                    Name  Flags
      nonExpiredSSTables  
      estimatedTotalKeys  
      cfs                 
      compactionType      

  protected boolean realAppend(org.apache.cassandra.db.rows.UnfilteredRowIterator);
    descriptor: (Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;)Z
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter this
        start local 1 // org.apache.cassandra.db.rows.UnfilteredRowIterator partition
         0: .line 98
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.sstableWriter:Lorg/apache/cassandra/io/sstable/SSTableRewriter;
            aload 1 /* partition */
            invokevirtual org.apache.cassandra.io.sstable.SSTableRewriter.append:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;)Lorg/apache/cassandra/db/RowIndexEntry;
            astore 2 /* rie */
        start local 2 // org.apache.cassandra.db.RowIndexEntry rie
         1: .line 99
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.sstableWriter:Lorg/apache/cassandra/io/sstable/SSTableRewriter;
            invokevirtual org.apache.cassandra.io.sstable.SSTableRewriter.currentWriter:()Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
            invokevirtual org.apache.cassandra.io.sstable.format.SSTableWriter.getEstimatedOnDiskBytesWritten:()J
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.maxSSTableSize:J
            lcmp
            ifle 3
         2: .line 101
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.sstableDirectory:Lorg/apache/cassandra/db/Directories$DataDirectory;
            invokevirtual org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.switchCompactionLocation:(Lorg/apache/cassandra/db/Directories$DataDirectory;)V
         3: .line 103
      StackMap locals: org.apache.cassandra.db.RowIndexEntry
      StackMap stack:
            aload 2 /* rie */
            ifnull 4
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
         4: iconst_0
            ireturn
        end local 2 // org.apache.cassandra.db.RowIndexEntry rie
        end local 1 // org.apache.cassandra.db.rows.UnfilteredRowIterator partition
        end local 0 // org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    5     0       this  Lorg/apache/cassandra/db/compaction/writers/MaxSSTableSizeWriter;
            0    5     1  partition  Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
            1    5     2        rie  Lorg/apache/cassandra/db/RowIndexEntry;
    MethodParameters:
           Name  Flags
      partition  

  public void switchCompactionLocation(org.apache.cassandra.db.Directories$DataDirectory);
    descriptor: (Lorg/apache/cassandra/db/Directories$DataDirectory;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=9, locals=3, args_size=2
        start local 0 // org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter this
        start local 1 // org.apache.cassandra.db.Directories$DataDirectory location
         0: .line 109
            aload 0 /* this */
            aload 1 /* location */
            putfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.sstableDirectory:Lorg/apache/cassandra/db/Directories$DataDirectory;
         1: .line 111
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
            aload 0 /* this */
            invokevirtual org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.getDirectories:()Lorg/apache/cassandra/db/Directories;
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.sstableDirectory:Lorg/apache/cassandra/db/Directories$DataDirectory;
            invokevirtual org.apache.cassandra.db.Directories.getLocationForDisk:(Lorg/apache/cassandra/db/Directories$DataDirectory;)Ljava/io/File;
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getSSTablePath:(Ljava/io/File;)Ljava/lang/String;
            invokestatic org.apache.cassandra.io.sstable.Descriptor.fromFilename:(Ljava/lang/String;)Lorg/apache/cassandra/io/sstable/Descriptor;
         2: .line 112
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.estimatedTotalKeys:J
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.estimatedSSTables:J
            ldiv
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
         3: .line 113
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.minRepairedAt:J
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
         4: .line 114
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
            getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
         5: .line 115
            new org.apache.cassandra.io.sstable.metadata.MetadataCollector
            dup
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.allSSTables:Ljava/util/Set;
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
            getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
            getfield org.apache.cassandra.config.CFMetaData.comparator:Lorg/apache/cassandra/db/ClusteringComparator;
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.level:I
            invokespecial org.apache.cassandra.io.sstable.metadata.MetadataCollector.<init>:(Ljava/lang/Iterable;Lorg/apache/cassandra/db/ClusteringComparator;I)V
         6: .line 116
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
            getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.nonExpiredSSTables:Ljava/util/Set;
            invokestatic org.apache.cassandra.db.SerializationHeader.make:(Lorg/apache/cassandra/config/CFMetaData;Ljava/util/Collection;)Lorg/apache/cassandra/db/SerializationHeader;
         7: .line 117
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
            getfield org.apache.cassandra.db.ColumnFamilyStore.indexManager:Lorg/apache/cassandra/index/SecondaryIndexManager;
            invokevirtual org.apache.cassandra.index.SecondaryIndexManager.listIndexes:()Ljava/util/Collection;
         8: .line 118
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.txn:Lorg/apache/cassandra/db/lifecycle/LifecycleTransaction;
         9: .line 111
            invokestatic org.apache.cassandra.io.sstable.format.SSTableWriter.create:(Lorg/apache/cassandra/io/sstable/Descriptor;Ljava/lang/Long;Ljava/lang/Long;Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/io/sstable/metadata/MetadataCollector;Lorg/apache/cassandra/db/SerializationHeader;Ljava/util/Collection;Lorg/apache/cassandra/db/lifecycle/LifecycleNewTracker;)Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
            astore 2 /* writer */
        start local 2 // org.apache.cassandra.io.sstable.format.SSTableWriter writer
        10: .line 120
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter.sstableWriter:Lorg/apache/cassandra/io/sstable/SSTableRewriter;
            aload 2 /* writer */
            invokevirtual org.apache.cassandra.io.sstable.SSTableRewriter.switchWriter:(Lorg/apache/cassandra/io/sstable/format/SSTableWriter;)V
        11: .line 121
            return
        end local 2 // org.apache.cassandra.io.sstable.format.SSTableWriter writer
        end local 1 // org.apache.cassandra.db.Directories$DataDirectory location
        end local 0 // org.apache.cassandra.db.compaction.writers.MaxSSTableSizeWriter this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   12     0      this  Lorg/apache/cassandra/db/compaction/writers/MaxSSTableSizeWriter;
            0   12     1  location  Lorg/apache/cassandra/db/Directories$DataDirectory;
           10   12     2    writer  Lorg/apache/cassandra/io/sstable/format/SSTableWriter;
    MethodParameters:
          Name  Flags
      location  
}
SourceFile: "MaxSSTableSizeWriter.java"
InnerClasses:
  public DataDirectory = org.apache.cassandra.db.Directories$DataDirectory of org.apache.cassandra.db.Directories
/

org.apache.cassandra/ cassandra-all/ 3.11.5/ org/apache/cassandra/db/compaction/writers/MaxSSTableSizeWriter.class
