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

CompactionManager$CleanupStrategy$Full

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

final class org.apache.cassandra.db.compaction.CompactionManager$CleanupStrategy$Full extends org.apache.cassandra.db.compaction.CompactionManager$CleanupStrategy
  minor version: 0
  major version: 59
  flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
  this_class: org.apache.cassandra.db.compaction.CompactionManager$CleanupStrategy$Full
  super_class: org.apache.cassandra.db.compaction.CompactionManager$CleanupStrategy
{
  private final org.apache.cassandra.db.ColumnFamilyStore cfs;
    descriptor: Lorg/apache/cassandra/db/ColumnFamilyStore;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  public void <init>(org.apache.cassandra.db.ColumnFamilyStore, java.util.Collection<org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>>, );
    descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;Ljava/util/Collection;I)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=4
        start local 0 // org.apache.cassandra.db.compaction.CompactionManager$CleanupStrategy$Full this
        start local 1 // org.apache.cassandra.db.ColumnFamilyStore cfs
        start local 2 // java.util.Collection ranges
        start local 3 // int nowInSec
         0: .line 1288
            aload 0 /* this */
            aload 2 /* ranges */
            iload 3 /* nowInSec */
            invokespecial org.apache.cassandra.db.compaction.CompactionManager$CleanupStrategy.<init>:(Ljava/util/Collection;I)V
         1: .line 1289
            aload 0 /* this */
            aload 1 /* cfs */
            putfield org.apache.cassandra.db.compaction.CompactionManager$CleanupStrategy$Full.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
         2: .line 1290
            return
        end local 3 // int nowInSec
        end local 2 // java.util.Collection ranges
        end local 1 // org.apache.cassandra.db.ColumnFamilyStore cfs
        end local 0 // org.apache.cassandra.db.compaction.CompactionManager$CleanupStrategy$Full this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    3     0      this  Lorg/apache/cassandra/db/compaction/CompactionManager$CleanupStrategy$Full;
            0    3     1       cfs  Lorg/apache/cassandra/db/ColumnFamilyStore;
            0    3     2    ranges  Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;
            0    3     3  nowInSec  I
    Signature: (Lorg/apache/cassandra/db/ColumnFamilyStore;Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;I)V
    MethodParameters:
          Name  Flags
      cfs       
      ranges    
      nowInSec  

  public org.apache.cassandra.io.sstable.ISSTableScanner getScanner(org.apache.cassandra.io.sstable.format.SSTableReader, com.google.common.util.concurrent.RateLimiter);
    descriptor: (Lorg/apache/cassandra/io/sstable/format/SSTableReader;Lcom/google/common/util/concurrent/RateLimiter;)Lorg/apache/cassandra/io/sstable/ISSTableScanner;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // org.apache.cassandra.db.compaction.CompactionManager$CleanupStrategy$Full this
        start local 1 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
        start local 2 // com.google.common.util.concurrent.RateLimiter limiter
         0: .line 1295
            aload 1 /* sstable */
            aload 2 /* limiter */
            invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getScanner:(Lcom/google/common/util/concurrent/RateLimiter;)Lorg/apache/cassandra/io/sstable/ISSTableScanner;
            areturn
        end local 2 // com.google.common.util.concurrent.RateLimiter limiter
        end local 1 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
        end local 0 // org.apache.cassandra.db.compaction.CompactionManager$CleanupStrategy$Full this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0     this  Lorg/apache/cassandra/db/compaction/CompactionManager$CleanupStrategy$Full;
            0    1     1  sstable  Lorg/apache/cassandra/io/sstable/format/SSTableReader;
            0    1     2  limiter  Lcom/google/common/util/concurrent/RateLimiter;
    MethodParameters:
         Name  Flags
      sstable  
      limiter  

  public org.apache.cassandra.db.rows.UnfilteredRowIterator cleanup(org.apache.cassandra.db.rows.UnfilteredRowIterator);
    descriptor: (Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.apache.cassandra.db.compaction.CompactionManager$CleanupStrategy$Full this
        start local 1 // org.apache.cassandra.db.rows.UnfilteredRowIterator partition
         0: .line 1301
            aload 1 /* partition */
            invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
            invokevirtual org.apache.cassandra.db.DecoratedKey.getToken:()Lorg/apache/cassandra/dht/Token;
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.CompactionManager$CleanupStrategy$Full.ranges:Ljava/util/Collection;
            invokestatic org.apache.cassandra.dht.Range.isInRanges:(Lorg/apache/cassandra/dht/RingPosition;Ljava/lang/Iterable;)Z
            ifeq 2
         1: .line 1302
            aload 1 /* partition */
            areturn
         2: .line 1304
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.CompactionManager$CleanupStrategy$Full.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
            aload 1 /* partition */
            invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.invalidateCachedPartition:(Lorg/apache/cassandra/db/DecoratedKey;)V
         3: .line 1306
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.CompactionManager$CleanupStrategy$Full.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
            getfield org.apache.cassandra.db.ColumnFamilyStore.indexManager:Lorg/apache/cassandra/index/SecondaryIndexManager;
            aload 1 /* partition */
            aload 0 /* this */
            getfield org.apache.cassandra.db.compaction.CompactionManager$CleanupStrategy$Full.nowInSec:I
            invokevirtual org.apache.cassandra.index.SecondaryIndexManager.deletePartition:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;I)V
         4: .line 1307
            aconst_null
            areturn
        end local 1 // org.apache.cassandra.db.rows.UnfilteredRowIterator partition
        end local 0 // org.apache.cassandra.db.compaction.CompactionManager$CleanupStrategy$Full this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    5     0       this  Lorg/apache/cassandra/db/compaction/CompactionManager$CleanupStrategy$Full;
            0    5     1  partition  Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
    MethodParameters:
           Name  Flags
      partition  
}
SourceFile: "CompactionManager.java"
NestHost: org.apache.cassandra.db.compaction.CompactionManager
InnerClasses:
  private abstract CleanupStrategy = org.apache.cassandra.db.compaction.CompactionManager$CleanupStrategy of org.apache.cassandra.db.compaction.CompactionManager
  private final Full = org.apache.cassandra.db.compaction.CompactionManager$CleanupStrategy$Full of org.apache.cassandra.db.compaction.CompactionManager$CleanupStrategy

/

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