public abstract class org.apache.cassandra.db.transform.BaseRows<R extends org.apache.cassandra.db.rows.Unfiltered, I extends org.apache.cassandra.db.rows.BaseRowIterator<? extends org.apache.cassandra.db.rows.Unfiltered>> extends org.apache.cassandra.db.transform.BaseIterator<org.apache.cassandra.db.rows.Unfiltered, I, R> implements org.apache.cassandra.db.rows.BaseRowIterator<R>
minor version: 0
major version: 59
flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
this_class: org.apache.cassandra.db.transform.BaseRows
super_class: org.apache.cassandra.db.transform.BaseIterator
{
private org.apache.cassandra.db.rows.Row staticRow;
descriptor: Lorg/apache/cassandra/db/rows/Row;
flags: (0x0002) ACC_PRIVATE
private org.apache.cassandra.db.DecoratedKey partitionKey;
descriptor: Lorg/apache/cassandra/db/DecoratedKey;
flags: (0x0002) ACC_PRIVATE
public void <init>();
descriptor: (Lorg/apache/cassandra/db/rows/BaseRowIterator;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokespecial org.apache.cassandra.db.transform.BaseIterator.<init>:(Lorg/apache/cassandra/utils/CloseableIterator;)V
1: aload 0
aload 1
invokeinterface org.apache.cassandra.db.rows.BaseRowIterator.staticRow:()Lorg/apache/cassandra/db/rows/Row;
putfield org.apache.cassandra.db.transform.BaseRows.staticRow:Lorg/apache/cassandra/db/rows/Row;
2: aload 0
aload 1
invokeinterface org.apache.cassandra.db.rows.BaseRowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
putfield org.apache.cassandra.db.transform.BaseRows.partitionKey:Lorg/apache/cassandra/db/DecoratedKey;
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/db/transform/BaseRows<TR;TI;>;
0 4 1 input TI;
Signature: (TI;)V
MethodParameters:
Name Flags
input
void <init>(org.apache.cassandra.db.transform.BaseRows<?, ? extends I>);
descriptor: (Lorg/apache/cassandra/db/transform/BaseRows;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokespecial org.apache.cassandra.db.transform.BaseIterator.<init>:(Lorg/apache/cassandra/db/transform/BaseIterator;)V
1: aload 0
aload 1
getfield org.apache.cassandra.db.transform.BaseRows.staticRow:Lorg/apache/cassandra/db/rows/Row;
putfield org.apache.cassandra.db.transform.BaseRows.staticRow:Lorg/apache/cassandra/db/rows/Row;
2: aload 0
aload 1
invokevirtual org.apache.cassandra.db.transform.BaseRows.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
putfield org.apache.cassandra.db.transform.BaseRows.partitionKey:Lorg/apache/cassandra/db/DecoratedKey;
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/db/transform/BaseRows<TR;TI;>;
0 4 1 copyFrom Lorg/apache/cassandra/db/transform/BaseRows<*+TI;>;
Signature: (Lorg/apache/cassandra/db/transform/BaseRows<*+TI;>;)V
MethodParameters:
Name Flags
copyFrom
public org.apache.cassandra.config.CFMetaData metadata();
descriptor: ()Lorg/apache/cassandra/config/CFMetaData;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.transform.BaseRows.input:Lorg/apache/cassandra/utils/CloseableIterator;
checkcast org.apache.cassandra.db.rows.BaseRowIterator
invokeinterface org.apache.cassandra.db.rows.BaseRowIterator.metadata:()Lorg/apache/cassandra/config/CFMetaData;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/transform/BaseRows<TR;TI;>;
public boolean isReverseOrder();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.transform.BaseRows.input:Lorg/apache/cassandra/utils/CloseableIterator;
checkcast org.apache.cassandra.db.rows.BaseRowIterator
invokeinterface org.apache.cassandra.db.rows.BaseRowIterator.isReverseOrder:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/transform/BaseRows<TR;TI;>;
public org.apache.cassandra.db.PartitionColumns columns();
descriptor: ()Lorg/apache/cassandra/db/PartitionColumns;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.transform.BaseRows.input:Lorg/apache/cassandra/utils/CloseableIterator;
checkcast org.apache.cassandra.db.rows.BaseRowIterator
invokeinterface org.apache.cassandra.db.rows.BaseRowIterator.columns:()Lorg/apache/cassandra/db/PartitionColumns;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/transform/BaseRows<TR;TI;>;
public org.apache.cassandra.db.DecoratedKey partitionKey();
descriptor: ()Lorg/apache/cassandra/db/DecoratedKey;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.transform.BaseRows.input:Lorg/apache/cassandra/utils/CloseableIterator;
checkcast org.apache.cassandra.db.rows.BaseRowIterator
invokeinterface org.apache.cassandra.db.rows.BaseRowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/transform/BaseRows<TR;TI;>;
public org.apache.cassandra.db.rows.Row staticRow();
descriptor: ()Lorg/apache/cassandra/db/rows/Row;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.transform.BaseRows.staticRow:Lorg/apache/cassandra/db/rows/Row;
ifnonnull 1
getstatic org.apache.cassandra.db.rows.Rows.EMPTY_STATIC_ROW:Lorg/apache/cassandra/db/rows/Row;
goto 2
StackMap locals:
StackMap stack:
1: aload 0
getfield org.apache.cassandra.db.transform.BaseRows.staticRow:Lorg/apache/cassandra/db/rows/Row;
StackMap locals:
StackMap stack: org.apache.cassandra.db.rows.Row
2: areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/db/transform/BaseRows<TR;TI;>;
protected java.lang.Throwable runOnClose(int);
descriptor: (I)Ljava/lang/Throwable;
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=6, args_size=2
start local 0 start local 1 0: aconst_null
astore 2
start local 2 1: aload 0
getfield org.apache.cassandra.db.transform.BaseRows.stack:[Lorg/apache/cassandra/db/transform/Transformation;
astore 3
start local 3 2: iconst_0
istore 4
start local 4 3: goto 9
4: StackMap locals: java.lang.Throwable org.apache.cassandra.db.transform.Transformation[] int
StackMap stack:
aload 3
iload 4
aaload
invokevirtual org.apache.cassandra.db.transform.Transformation.onPartitionClose:()V
5: goto 8
6: StackMap locals:
StackMap stack: java.lang.Throwable
astore 5
start local 5 7: aload 2
aload 5
invokestatic org.apache.cassandra.utils.Throwables.merge:(Ljava/lang/Throwable;Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 2
end local 5 8: StackMap locals:
StackMap stack:
iinc 4 1
StackMap locals:
StackMap stack:
9: iload 4
iload 1
if_icmplt 4
end local 4 10: aload 2
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/apache/cassandra/db/transform/BaseRows<TR;TI;>;
0 11 1 length I
1 11 2 fail Ljava/lang/Throwable;
2 11 3 fs [Lorg/apache/cassandra/db/transform/Transformation;
3 10 4 i I
7 8 5 t Ljava/lang/Throwable;
Exception table:
from to target type
4 5 6 Class java.lang.Throwable
MethodParameters:
Name Flags
length
void add(org.apache.cassandra.db.transform.Transformation);
descriptor: (Lorg/apache/cassandra/db/transform/Transformation;)V
flags: (0x0000)
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
aload 0
invokevirtual org.apache.cassandra.db.transform.Transformation.attachTo:(Lorg/apache/cassandra/db/transform/BaseRows;)V
1: aload 0
aload 1
invokespecial org.apache.cassandra.db.transform.BaseIterator.add:(Lorg/apache/cassandra/db/transform/Transformation;)V
2: aload 0
getfield org.apache.cassandra.db.transform.BaseRows.staticRow:Lorg/apache/cassandra/db/rows/Row;
ifnull 4
3: aload 0
aload 1
aload 0
getfield org.apache.cassandra.db.transform.BaseRows.staticRow:Lorg/apache/cassandra/db/rows/Row;
invokevirtual org.apache.cassandra.db.transform.Transformation.applyToStatic:(Lorg/apache/cassandra/db/rows/Row;)Lorg/apache/cassandra/db/rows/Row;
putfield org.apache.cassandra.db.transform.BaseRows.staticRow:Lorg/apache/cassandra/db/rows/Row;
4: StackMap locals:
StackMap stack:
aload 0
aload 0
aload 0
getfield org.apache.cassandra.db.transform.BaseRows.next:Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Unfiltered
aload 1
invokevirtual org.apache.cassandra.db.transform.BaseRows.applyOne:(Lorg/apache/cassandra/db/rows/Unfiltered;Lorg/apache/cassandra/db/transform/Transformation;)Lorg/apache/cassandra/db/rows/Unfiltered;
putfield org.apache.cassandra.db.transform.BaseRows.next:Ljava/lang/Object;
5: aload 0
aload 1
aload 0
getfield org.apache.cassandra.db.transform.BaseRows.partitionKey:Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.transform.Transformation.applyToPartitionKey:(Lorg/apache/cassandra/db/DecoratedKey;)Lorg/apache/cassandra/db/DecoratedKey;
putfield org.apache.cassandra.db.transform.BaseRows.partitionKey:Lorg/apache/cassandra/db/DecoratedKey;
6: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/db/transform/BaseRows<TR;TI;>;
0 7 1 transformation Lorg/apache/cassandra/db/transform/Transformation;
MethodParameters:
Name Flags
transformation
protected org.apache.cassandra.db.rows.Unfiltered applyOne(org.apache.cassandra.db.rows.Unfiltered, org.apache.cassandra.db.transform.Transformation);
descriptor: (Lorg/apache/cassandra/db/rows/Unfiltered;Lorg/apache/cassandra/db/transform/Transformation;)Lorg/apache/cassandra/db/rows/Unfiltered;
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
ifnonnull 2
1: aconst_null
goto 5
2: StackMap locals:
StackMap stack:
aload 1
instanceof org.apache.cassandra.db.rows.Row
ifeq 4
3: aload 2
aload 1
checkcast org.apache.cassandra.db.rows.Row
invokevirtual org.apache.cassandra.db.transform.Transformation.applyToRow:(Lorg/apache/cassandra/db/rows/Row;)Lorg/apache/cassandra/db/rows/Row;
goto 5
4: StackMap locals:
StackMap stack:
aload 2
aload 1
checkcast org.apache.cassandra.db.rows.RangeTombstoneMarker
invokevirtual org.apache.cassandra.db.transform.Transformation.applyToMarker:(Lorg/apache/cassandra/db/rows/RangeTombstoneMarker;)Lorg/apache/cassandra/db/rows/RangeTombstoneMarker;
5: StackMap locals:
StackMap stack: org.apache.cassandra.db.rows.Unfiltered
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/db/transform/BaseRows<TR;TI;>;
0 6 1 value Lorg/apache/cassandra/db/rows/Unfiltered;
0 6 2 transformation Lorg/apache/cassandra/db/transform/Transformation;
MethodParameters:
Name Flags
value
transformation
public final boolean hasNext();
descriptor: ()Z
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=2, locals=7, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.transform.BaseRows.stop:Lorg/apache/cassandra/db/transform/BaseIterator$Stop;
astore 1
start local 1 1: goto 28
2: StackMap locals: org.apache.cassandra.db.transform.BaseIterator$Stop
StackMap stack:
aload 0
getfield org.apache.cassandra.db.transform.BaseRows.stack:[Lorg/apache/cassandra/db/transform/Transformation;
astore 2
start local 2 3: aload 0
getfield org.apache.cassandra.db.transform.BaseRows.length:I
istore 3
start local 3 4: goto 25
5: StackMap locals: org.apache.cassandra.db.transform.Transformation[] int
StackMap stack:
aload 0
getfield org.apache.cassandra.db.transform.BaseRows.input:Lorg/apache/cassandra/utils/CloseableIterator;
checkcast org.apache.cassandra.db.rows.BaseRowIterator
invokeinterface org.apache.cassandra.db.rows.BaseRowIterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Unfiltered
astore 4
start local 4 6: aload 4
invokeinterface org.apache.cassandra.db.rows.Unfiltered.isRow:()Z
ifeq 15
7: aload 4
checkcast org.apache.cassandra.db.rows.Row
astore 5
start local 5 8: iconst_0
istore 6
start local 6 9: goto 12
10: StackMap locals: org.apache.cassandra.db.rows.Unfiltered org.apache.cassandra.db.rows.Row int
StackMap stack:
aload 2
iload 6
aaload
aload 5
invokevirtual org.apache.cassandra.db.transform.Transformation.applyToRow:(Lorg/apache/cassandra/db/rows/Row;)Lorg/apache/cassandra/db/rows/Row;
astore 5
11: iinc 6 1
StackMap locals:
StackMap stack:
12: aload 5
ifnull 13
iload 6
iload 3
if_icmplt 10
end local 6 13: StackMap locals:
StackMap stack:
aload 5
astore 4
end local 5 14: goto 22
15: StackMap locals:
StackMap stack:
aload 4
checkcast org.apache.cassandra.db.rows.RangeTombstoneMarker
astore 5
start local 5 16: iconst_0
istore 6
start local 6 17: goto 20
18: StackMap locals: org.apache.cassandra.db.rows.RangeTombstoneMarker int
StackMap stack:
aload 2
iload 6
aaload
aload 5
invokevirtual org.apache.cassandra.db.transform.Transformation.applyToMarker:(Lorg/apache/cassandra/db/rows/RangeTombstoneMarker;)Lorg/apache/cassandra/db/rows/RangeTombstoneMarker;
astore 5
19: iinc 6 1
StackMap locals:
StackMap stack:
20: aload 5
ifnull 21
iload 6
iload 3
if_icmplt 18
end local 6 21: StackMap locals:
StackMap stack:
aload 5
astore 4
end local 5 22: StackMap locals:
StackMap stack:
aload 4
ifnull 25
23: aload 0
aload 4
putfield org.apache.cassandra.db.transform.BaseRows.next:Ljava/lang/Object;
24: iconst_1
ireturn
end local 4 25: StackMap locals:
StackMap stack:
aload 1
getfield org.apache.cassandra.db.transform.BaseIterator$Stop.isSignalled:Z
ifne 26
aload 0
getfield org.apache.cassandra.db.transform.BaseRows.stopChild:Lorg/apache/cassandra/db/transform/BaseIterator$Stop;
getfield org.apache.cassandra.db.transform.BaseIterator$Stop.isSignalled:Z
ifne 26
aload 0
getfield org.apache.cassandra.db.transform.BaseRows.input:Lorg/apache/cassandra/utils/CloseableIterator;
checkcast org.apache.cassandra.db.rows.BaseRowIterator
invokeinterface org.apache.cassandra.db.rows.BaseRowIterator.hasNext:()Z
ifne 5
26: StackMap locals:
StackMap stack:
aload 1
getfield org.apache.cassandra.db.transform.BaseIterator$Stop.isSignalled:Z
ifne 27
aload 0
getfield org.apache.cassandra.db.transform.BaseRows.stopChild:Lorg/apache/cassandra/db/transform/BaseIterator$Stop;
getfield org.apache.cassandra.db.transform.BaseIterator$Stop.isSignalled:Z
ifne 27
aload 0
invokevirtual org.apache.cassandra.db.transform.BaseRows.hasMoreContents:()Z
ifne 28
27: StackMap locals:
StackMap stack:
iconst_0
ireturn
end local 3 end local 2 28: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.transform.BaseRows.next:Ljava/lang/Object;
ifnull 2
29: iconst_1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 30 0 this Lorg/apache/cassandra/db/transform/BaseRows<TR;TI;>;
1 30 1 stop Lorg/apache/cassandra/db/transform/BaseIterator$Stop;
3 28 2 fs [Lorg/apache/cassandra/db/transform/Transformation;
4 28 3 len I
6 25 4 next Lorg/apache/cassandra/db/rows/Unfiltered;
8 14 5 row Lorg/apache/cassandra/db/rows/Row;
9 13 6 i I
16 22 5 rtm Lorg/apache/cassandra/db/rows/RangeTombstoneMarker;
17 21 6 i I
protected java.lang.Object applyOne(java.lang.Object, org.apache.cassandra.db.transform.Transformation);
descriptor: (Ljava/lang/Object;Lorg/apache/cassandra/db/transform/Transformation;)Ljava/lang/Object;
flags: (0x1044) ACC_PROTECTED, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
checkcast org.apache.cassandra.db.rows.Unfiltered
aload 2
invokevirtual org.apache.cassandra.db.transform.BaseRows.applyOne:(Lorg/apache/cassandra/db/rows/Unfiltered;Lorg/apache/cassandra/db/transform/Transformation;)Lorg/apache/cassandra/db/rows/Unfiltered;
areturn
LocalVariableTable:
Start End Slot Name Signature
}
Signature: <R::Lorg/apache/cassandra/db/rows/Unfiltered;I::Lorg/apache/cassandra/db/rows/BaseRowIterator<+Lorg/apache/cassandra/db/rows/Unfiltered;>;>Lorg/apache/cassandra/db/transform/BaseIterator<Lorg/apache/cassandra/db/rows/Unfiltered;TI;TR;>;Lorg/apache/cassandra/db/rows/BaseRowIterator<TR;>;
SourceFile: "BaseRows.java"
InnerClasses:
Stop = org.apache.cassandra.db.transform.BaseIterator$Stop of org.apache.cassandra.db.transform.BaseIterator