org.apache.cassandra/cassandra-all/3.11.5 : org/apache/cassandra/db/transform/RTBoundValidator$RowsTransformation.class

RTBoundValidator$RowsTransformation
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.transform.RTBoundValidator$RowsTransformation extends org.apache.cassandra.db.transform.Transformation
  minor version: 0
  major version: 59
  flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
  this_class: org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation
  super_class: org.apache.cassandra.db.transform.Transformation
{
  private final org.apache.cassandra.db.transform.RTBoundValidator$Stage stage;
    descriptor: Lorg/apache/cassandra/db/transform/RTBoundValidator$Stage;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.apache.cassandra.config.CFMetaData metadata;
    descriptor: Lorg/apache/cassandra/config/CFMetaData;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

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

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

  private org.apache.cassandra.db.DeletionTime openMarkerDeletionTime;
    descriptor: Lorg/apache/cassandra/db/DeletionTime;
    flags: (0x0002) ACC_PRIVATE

  private void <init>(org.apache.cassandra.db.transform.RTBoundValidator$Stage, org.apache.cassandra.config.CFMetaData, boolean, boolean);
    descriptor: (Lorg/apache/cassandra/db/transform/RTBoundValidator$Stage;Lorg/apache/cassandra/config/CFMetaData;ZZ)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=5, args_size=5
        start local 0 // org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation this
        start local 1 // org.apache.cassandra.db.transform.RTBoundValidator$Stage stage
        start local 2 // org.apache.cassandra.config.CFMetaData metadata
        start local 3 // boolean isReverseOrder
        start local 4 // boolean enforceIsClosed
         0: .line 72
            aload 0 /* this */
            invokespecial org.apache.cassandra.db.transform.Transformation.<init>:()V
         1: .line 74
            aload 0 /* this */
            aload 1 /* stage */
            putfield org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.stage:Lorg/apache/cassandra/db/transform/RTBoundValidator$Stage;
         2: .line 75
            aload 0 /* this */
            aload 2 /* metadata */
            putfield org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.metadata:Lorg/apache/cassandra/config/CFMetaData;
         3: .line 76
            aload 0 /* this */
            iload 3 /* isReverseOrder */
            putfield org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.isReverseOrder:Z
         4: .line 77
            aload 0 /* this */
            iload 4 /* enforceIsClosed */
            putfield org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.enforceIsClosed:Z
         5: .line 78
            return
        end local 4 // boolean enforceIsClosed
        end local 3 // boolean isReverseOrder
        end local 2 // org.apache.cassandra.config.CFMetaData metadata
        end local 1 // org.apache.cassandra.db.transform.RTBoundValidator$Stage stage
        end local 0 // org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    6     0             this  Lorg/apache/cassandra/db/transform/RTBoundValidator$RowsTransformation;
            0    6     1            stage  Lorg/apache/cassandra/db/transform/RTBoundValidator$Stage;
            0    6     2         metadata  Lorg/apache/cassandra/config/CFMetaData;
            0    6     3   isReverseOrder  Z
            0    6     4  enforceIsClosed  Z
    MethodParameters:
                 Name  Flags
      stage            
      metadata         
      isReverseOrder   
      enforceIsClosed  

  public org.apache.cassandra.db.rows.RangeTombstoneMarker applyToMarker(org.apache.cassandra.db.rows.RangeTombstoneMarker);
    descriptor: (Lorg/apache/cassandra/db/rows/RangeTombstoneMarker;)Lorg/apache/cassandra/db/rows/RangeTombstoneMarker;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation this
        start local 1 // org.apache.cassandra.db.rows.RangeTombstoneMarker marker
         0: .line 83
            aload 0 /* this */
            getfield org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.openMarkerDeletionTime:Lorg/apache/cassandra/db/DeletionTime;
            ifnonnull 3
         1: .line 86
            aload 1 /* marker */
            aload 0 /* this */
            getfield org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.isReverseOrder:Z
            invokeinterface org.apache.cassandra.db.rows.RangeTombstoneMarker.isClose:(Z)Z
            ifeq 9
         2: .line 87
            aload 0 /* this */
            new java.lang.StringBuilder
            dup
            ldc "unexpected end bound or boundary "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* marker */
            aload 0 /* this */
            getfield org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.metadata:Lorg/apache/cassandra/config/CFMetaData;
            invokeinterface org.apache.cassandra.db.rows.RangeTombstoneMarker.toString:(Lorg/apache/cassandra/config/CFMetaData;)Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.ise:(Ljava/lang/String;)Ljava/lang/IllegalStateException;
            athrow
         3: .line 92
      StackMap locals:
      StackMap stack:
            aload 1 /* marker */
            aload 0 /* this */
            getfield org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.isReverseOrder:Z
            invokeinterface org.apache.cassandra.db.rows.RangeTombstoneMarker.isClose:(Z)Z
            ifne 5
         4: .line 93
            aload 0 /* this */
            new java.lang.StringBuilder
            dup
            ldc "start bound followed by another start bound "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* marker */
            aload 0 /* this */
            getfield org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.metadata:Lorg/apache/cassandra/config/CFMetaData;
            invokeinterface org.apache.cassandra.db.rows.RangeTombstoneMarker.toString:(Lorg/apache/cassandra/config/CFMetaData;)Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.ise:(Ljava/lang/String;)Ljava/lang/IllegalStateException;
            athrow
         5: .line 96
      StackMap locals:
      StackMap stack:
            aload 1 /* marker */
            aload 0 /* this */
            getfield org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.isReverseOrder:Z
            invokeinterface org.apache.cassandra.db.rows.RangeTombstoneMarker.closeDeletionTime:(Z)Lorg/apache/cassandra/db/DeletionTime;
            astore 2 /* deletionTime */
        start local 2 // org.apache.cassandra.db.DeletionTime deletionTime
         6: .line 97
            aload 2 /* deletionTime */
            aload 0 /* this */
            getfield org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.openMarkerDeletionTime:Lorg/apache/cassandra/db/DeletionTime;
            invokevirtual org.apache.cassandra.db.DeletionTime.equals:(Ljava/lang/Object;)Z
            ifne 8
         7: .line 98
            aload 0 /* this */
            ldc "open marker and close marker have different deletion times"
            invokevirtual org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.ise:(Ljava/lang/String;)Ljava/lang/IllegalStateException;
            athrow
         8: .line 100
      StackMap locals: org.apache.cassandra.db.DeletionTime
      StackMap stack:
            aload 0 /* this */
            aconst_null
            putfield org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.openMarkerDeletionTime:Lorg/apache/cassandra/db/DeletionTime;
        end local 2 // org.apache.cassandra.db.DeletionTime deletionTime
         9: .line 103
      StackMap locals:
      StackMap stack:
            aload 1 /* marker */
            aload 0 /* this */
            getfield org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.isReverseOrder:Z
            invokeinterface org.apache.cassandra.db.rows.RangeTombstoneMarker.isOpen:(Z)Z
            ifeq 11
        10: .line 104
            aload 0 /* this */
            aload 1 /* marker */
            aload 0 /* this */
            getfield org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.isReverseOrder:Z
            invokeinterface org.apache.cassandra.db.rows.RangeTombstoneMarker.openDeletionTime:(Z)Lorg/apache/cassandra/db/DeletionTime;
            putfield org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.openMarkerDeletionTime:Lorg/apache/cassandra/db/DeletionTime;
        11: .line 106
      StackMap locals:
      StackMap stack:
            aload 1 /* marker */
            areturn
        end local 1 // org.apache.cassandra.db.rows.RangeTombstoneMarker marker
        end local 0 // org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0   12     0          this  Lorg/apache/cassandra/db/transform/RTBoundValidator$RowsTransformation;
            0   12     1        marker  Lorg/apache/cassandra/db/rows/RangeTombstoneMarker;
            6    9     2  deletionTime  Lorg/apache/cassandra/db/DeletionTime;
    MethodParameters:
        Name  Flags
      marker  

  public void onPartitionClose();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation this
         0: .line 112
            aload 0 /* this */
            getfield org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.enforceIsClosed:Z
            ifeq 2
            aload 0 /* this */
            getfield org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.openMarkerDeletionTime:Lorg/apache/cassandra/db/DeletionTime;
            ifnull 2
         1: .line 113
            aload 0 /* this */
            ldc "expected all RTs to be closed, but the last one is open"
            invokevirtual org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.ise:(Ljava/lang/String;)Ljava/lang/IllegalStateException;
            athrow
         2: .line 114
      StackMap locals:
      StackMap stack:
            return
        end local 0 // org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/apache/cassandra/db/transform/RTBoundValidator$RowsTransformation;

  private java.lang.IllegalStateException ise(java.lang.String);
    descriptor: (Ljava/lang/String;)Ljava/lang/IllegalStateException;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=3, args_size=2
        start local 0 // org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation this
        start local 1 // java.lang.String why
         0: .line 118
            ldc "%s UnfilteredRowIterator for %s.%s has an illegal RT bounds sequence: %s"
            iconst_4
            anewarray java.lang.Object
            dup
            iconst_0
         1: .line 119
            aload 0 /* this */
            getfield org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.stage:Lorg/apache/cassandra/db/transform/RTBoundValidator$Stage;
            aastore
            dup
            iconst_1
            aload 0 /* this */
            getfield org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.metadata:Lorg/apache/cassandra/config/CFMetaData;
            getfield org.apache.cassandra.config.CFMetaData.ksName:Ljava/lang/String;
            aastore
            dup
            iconst_2
            aload 0 /* this */
            getfield org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation.metadata:Lorg/apache/cassandra/config/CFMetaData;
            getfield org.apache.cassandra.config.CFMetaData.cfName:Ljava/lang/String;
            aastore
            dup
            iconst_3
            aload 1 /* why */
            aastore
         2: .line 118
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            astore 2 /* message */
        start local 2 // java.lang.String message
         3: .line 120
            new java.lang.IllegalStateException
            dup
            aload 2 /* message */
            invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
            athrow
        end local 2 // java.lang.String message
        end local 1 // java.lang.String why
        end local 0 // org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0     this  Lorg/apache/cassandra/db/transform/RTBoundValidator$RowsTransformation;
            0    4     1      why  Ljava/lang/String;
            3    4     2  message  Ljava/lang/String;
    MethodParameters:
      Name  Flags
      why   
}
SourceFile: "RTBoundValidator.java"
NestHost: org.apache.cassandra.db.transform.RTBoundValidator
InnerClasses:
  private final RowsTransformation = org.apache.cassandra.db.transform.RTBoundValidator$RowsTransformation of org.apache.cassandra.db.transform.RTBoundValidator
  public final Stage = org.apache.cassandra.db.transform.RTBoundValidator$Stage of org.apache.cassandra.db.transform.RTBoundValidator
/

org.apache.cassandra/ cassandra-all/ 3.11.5/ org/apache/cassandra/db/transform/RTBoundValidator$RowsTransformation.class
