public abstract class org.apache.cassandra.db.rows.Rows
minor version: 0
major version: 59
flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
this_class: org.apache.cassandra.db.rows.Rows
super_class: java.lang.Object
{
public static final org.apache.cassandra.db.rows.Row EMPTY_STATIC_ROW;
descriptor: Lorg/apache/cassandra/db/rows/Row;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
static final boolean $assertionsDisabled;
descriptor: Z
flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/db/rows/Rows;
invokevirtual java.lang.Class.desiredAssertionStatus:()Z
ifne 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: putstatic org.apache.cassandra.db.rows.Rows.$assertionsDisabled:Z
3: getstatic org.apache.cassandra.db.Clustering.STATIC_CLUSTERING:Lorg/apache/cassandra/db/Clustering;
invokestatic org.apache.cassandra.db.rows.BTreeRow.emptyRow:(Lorg/apache/cassandra/db/Clustering;)Lorg/apache/cassandra/db/rows/BTreeRow;
putstatic org.apache.cassandra.db.rows.Rows.EMPTY_STATIC_ROW:Lorg/apache/cassandra/db/rows/Row;
return
LocalVariableTable:
Start End Slot Name Signature
private void <init>();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/rows/Rows;
public static org.apache.cassandra.db.rows.Row$Builder copy(org.apache.cassandra.db.rows.Row, org.apache.cassandra.db.rows.Row$Builder);
descriptor: (Lorg/apache/cassandra/db/rows/Row;Lorg/apache/cassandra/db/rows/Row$Builder;)Lorg/apache/cassandra/db/rows/Row$Builder;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=7, args_size=2
start local 0 start local 1 0: aload 1
aload 0
invokeinterface org.apache.cassandra.db.rows.Row.clustering:()Lorg/apache/cassandra/db/Clustering;
invokeinterface org.apache.cassandra.db.rows.Row$Builder.newRow:(Lorg/apache/cassandra/db/Clustering;)V
1: aload 1
aload 0
invokeinterface org.apache.cassandra.db.rows.Row.primaryKeyLivenessInfo:()Lorg/apache/cassandra/db/LivenessInfo;
invokeinterface org.apache.cassandra.db.rows.Row$Builder.addPrimaryKeyLivenessInfo:(Lorg/apache/cassandra/db/LivenessInfo;)V
2: aload 1
aload 0
invokeinterface org.apache.cassandra.db.rows.Row.deletion:()Lorg/apache/cassandra/db/rows/Row$Deletion;
invokeinterface org.apache.cassandra.db.rows.Row$Builder.addRowDeletion:(Lorg/apache/cassandra/db/rows/Row$Deletion;)V
3: aload 0
invokeinterface org.apache.cassandra.db.rows.Row.iterator:()Ljava/util/Iterator;
astore 3
goto 14
StackMap locals: org.apache.cassandra.db.rows.Row org.apache.cassandra.db.rows.Row$Builder top java.util.Iterator
StackMap stack:
4: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.ColumnData
astore 2
start local 2 5: aload 2
invokevirtual org.apache.cassandra.db.rows.ColumnData.column:()Lorg/apache/cassandra/config/ColumnDefinition;
invokevirtual org.apache.cassandra.config.ColumnDefinition.isSimple:()Z
ifeq 8
6: aload 1
aload 2
checkcast org.apache.cassandra.db.rows.Cell
invokeinterface org.apache.cassandra.db.rows.Row$Builder.addCell:(Lorg/apache/cassandra/db/rows/Cell;)V
7: goto 14
8: StackMap locals: org.apache.cassandra.db.rows.Row org.apache.cassandra.db.rows.Row$Builder org.apache.cassandra.db.rows.ColumnData java.util.Iterator
StackMap stack:
aload 2
checkcast org.apache.cassandra.db.rows.ComplexColumnData
astore 4
start local 4 9: aload 1
aload 4
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.column:()Lorg/apache/cassandra/config/ColumnDefinition;
aload 4
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.complexDeletion:()Lorg/apache/cassandra/db/DeletionTime;
invokeinterface org.apache.cassandra.db.rows.Row$Builder.addComplexDeletion:(Lorg/apache/cassandra/config/ColumnDefinition;Lorg/apache/cassandra/db/DeletionTime;)V
10: aload 4
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.iterator:()Ljava/util/Iterator;
astore 6
goto 13
StackMap locals: org.apache.cassandra.db.rows.Row org.apache.cassandra.db.rows.Row$Builder org.apache.cassandra.db.rows.ColumnData java.util.Iterator org.apache.cassandra.db.rows.ComplexColumnData top java.util.Iterator
StackMap stack:
11: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Cell
astore 5
start local 5 12: aload 1
aload 5
invokeinterface org.apache.cassandra.db.rows.Row$Builder.addCell:(Lorg/apache/cassandra/db/rows/Cell;)V
end local 5 13: StackMap locals:
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 11
end local 4 end local 2 14: StackMap locals: org.apache.cassandra.db.rows.Row org.apache.cassandra.db.rows.Row$Builder top java.util.Iterator
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
15: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 row Lorg/apache/cassandra/db/rows/Row;
0 16 1 builder Lorg/apache/cassandra/db/rows/Row$Builder;
5 14 2 cd Lorg/apache/cassandra/db/rows/ColumnData;
9 14 4 complexData Lorg/apache/cassandra/db/rows/ComplexColumnData;
12 13 5 cell Lorg/apache/cassandra/db/rows/Cell;
MethodParameters:
Name Flags
row
builder
public static org.apache.cassandra.db.rows.Row$SimpleBuilder simpleBuilder(org.apache.cassandra.config.CFMetaData, java.lang.Object[]);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;[Ljava/lang/Object;)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: new org.apache.cassandra.db.SimpleBuilders$RowBuilder
dup
aload 0
aload 1
invokespecial org.apache.cassandra.db.SimpleBuilders$RowBuilder.<init>:(Lorg/apache/cassandra/config/CFMetaData;[Ljava/lang/Object;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 metadata Lorg/apache/cassandra/config/CFMetaData;
0 1 1 clusteringValues [Ljava/lang/Object;
MethodParameters:
Name Flags
metadata
clusteringValues
public static int collectStats(org.apache.cassandra.db.rows.Row, org.apache.cassandra.db.partitions.PartitionStatisticsCollector);
descriptor: (Lorg/apache/cassandra/db/rows/Row;Lorg/apache/cassandra/db/partitions/PartitionStatisticsCollector;)I
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=4, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.db.rows.Rows.$assertionsDisabled:Z
ifne 1
aload 0
invokeinterface org.apache.cassandra.db.rows.Row.isEmpty:()Z
ifeq 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 1
aload 0
invokeinterface org.apache.cassandra.db.rows.Row.primaryKeyLivenessInfo:()Lorg/apache/cassandra/db/LivenessInfo;
invokeinterface org.apache.cassandra.db.partitions.PartitionStatisticsCollector.update:(Lorg/apache/cassandra/db/LivenessInfo;)V
2: aload 1
aload 0
invokeinterface org.apache.cassandra.db.rows.Row.deletion:()Lorg/apache/cassandra/db/rows/Row$Deletion;
invokevirtual org.apache.cassandra.db.rows.Row$Deletion.time:()Lorg/apache/cassandra/db/DeletionTime;
invokeinterface org.apache.cassandra.db.partitions.PartitionStatisticsCollector.update:(Lorg/apache/cassandra/db/DeletionTime;)V
3: new org.apache.cassandra.utils.WrappedInt
dup
iconst_0
invokespecial org.apache.cassandra.utils.WrappedInt.<init>:(I)V
astore 2
start local 2 4: new org.apache.cassandra.utils.WrappedInt
dup
iconst_0
invokespecial org.apache.cassandra.utils.WrappedInt.<init>:(I)V
astore 3
start local 3 5: aload 0
aload 2
aload 3
aload 1
invokedynamic accept(Lorg/apache/cassandra/utils/WrappedInt;Lorg/apache/cassandra/utils/WrappedInt;Lorg/apache/cassandra/db/partitions/PartitionStatisticsCollector;)Ljava/util/function/Consumer;
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;)V
org/apache/cassandra/db/rows/Rows.lambda$0(Lorg/apache/cassandra/utils/WrappedInt;Lorg/apache/cassandra/utils/WrappedInt;Lorg/apache/cassandra/db/partitions/PartitionStatisticsCollector;Lorg/apache/cassandra/db/rows/ColumnData;)V (6)
(Lorg/apache/cassandra/db/rows/ColumnData;)V
6: iconst_0
7: invokeinterface org.apache.cassandra.db.rows.Row.apply:(Ljava/util/function/Consumer;Z)V
8: aload 1
aload 2
invokevirtual org.apache.cassandra.utils.WrappedInt.get:()I
i2l
invokeinterface org.apache.cassandra.db.partitions.PartitionStatisticsCollector.updateColumnSetPerRow:(J)V
9: aload 3
invokevirtual org.apache.cassandra.utils.WrappedInt.get:()I
ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 row Lorg/apache/cassandra/db/rows/Row;
0 10 1 collector Lorg/apache/cassandra/db/partitions/PartitionStatisticsCollector;
4 10 2 columnCount Lorg/apache/cassandra/utils/WrappedInt;
5 10 3 cellCount Lorg/apache/cassandra/utils/WrappedInt;
MethodParameters:
Name Flags
row
collector
public static void diff(org.apache.cassandra.db.rows.RowDiffListener, org.apache.cassandra.db.rows.Row, org.apache.cassandra.db.rows.Row[]);
descriptor: (Lorg/apache/cassandra/db/rows/RowDiffListener;Lorg/apache/cassandra/db/rows/Row;[Lorg/apache/cassandra/db/rows/Row;)V
flags: (0x0089) ACC_PUBLIC, ACC_STATIC, ACC_VARARGS
Code:
stack=7, locals=11, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokeinterface org.apache.cassandra.db.rows.Row.clustering:()Lorg/apache/cassandra/db/Clustering;
astore 3
start local 3 1: aload 1
invokeinterface org.apache.cassandra.db.rows.Row.primaryKeyLivenessInfo:()Lorg/apache/cassandra/db/LivenessInfo;
invokevirtual org.apache.cassandra.db.LivenessInfo.isEmpty:()Z
ifeq 2
aconst_null
goto 3
StackMap locals: org.apache.cassandra.db.Clustering
StackMap stack:
2: aload 1
invokeinterface org.apache.cassandra.db.rows.Row.primaryKeyLivenessInfo:()Lorg/apache/cassandra/db/LivenessInfo;
StackMap locals:
StackMap stack: org.apache.cassandra.db.LivenessInfo
3: astore 4
start local 4 4: aload 1
invokeinterface org.apache.cassandra.db.rows.Row.deletion:()Lorg/apache/cassandra/db/rows/Row$Deletion;
invokevirtual org.apache.cassandra.db.rows.Row$Deletion.isLive:()Z
ifeq 5
aconst_null
goto 6
StackMap locals: org.apache.cassandra.db.LivenessInfo
StackMap stack:
5: aload 1
invokeinterface org.apache.cassandra.db.rows.Row.deletion:()Lorg/apache/cassandra/db/rows/Row$Deletion;
StackMap locals:
StackMap stack: org.apache.cassandra.db.rows.Row$Deletion
6: astore 5
start local 5 7: iconst_0
istore 6
start local 6 8: goto 23
9: StackMap locals: org.apache.cassandra.db.rows.Row$Deletion int
StackMap stack:
aload 2
iload 6
aaload
astore 7
start local 7 10: aload 7
ifnull 11
aload 7
invokeinterface org.apache.cassandra.db.rows.Row.primaryKeyLivenessInfo:()Lorg/apache/cassandra/db/LivenessInfo;
invokevirtual org.apache.cassandra.db.LivenessInfo.isEmpty:()Z
ifeq 12
StackMap locals: org.apache.cassandra.db.rows.Row
StackMap stack:
11: aconst_null
goto 13
StackMap locals:
StackMap stack:
12: aload 7
invokeinterface org.apache.cassandra.db.rows.Row.primaryKeyLivenessInfo:()Lorg/apache/cassandra/db/LivenessInfo;
StackMap locals:
StackMap stack: org.apache.cassandra.db.LivenessInfo
13: astore 8
start local 8 14: aload 7
ifnull 15
aload 7
invokeinterface org.apache.cassandra.db.rows.Row.deletion:()Lorg/apache/cassandra/db/rows/Row$Deletion;
invokevirtual org.apache.cassandra.db.rows.Row$Deletion.isLive:()Z
ifeq 16
StackMap locals: org.apache.cassandra.db.LivenessInfo
StackMap stack:
15: aconst_null
goto 17
StackMap locals:
StackMap stack:
16: aload 7
invokeinterface org.apache.cassandra.db.rows.Row.deletion:()Lorg/apache/cassandra/db/rows/Row$Deletion;
StackMap locals:
StackMap stack: org.apache.cassandra.db.rows.Row$Deletion
17: astore 9
start local 9 18: aload 4
ifnonnull 19
aload 8
ifnull 20
19: StackMap locals: org.apache.cassandra.db.rows.Row$Deletion
StackMap stack:
aload 0
iload 6
aload 3
aload 4
aload 8
invokeinterface org.apache.cassandra.db.rows.RowDiffListener.onPrimaryKeyLivenessInfo:(ILorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/db/LivenessInfo;Lorg/apache/cassandra/db/LivenessInfo;)V
20: StackMap locals:
StackMap stack:
aload 5
ifnonnull 21
aload 9
ifnull 22
21: StackMap locals:
StackMap stack:
aload 0
iload 6
aload 3
aload 5
aload 9
invokeinterface org.apache.cassandra.db.rows.RowDiffListener.onDeletion:(ILorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/db/rows/Row$Deletion;Lorg/apache/cassandra/db/rows/Row$Deletion;)V
end local 9 end local 8 end local 7 22: StackMap locals:
StackMap stack:
iinc 6 1
StackMap locals:
StackMap stack:
23: iload 6
aload 2
arraylength
if_icmplt 9
end local 6 24: new java.util.ArrayList
dup
iconst_1
aload 2
arraylength
iadd
invokespecial java.util.ArrayList.<init>:(I)V
astore 6
start local 6 25: aload 6
aload 1
invokeinterface org.apache.cassandra.db.rows.Row.iterator:()Ljava/util/Iterator;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
26: aload 2
dup
astore 10
arraylength
istore 9
iconst_0
istore 8
goto 32
StackMap locals: org.apache.cassandra.db.rows.RowDiffListener org.apache.cassandra.db.rows.Row org.apache.cassandra.db.rows.Row[] org.apache.cassandra.db.Clustering org.apache.cassandra.db.LivenessInfo org.apache.cassandra.db.rows.Row$Deletion java.util.List top int int org.apache.cassandra.db.rows.Row[]
StackMap stack:
27: aload 10
iload 8
aaload
astore 7
start local 7 28: aload 6
aload 7
ifnonnull 29
invokestatic java.util.Collections.emptyIterator:()Ljava/util/Iterator;
goto 30
StackMap locals: org.apache.cassandra.db.rows.RowDiffListener org.apache.cassandra.db.rows.Row org.apache.cassandra.db.rows.Row[] org.apache.cassandra.db.Clustering org.apache.cassandra.db.LivenessInfo org.apache.cassandra.db.rows.Row$Deletion java.util.List org.apache.cassandra.db.rows.Row int int org.apache.cassandra.db.rows.Row[]
StackMap stack: java.util.List
29: aload 7
invokeinterface org.apache.cassandra.db.rows.Row.iterator:()Ljava/util/Iterator;
StackMap locals: org.apache.cassandra.db.rows.RowDiffListener org.apache.cassandra.db.rows.Row org.apache.cassandra.db.rows.Row[] org.apache.cassandra.db.Clustering org.apache.cassandra.db.LivenessInfo org.apache.cassandra.db.rows.Row$Deletion java.util.List org.apache.cassandra.db.rows.Row int int org.apache.cassandra.db.rows.Row[]
StackMap stack: java.util.List java.util.Iterator
30: invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 7 31: iinc 8 1
StackMap locals: org.apache.cassandra.db.rows.RowDiffListener org.apache.cassandra.db.rows.Row org.apache.cassandra.db.rows.Row[] org.apache.cassandra.db.Clustering org.apache.cassandra.db.LivenessInfo org.apache.cassandra.db.rows.Row$Deletion java.util.List top int int org.apache.cassandra.db.rows.Row[]
StackMap stack:
32: iload 8
iload 9
if_icmplt 27
33: aload 6
getstatic org.apache.cassandra.db.rows.ColumnData.comparator:Ljava/util/Comparator;
new org.apache.cassandra.db.rows.Rows$1
dup
aload 2
aload 0
aload 3
invokespecial org.apache.cassandra.db.rows.Rows$1.<init>:([Lorg/apache/cassandra/db/rows/Row;Lorg/apache/cassandra/db/rows/RowDiffListener;Lorg/apache/cassandra/db/Clustering;)V
invokestatic org.apache.cassandra.utils.MergeIterator.get:(Ljava/util/List;Ljava/util/Comparator;Lorg/apache/cassandra/utils/MergeIterator$Reducer;)Lorg/apache/cassandra/utils/MergeIterator;
astore 7
start local 7 34: goto 36
35: StackMap locals: org.apache.cassandra.db.rows.RowDiffListener org.apache.cassandra.db.rows.Row org.apache.cassandra.db.rows.Row[] org.apache.cassandra.db.Clustering org.apache.cassandra.db.LivenessInfo org.apache.cassandra.db.rows.Row$Deletion java.util.List java.util.Iterator
StackMap stack:
aload 7
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
pop
36: StackMap locals:
StackMap stack:
aload 7
invokeinterface java.util.Iterator.hasNext:()Z
ifne 35
37: return
end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 38 0 diffListener Lorg/apache/cassandra/db/rows/RowDiffListener;
0 38 1 merged Lorg/apache/cassandra/db/rows/Row;
0 38 2 inputs [Lorg/apache/cassandra/db/rows/Row;
1 38 3 clustering Lorg/apache/cassandra/db/Clustering;
4 38 4 mergedInfo Lorg/apache/cassandra/db/LivenessInfo;
7 38 5 mergedDeletion Lorg/apache/cassandra/db/rows/Row$Deletion;
8 24 6 i I
10 22 7 input Lorg/apache/cassandra/db/rows/Row;
14 22 8 inputInfo Lorg/apache/cassandra/db/LivenessInfo;
18 22 9 inputDeletion Lorg/apache/cassandra/db/rows/Row$Deletion;
25 38 6 inputIterators Ljava/util/List<Ljava/util/Iterator<Lorg/apache/cassandra/db/rows/ColumnData;>;>;
28 31 7 row Lorg/apache/cassandra/db/rows/Row;
34 38 7 iter Ljava/util/Iterator<*>;
MethodParameters:
Name Flags
diffListener
merged
inputs
public static org.apache.cassandra.db.rows.Row merge(org.apache.cassandra.db.rows.Row, org.apache.cassandra.db.rows.Row, int);
descriptor: (Lorg/apache/cassandra/db/rows/Row;Lorg/apache/cassandra/db/rows/Row;I)Lorg/apache/cassandra/db/rows/Row;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: invokestatic org.apache.cassandra.db.rows.BTreeRow.sortedBuilder:()Lorg/apache/cassandra/db/rows/Row$Builder;
astore 3
start local 3 1: aload 0
aload 1
aload 3
iload 2
invokestatic org.apache.cassandra.db.rows.Rows.merge:(Lorg/apache/cassandra/db/rows/Row;Lorg/apache/cassandra/db/rows/Row;Lorg/apache/cassandra/db/rows/Row$Builder;I)J
pop2
2: aload 3
invokeinterface org.apache.cassandra.db.rows.Row$Builder.build:()Lorg/apache/cassandra/db/rows/Row;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 row1 Lorg/apache/cassandra/db/rows/Row;
0 3 1 row2 Lorg/apache/cassandra/db/rows/Row;
0 3 2 nowInSec I
1 3 3 builder Lorg/apache/cassandra/db/rows/Row$Builder;
MethodParameters:
Name Flags
row1
row2
nowInSec
public static long merge(org.apache.cassandra.db.rows.Row, org.apache.cassandra.db.rows.Row, org.apache.cassandra.db.rows.Row$Builder, int);
descriptor: (Lorg/apache/cassandra/db/rows/Row;Lorg/apache/cassandra/db/rows/Row;Lorg/apache/cassandra/db/rows/Row$Builder;I)J
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=8, locals=27, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokeinterface org.apache.cassandra.db.rows.Row.clustering:()Lorg/apache/cassandra/db/Clustering;
astore 4
start local 4 1: aload 2
aload 4
invokeinterface org.apache.cassandra.db.rows.Row$Builder.newRow:(Lorg/apache/cassandra/db/Clustering;)V
2: aload 0
invokeinterface org.apache.cassandra.db.rows.Row.primaryKeyLivenessInfo:()Lorg/apache/cassandra/db/LivenessInfo;
astore 5
start local 5 3: aload 1
invokeinterface org.apache.cassandra.db.rows.Row.primaryKeyLivenessInfo:()Lorg/apache/cassandra/db/LivenessInfo;
astore 6
start local 6 4: aload 5
aload 6
invokevirtual org.apache.cassandra.db.LivenessInfo.supersedes:(Lorg/apache/cassandra/db/LivenessInfo;)Z
ifeq 5
aload 5
goto 6
StackMap locals: org.apache.cassandra.db.Clustering org.apache.cassandra.db.LivenessInfo org.apache.cassandra.db.LivenessInfo
StackMap stack:
5: aload 6
StackMap locals:
StackMap stack: org.apache.cassandra.db.LivenessInfo
6: astore 7
start local 7 7: aload 5
invokevirtual org.apache.cassandra.db.LivenessInfo.timestamp:()J
aload 7
invokevirtual org.apache.cassandra.db.LivenessInfo.timestamp:()J
lsub
invokestatic java.lang.Math.abs:(J)J
lstore 8
start local 8 8: aload 0
invokeinterface org.apache.cassandra.db.rows.Row.deletion:()Lorg/apache/cassandra/db/rows/Row$Deletion;
aload 1
invokeinterface org.apache.cassandra.db.rows.Row.deletion:()Lorg/apache/cassandra/db/rows/Row$Deletion;
invokevirtual org.apache.cassandra.db.rows.Row$Deletion.supersedes:(Lorg/apache/cassandra/db/rows/Row$Deletion;)Z
ifeq 9
aload 0
invokeinterface org.apache.cassandra.db.rows.Row.deletion:()Lorg/apache/cassandra/db/rows/Row$Deletion;
goto 10
StackMap locals: org.apache.cassandra.db.LivenessInfo long
StackMap stack:
9: aload 1
invokeinterface org.apache.cassandra.db.rows.Row.deletion:()Lorg/apache/cassandra/db/rows/Row$Deletion;
StackMap locals:
StackMap stack: org.apache.cassandra.db.rows.Row$Deletion
10: astore 10
start local 10 11: aload 10
aload 7
invokevirtual org.apache.cassandra.db.rows.Row$Deletion.deletes:(Lorg/apache/cassandra/db/LivenessInfo;)Z
ifeq 13
12: getstatic org.apache.cassandra.db.LivenessInfo.EMPTY:Lorg/apache/cassandra/db/LivenessInfo;
astore 7
goto 15
13: StackMap locals: org.apache.cassandra.db.rows.Row$Deletion
StackMap stack:
aload 10
aload 7
invokevirtual org.apache.cassandra.db.rows.Row$Deletion.isShadowedBy:(Lorg/apache/cassandra/db/LivenessInfo;)Z
ifeq 15
14: getstatic org.apache.cassandra.db.rows.Row$Deletion.LIVE:Lorg/apache/cassandra/db/rows/Row$Deletion;
astore 10
15: StackMap locals:
StackMap stack:
aload 2
aload 7
invokeinterface org.apache.cassandra.db.rows.Row$Builder.addPrimaryKeyLivenessInfo:(Lorg/apache/cassandra/db/LivenessInfo;)V
16: aload 2
aload 10
invokeinterface org.apache.cassandra.db.rows.Row$Builder.addRowDeletion:(Lorg/apache/cassandra/db/rows/Row$Deletion;)V
17: aload 10
invokevirtual org.apache.cassandra.db.rows.Row$Deletion.time:()Lorg/apache/cassandra/db/DeletionTime;
astore 11
start local 11 18: aload 0
invokeinterface org.apache.cassandra.db.rows.Row.iterator:()Ljava/util/Iterator;
astore 12
start local 12 19: aload 1
invokeinterface org.apache.cassandra.db.rows.Row.iterator:()Ljava/util/Iterator;
astore 13
start local 13 20: aload 12
invokeinterface java.util.Iterator.hasNext:()Z
ifeq 21
aload 12
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.ColumnData
goto 22
StackMap locals: org.apache.cassandra.db.DeletionTime java.util.Iterator java.util.Iterator
StackMap stack:
21: aconst_null
StackMap locals:
StackMap stack: org.apache.cassandra.db.rows.ColumnData
22: astore 14
start local 14 23: aload 13
invokeinterface java.util.Iterator.hasNext:()Z
ifeq 24
aload 13
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.ColumnData
goto 25
StackMap locals: org.apache.cassandra.db.rows.ColumnData
StackMap stack:
24: aconst_null
StackMap locals:
StackMap stack: org.apache.cassandra.db.rows.ColumnData
25: astore 15
start local 15 26: goto 70
27: StackMap locals: org.apache.cassandra.db.rows.ColumnData
StackMap stack:
aload 14
ifnonnull 28
iconst_1
goto 30
StackMap locals:
StackMap stack:
28: aload 15
ifnonnull 29
iconst_m1
goto 30
StackMap locals:
StackMap stack:
29: aload 14
getfield org.apache.cassandra.db.rows.ColumnData.column:Lorg/apache/cassandra/config/ColumnDefinition;
aload 15
getfield org.apache.cassandra.db.rows.ColumnData.column:Lorg/apache/cassandra/config/ColumnDefinition;
invokevirtual org.apache.cassandra.config.ColumnDefinition.compareTo:(Lorg/apache/cassandra/config/ColumnDefinition;)I
StackMap locals:
StackMap stack: int
30: istore 16
start local 16 31: iload 16
ifgt 32
aload 14
goto 33
StackMap locals: int
StackMap stack:
32: aconst_null
StackMap locals:
StackMap stack: org.apache.cassandra.db.rows.ColumnData
33: astore 17
start local 17 34: iload 16
iflt 35
aload 15
goto 36
StackMap locals: org.apache.cassandra.db.rows.ColumnData
StackMap stack:
35: aconst_null
StackMap locals:
StackMap stack: org.apache.cassandra.db.rows.ColumnData
36: astore 18
start local 18 37: aload 17
aload 18
invokestatic org.apache.cassandra.db.rows.Rows.getColumnDefinition:(Lorg/apache/cassandra/db/rows/ColumnData;Lorg/apache/cassandra/db/rows/ColumnData;)Lorg/apache/cassandra/config/ColumnDefinition;
astore 19
start local 19 38: aload 19
invokevirtual org.apache.cassandra.config.ColumnDefinition.isSimple:()Z
ifeq 41
39: lload 8
aload 17
checkcast org.apache.cassandra.db.rows.Cell
aload 18
checkcast org.apache.cassandra.db.rows.Cell
aload 11
aload 2
iload 3
invokestatic org.apache.cassandra.db.rows.Cells.reconcile:(Lorg/apache/cassandra/db/rows/Cell;Lorg/apache/cassandra/db/rows/Cell;Lorg/apache/cassandra/db/DeletionTime;Lorg/apache/cassandra/db/rows/Row$Builder;I)J
invokestatic java.lang.Math.min:(JJ)J
lstore 8
40: goto 62
41: StackMap locals: org.apache.cassandra.db.rows.ColumnData org.apache.cassandra.config.ColumnDefinition
StackMap stack:
aload 17
checkcast org.apache.cassandra.db.rows.ComplexColumnData
astore 20
start local 20 42: aload 18
checkcast org.apache.cassandra.db.rows.ComplexColumnData
astore 21
start local 21 43: aload 20
ifnonnull 44
getstatic org.apache.cassandra.db.DeletionTime.LIVE:Lorg/apache/cassandra/db/DeletionTime;
goto 45
StackMap locals: org.apache.cassandra.db.rows.ComplexColumnData org.apache.cassandra.db.rows.ComplexColumnData
StackMap stack:
44: aload 20
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.complexDeletion:()Lorg/apache/cassandra/db/DeletionTime;
StackMap locals:
StackMap stack: org.apache.cassandra.db.DeletionTime
45: astore 22
start local 22 46: aload 21
ifnonnull 47
getstatic org.apache.cassandra.db.DeletionTime.LIVE:Lorg/apache/cassandra/db/DeletionTime;
goto 48
StackMap locals: org.apache.cassandra.db.DeletionTime
StackMap stack:
47: aload 21
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.complexDeletion:()Lorg/apache/cassandra/db/DeletionTime;
StackMap locals:
StackMap stack: org.apache.cassandra.db.DeletionTime
48: astore 23
start local 23 49: aload 22
aload 23
invokevirtual org.apache.cassandra.db.DeletionTime.supersedes:(Lorg/apache/cassandra/db/DeletionTime;)Z
ifeq 50
aload 22
goto 51
StackMap locals: org.apache.cassandra.db.DeletionTime
StackMap stack:
50: aload 23
StackMap locals:
StackMap stack: org.apache.cassandra.db.DeletionTime
51: astore 24
start local 24 52: aload 24
aload 11
invokevirtual org.apache.cassandra.db.DeletionTime.supersedes:(Lorg/apache/cassandra/db/DeletionTime;)Z
ifeq 54
53: aload 2
aload 19
aload 24
invokeinterface org.apache.cassandra.db.rows.Row$Builder.addComplexDeletion:(Lorg/apache/cassandra/config/ColumnDefinition;Lorg/apache/cassandra/db/DeletionTime;)V
goto 55
54: StackMap locals: org.apache.cassandra.db.DeletionTime
StackMap stack:
aload 11
astore 24
55: StackMap locals:
StackMap stack:
aload 20
ifnonnull 56
aconst_null
goto 57
StackMap locals:
StackMap stack:
56: aload 20
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.iterator:()Ljava/util/Iterator;
StackMap locals:
StackMap stack: java.util.Iterator
57: astore 25
start local 25 58: aload 21
ifnonnull 59
aconst_null
goto 60
StackMap locals: java.util.Iterator
StackMap stack:
59: aload 21
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.iterator:()Ljava/util/Iterator;
StackMap locals:
StackMap stack: java.util.Iterator
60: astore 26
start local 26 61: lload 8
aload 19
aload 25
aload 26
aload 24
aload 2
iload 3
invokestatic org.apache.cassandra.db.rows.Cells.reconcileComplex:(Lorg/apache/cassandra/config/ColumnDefinition;Ljava/util/Iterator;Ljava/util/Iterator;Lorg/apache/cassandra/db/DeletionTime;Lorg/apache/cassandra/db/rows/Row$Builder;I)J
invokestatic java.lang.Math.min:(JJ)J
lstore 8
end local 26 end local 25 end local 24 end local 23 end local 22 end local 21 end local 20 62: StackMap locals: org.apache.cassandra.db.rows.Row org.apache.cassandra.db.rows.Row org.apache.cassandra.db.rows.Row$Builder int org.apache.cassandra.db.Clustering org.apache.cassandra.db.LivenessInfo org.apache.cassandra.db.LivenessInfo org.apache.cassandra.db.LivenessInfo long org.apache.cassandra.db.rows.Row$Deletion org.apache.cassandra.db.DeletionTime java.util.Iterator java.util.Iterator org.apache.cassandra.db.rows.ColumnData org.apache.cassandra.db.rows.ColumnData int org.apache.cassandra.db.rows.ColumnData org.apache.cassandra.db.rows.ColumnData org.apache.cassandra.config.ColumnDefinition
StackMap stack:
aload 17
ifnull 66
63: aload 12
invokeinterface java.util.Iterator.hasNext:()Z
ifeq 64
aload 12
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.ColumnData
goto 65
StackMap locals:
StackMap stack:
64: aconst_null
StackMap locals:
StackMap stack: org.apache.cassandra.db.rows.ColumnData
65: astore 14
66: StackMap locals:
StackMap stack:
aload 18
ifnull 70
67: aload 13
invokeinterface java.util.Iterator.hasNext:()Z
ifeq 68
aload 13
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.ColumnData
goto 69
StackMap locals:
StackMap stack:
68: aconst_null
StackMap locals:
StackMap stack: org.apache.cassandra.db.rows.ColumnData
69: astore 15
end local 19 end local 18 end local 17 end local 16 70: StackMap locals: org.apache.cassandra.db.rows.Row org.apache.cassandra.db.rows.Row org.apache.cassandra.db.rows.Row$Builder int org.apache.cassandra.db.Clustering org.apache.cassandra.db.LivenessInfo org.apache.cassandra.db.LivenessInfo org.apache.cassandra.db.LivenessInfo long org.apache.cassandra.db.rows.Row$Deletion org.apache.cassandra.db.DeletionTime java.util.Iterator java.util.Iterator org.apache.cassandra.db.rows.ColumnData org.apache.cassandra.db.rows.ColumnData
StackMap stack:
aload 14
ifnull 71
iconst_1
goto 72
StackMap locals:
StackMap stack:
71: iconst_0
StackMap locals:
StackMap stack: int
72: aload 15
ifnull 73
iconst_1
goto 74
StackMap locals:
StackMap stack: int
73: iconst_0
StackMap locals: org.apache.cassandra.db.rows.Row org.apache.cassandra.db.rows.Row org.apache.cassandra.db.rows.Row$Builder int org.apache.cassandra.db.Clustering org.apache.cassandra.db.LivenessInfo org.apache.cassandra.db.LivenessInfo org.apache.cassandra.db.LivenessInfo long org.apache.cassandra.db.rows.Row$Deletion org.apache.cassandra.db.DeletionTime java.util.Iterator java.util.Iterator org.apache.cassandra.db.rows.ColumnData org.apache.cassandra.db.rows.ColumnData
StackMap stack: int int
74: ior
ifne 27
75: lload 8
lreturn
end local 15 end local 14 end local 13 end local 12 end local 11 end local 10 end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 76 0 existing Lorg/apache/cassandra/db/rows/Row;
0 76 1 update Lorg/apache/cassandra/db/rows/Row;
0 76 2 builder Lorg/apache/cassandra/db/rows/Row$Builder;
0 76 3 nowInSec I
1 76 4 clustering Lorg/apache/cassandra/db/Clustering;
3 76 5 existingInfo Lorg/apache/cassandra/db/LivenessInfo;
4 76 6 updateInfo Lorg/apache/cassandra/db/LivenessInfo;
7 76 7 mergedInfo Lorg/apache/cassandra/db/LivenessInfo;
8 76 8 timeDelta J
11 76 10 rowDeletion Lorg/apache/cassandra/db/rows/Row$Deletion;
18 76 11 deletion Lorg/apache/cassandra/db/DeletionTime;
19 76 12 a Ljava/util/Iterator<Lorg/apache/cassandra/db/rows/ColumnData;>;
20 76 13 b Ljava/util/Iterator<Lorg/apache/cassandra/db/rows/ColumnData;>;
23 76 14 nexta Lorg/apache/cassandra/db/rows/ColumnData;
26 76 15 nextb Lorg/apache/cassandra/db/rows/ColumnData;
31 70 16 comparison I
34 70 17 cura Lorg/apache/cassandra/db/rows/ColumnData;
37 70 18 curb Lorg/apache/cassandra/db/rows/ColumnData;
38 70 19 column Lorg/apache/cassandra/config/ColumnDefinition;
42 62 20 existingData Lorg/apache/cassandra/db/rows/ComplexColumnData;
43 62 21 updateData Lorg/apache/cassandra/db/rows/ComplexColumnData;
46 62 22 existingDt Lorg/apache/cassandra/db/DeletionTime;
49 62 23 updateDt Lorg/apache/cassandra/db/DeletionTime;
52 62 24 maxDt Lorg/apache/cassandra/db/DeletionTime;
58 62 25 existingCells Ljava/util/Iterator<Lorg/apache/cassandra/db/rows/Cell;>;
61 62 26 updateCells Ljava/util/Iterator<Lorg/apache/cassandra/db/rows/Cell;>;
MethodParameters:
Name Flags
existing
update
builder
nowInSec
public static org.apache.cassandra.db.rows.Row removeShadowedCells(org.apache.cassandra.db.rows.Row, org.apache.cassandra.db.rows.Row, org.apache.cassandra.db.DeletionTime, int);
descriptor: (Lorg/apache/cassandra/db/rows/Row;Lorg/apache/cassandra/db/rows/Row;Lorg/apache/cassandra/db/DeletionTime;I)Lorg/apache/cassandra/db/rows/Row;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=24, args_size=4
start local 0 start local 1 start local 2 start local 3 0: invokestatic org.apache.cassandra.db.rows.BTreeRow.sortedBuilder:()Lorg/apache/cassandra/db/rows/Row$Builder;
astore 4
start local 4 1: aload 0
invokeinterface org.apache.cassandra.db.rows.Row.clustering:()Lorg/apache/cassandra/db/Clustering;
astore 5
start local 5 2: aload 4
aload 5
invokeinterface org.apache.cassandra.db.rows.Row$Builder.newRow:(Lorg/apache/cassandra/db/Clustering;)V
3: aload 1
invokeinterface org.apache.cassandra.db.rows.Row.deletion:()Lorg/apache/cassandra/db/rows/Row$Deletion;
invokevirtual org.apache.cassandra.db.rows.Row$Deletion.time:()Lorg/apache/cassandra/db/DeletionTime;
astore 6
start local 6 4: aload 2
aload 6
invokevirtual org.apache.cassandra.db.DeletionTime.supersedes:(Lorg/apache/cassandra/db/DeletionTime;)Z
ifeq 6
5: aload 2
astore 6
6: StackMap locals: org.apache.cassandra.db.rows.Row$Builder org.apache.cassandra.db.Clustering org.apache.cassandra.db.DeletionTime
StackMap stack:
aload 0
invokeinterface org.apache.cassandra.db.rows.Row.primaryKeyLivenessInfo:()Lorg/apache/cassandra/db/LivenessInfo;
astore 7
start local 7 7: aload 6
aload 7
invokevirtual org.apache.cassandra.db.DeletionTime.deletes:(Lorg/apache/cassandra/db/LivenessInfo;)Z
ifne 9
8: aload 4
aload 7
invokeinterface org.apache.cassandra.db.rows.Row$Builder.addPrimaryKeyLivenessInfo:(Lorg/apache/cassandra/db/LivenessInfo;)V
9: StackMap locals: org.apache.cassandra.db.LivenessInfo
StackMap stack:
aload 0
invokeinterface org.apache.cassandra.db.rows.Row.deletion:()Lorg/apache/cassandra/db/rows/Row$Deletion;
astore 8
start local 8 10: aload 6
aload 8
invokevirtual org.apache.cassandra.db.rows.Row$Deletion.time:()Lorg/apache/cassandra/db/DeletionTime;
invokevirtual org.apache.cassandra.db.DeletionTime.supersedes:(Lorg/apache/cassandra/db/DeletionTime;)Z
ifne 12
11: aload 4
aload 8
invokeinterface org.apache.cassandra.db.rows.Row$Builder.addRowDeletion:(Lorg/apache/cassandra/db/rows/Row$Deletion;)V
12: StackMap locals: org.apache.cassandra.db.rows.Row$Deletion
StackMap stack:
aload 0
invokeinterface org.apache.cassandra.db.rows.Row.iterator:()Ljava/util/Iterator;
astore 9
start local 9 13: aload 1
invokeinterface org.apache.cassandra.db.rows.Row.iterator:()Ljava/util/Iterator;
astore 10
start local 10 14: aload 9
invokeinterface java.util.Iterator.hasNext:()Z
ifeq 15
aload 9
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.ColumnData
goto 16
StackMap locals: java.util.Iterator java.util.Iterator
StackMap stack:
15: aconst_null
StackMap locals:
StackMap stack: org.apache.cassandra.db.rows.ColumnData
16: astore 11
start local 11 17: aload 10
invokeinterface java.util.Iterator.hasNext:()Z
ifeq 18
aload 10
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.ColumnData
goto 19
StackMap locals: org.apache.cassandra.db.rows.ColumnData
StackMap stack:
18: aconst_null
StackMap locals:
StackMap stack: org.apache.cassandra.db.rows.ColumnData
19: astore 12
start local 12 20: goto 61
21: StackMap locals: org.apache.cassandra.db.rows.ColumnData
StackMap stack:
aload 12
ifnonnull 22
iconst_m1
goto 23
StackMap locals:
StackMap stack:
22: aload 11
getfield org.apache.cassandra.db.rows.ColumnData.column:Lorg/apache/cassandra/config/ColumnDefinition;
aload 12
getfield org.apache.cassandra.db.rows.ColumnData.column:Lorg/apache/cassandra/config/ColumnDefinition;
invokevirtual org.apache.cassandra.config.ColumnDefinition.compareTo:(Lorg/apache/cassandra/config/ColumnDefinition;)I
StackMap locals:
StackMap stack: int
23: istore 13
start local 13 24: iload 13
ifgt 58
25: aload 11
astore 14
start local 14 26: aload 14
getfield org.apache.cassandra.db.rows.ColumnData.column:Lorg/apache/cassandra/config/ColumnDefinition;
astore 15
start local 15 27: iload 13
ifne 28
aload 12
goto 29
StackMap locals: int org.apache.cassandra.db.rows.ColumnData org.apache.cassandra.config.ColumnDefinition
StackMap stack:
28: aconst_null
StackMap locals:
StackMap stack: org.apache.cassandra.db.rows.ColumnData
29: astore 16
start local 16 30: aload 15
invokevirtual org.apache.cassandra.config.ColumnDefinition.isSimple:()Z
ifeq 33
31: aload 14
checkcast org.apache.cassandra.db.rows.Cell
aload 16
checkcast org.apache.cassandra.db.rows.Cell
aload 6
aload 4
iload 3
invokestatic org.apache.cassandra.db.rows.Cells.addNonShadowed:(Lorg/apache/cassandra/db/rows/Cell;Lorg/apache/cassandra/db/rows/Cell;Lorg/apache/cassandra/db/DeletionTime;Lorg/apache/cassandra/db/rows/Row$Builder;I)V
32: goto 50
33: StackMap locals: org.apache.cassandra.db.rows.ColumnData
StackMap stack:
aload 14
checkcast org.apache.cassandra.db.rows.ComplexColumnData
astore 17
start local 17 34: aload 16
checkcast org.apache.cassandra.db.rows.ComplexColumnData
astore 18
start local 18 35: aload 17
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.complexDeletion:()Lorg/apache/cassandra/db/DeletionTime;
astore 19
start local 19 36: aload 18
ifnonnull 37
getstatic org.apache.cassandra.db.DeletionTime.LIVE:Lorg/apache/cassandra/db/DeletionTime;
goto 38
StackMap locals: org.apache.cassandra.db.rows.ComplexColumnData org.apache.cassandra.db.rows.ComplexColumnData org.apache.cassandra.db.DeletionTime
StackMap stack:
37: aload 18
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.complexDeletion:()Lorg/apache/cassandra/db/DeletionTime;
StackMap locals:
StackMap stack: org.apache.cassandra.db.DeletionTime
38: astore 20
start local 20 39: aload 20
aload 6
invokevirtual org.apache.cassandra.db.DeletionTime.supersedes:(Lorg/apache/cassandra/db/DeletionTime;)Z
ifeq 40
aload 20
goto 41
StackMap locals: org.apache.cassandra.db.DeletionTime
StackMap stack:
40: aload 6
StackMap locals:
StackMap stack: org.apache.cassandra.db.DeletionTime
41: astore 21
start local 21 42: aload 19
aload 21
invokevirtual org.apache.cassandra.db.DeletionTime.supersedes:(Lorg/apache/cassandra/db/DeletionTime;)Z
ifeq 45
43: aload 4
aload 15
aload 19
invokeinterface org.apache.cassandra.db.rows.Row$Builder.addComplexDeletion:(Lorg/apache/cassandra/config/ColumnDefinition;Lorg/apache/cassandra/db/DeletionTime;)V
44: aload 19
astore 21
45: StackMap locals: org.apache.cassandra.db.DeletionTime
StackMap stack:
aload 17
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.iterator:()Ljava/util/Iterator;
astore 22
start local 22 46: aload 18
ifnonnull 47
aconst_null
goto 48
StackMap locals: java.util.Iterator
StackMap stack:
47: aload 18
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.iterator:()Ljava/util/Iterator;
StackMap locals:
StackMap stack: java.util.Iterator
48: astore 23
start local 23 49: aload 15
aload 22
aload 23
aload 21
aload 4
iload 3
invokestatic org.apache.cassandra.db.rows.Cells.addNonShadowedComplex:(Lorg/apache/cassandra/config/ColumnDefinition;Ljava/util/Iterator;Ljava/util/Iterator;Lorg/apache/cassandra/db/DeletionTime;Lorg/apache/cassandra/db/rows/Row$Builder;I)V
end local 23 end local 22 end local 21 end local 20 end local 19 end local 18 end local 17 50: StackMap locals: org.apache.cassandra.db.rows.Row org.apache.cassandra.db.rows.Row org.apache.cassandra.db.DeletionTime int org.apache.cassandra.db.rows.Row$Builder org.apache.cassandra.db.Clustering org.apache.cassandra.db.DeletionTime org.apache.cassandra.db.LivenessInfo org.apache.cassandra.db.rows.Row$Deletion java.util.Iterator java.util.Iterator org.apache.cassandra.db.rows.ColumnData org.apache.cassandra.db.rows.ColumnData int org.apache.cassandra.db.rows.ColumnData org.apache.cassandra.config.ColumnDefinition org.apache.cassandra.db.rows.ColumnData
StackMap stack:
aload 9
invokeinterface java.util.Iterator.hasNext:()Z
ifeq 51
aload 9
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.ColumnData
goto 52
StackMap locals:
StackMap stack:
51: aconst_null
StackMap locals:
StackMap stack: org.apache.cassandra.db.rows.ColumnData
52: astore 11
53: aload 16
ifnull 61
54: aload 10
invokeinterface java.util.Iterator.hasNext:()Z
ifeq 55
aload 10
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.ColumnData
goto 56
StackMap locals:
StackMap stack:
55: aconst_null
StackMap locals:
StackMap stack: org.apache.cassandra.db.rows.ColumnData
56: astore 12
end local 16 end local 15 end local 14 57: goto 61
58: StackMap locals:
StackMap stack:
aload 10
invokeinterface java.util.Iterator.hasNext:()Z
ifeq 59
aload 10
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.ColumnData
goto 60
StackMap locals:
StackMap stack:
59: aconst_null
StackMap locals:
StackMap stack: org.apache.cassandra.db.rows.ColumnData
60: astore 12
end local 13 61: StackMap locals:
StackMap stack:
aload 11
ifnonnull 21
62: aload 4
invokeinterface org.apache.cassandra.db.rows.Row$Builder.build:()Lorg/apache/cassandra/db/rows/Row;
astore 13
start local 13 63: aload 13
ifnull 64
aload 13
invokeinterface org.apache.cassandra.db.rows.Row.isEmpty:()Z
ifne 64
aload 13
goto 65
StackMap locals: org.apache.cassandra.db.rows.Row
StackMap stack:
64: aconst_null
StackMap locals:
StackMap stack: org.apache.cassandra.db.rows.Row
65: areturn
end local 13 end local 12 end local 11 end local 10 end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 66 0 existing Lorg/apache/cassandra/db/rows/Row;
0 66 1 update Lorg/apache/cassandra/db/rows/Row;
0 66 2 rangeDeletion Lorg/apache/cassandra/db/DeletionTime;
0 66 3 nowInSec I
1 66 4 builder Lorg/apache/cassandra/db/rows/Row$Builder;
2 66 5 clustering Lorg/apache/cassandra/db/Clustering;
4 66 6 deletion Lorg/apache/cassandra/db/DeletionTime;
7 66 7 existingInfo Lorg/apache/cassandra/db/LivenessInfo;
10 66 8 rowDeletion Lorg/apache/cassandra/db/rows/Row$Deletion;
13 66 9 a Ljava/util/Iterator<Lorg/apache/cassandra/db/rows/ColumnData;>;
14 66 10 b Ljava/util/Iterator<Lorg/apache/cassandra/db/rows/ColumnData;>;
17 66 11 nexta Lorg/apache/cassandra/db/rows/ColumnData;
20 66 12 nextb Lorg/apache/cassandra/db/rows/ColumnData;
24 61 13 comparison I
26 57 14 cura Lorg/apache/cassandra/db/rows/ColumnData;
27 57 15 column Lorg/apache/cassandra/config/ColumnDefinition;
30 57 16 curb Lorg/apache/cassandra/db/rows/ColumnData;
34 50 17 existingData Lorg/apache/cassandra/db/rows/ComplexColumnData;
35 50 18 updateData Lorg/apache/cassandra/db/rows/ComplexColumnData;
36 50 19 existingDt Lorg/apache/cassandra/db/DeletionTime;
39 50 20 updateDt Lorg/apache/cassandra/db/DeletionTime;
42 50 21 maxDt Lorg/apache/cassandra/db/DeletionTime;
46 50 22 existingCells Ljava/util/Iterator<Lorg/apache/cassandra/db/rows/Cell;>;
49 50 23 updateCells Ljava/util/Iterator<Lorg/apache/cassandra/db/rows/Cell;>;
63 66 13 row Lorg/apache/cassandra/db/rows/Row;
MethodParameters:
Name Flags
existing
update
rangeDeletion
nowInSec
private static org.apache.cassandra.config.ColumnDefinition getColumnDefinition(org.apache.cassandra.db.rows.ColumnData, org.apache.cassandra.db.rows.ColumnData);
descriptor: (Lorg/apache/cassandra/db/rows/ColumnData;Lorg/apache/cassandra/db/rows/ColumnData;)Lorg/apache/cassandra/config/ColumnDefinition;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
ifnonnull 2
1: aload 1
getfield org.apache.cassandra.db.rows.ColumnData.column:Lorg/apache/cassandra/config/ColumnDefinition;
areturn
2: StackMap locals:
StackMap stack:
aload 1
ifnonnull 4
3: aload 0
getfield org.apache.cassandra.db.rows.ColumnData.column:Lorg/apache/cassandra/config/ColumnDefinition;
areturn
4: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.db.rows.AbstractTypeVersionComparator.INSTANCE:Ljava/util/Comparator;
aload 0
getfield org.apache.cassandra.db.rows.ColumnData.column:Lorg/apache/cassandra/config/ColumnDefinition;
getfield org.apache.cassandra.config.ColumnDefinition.type:Lorg/apache/cassandra/db/marshal/AbstractType;
aload 1
getfield org.apache.cassandra.db.rows.ColumnData.column:Lorg/apache/cassandra/config/ColumnDefinition;
getfield org.apache.cassandra.config.ColumnDefinition.type:Lorg/apache/cassandra/db/marshal/AbstractType;
invokeinterface java.util.Comparator.compare:(Ljava/lang/Object;Ljava/lang/Object;)I
iflt 6
5: aload 0
getfield org.apache.cassandra.db.rows.ColumnData.column:Lorg/apache/cassandra/config/ColumnDefinition;
areturn
6: StackMap locals:
StackMap stack:
aload 1
getfield org.apache.cassandra.db.rows.ColumnData.column:Lorg/apache/cassandra/config/ColumnDefinition;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 cura Lorg/apache/cassandra/db/rows/ColumnData;
0 7 1 curb Lorg/apache/cassandra/db/rows/ColumnData;
MethodParameters:
Name Flags
cura
curb
private static void lambda$0(org.apache.cassandra.utils.WrappedInt, org.apache.cassandra.utils.WrappedInt, org.apache.cassandra.db.partitions.PartitionStatisticsCollector, org.apache.cassandra.db.rows.ColumnData);
descriptor: (Lorg/apache/cassandra/utils/WrappedInt;Lorg/apache/cassandra/utils/WrappedInt;Lorg/apache/cassandra/db/partitions/PartitionStatisticsCollector;Lorg/apache/cassandra/db/rows/ColumnData;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=7, args_size=4
start local 3 0: aload 3
invokevirtual org.apache.cassandra.db.rows.ColumnData.column:()Lorg/apache/cassandra/config/ColumnDefinition;
invokevirtual org.apache.cassandra.config.ColumnDefinition.isSimple:()Z
ifeq 5
1: aload 0
invokevirtual org.apache.cassandra.utils.WrappedInt.increment:()V
2: aload 1
invokevirtual org.apache.cassandra.utils.WrappedInt.increment:()V
3: aload 3
checkcast org.apache.cassandra.db.rows.Cell
aload 2
invokestatic org.apache.cassandra.db.rows.Cells.collectStats:(Lorg/apache/cassandra/db/rows/Cell;Lorg/apache/cassandra/db/partitions/PartitionStatisticsCollector;)V
4: goto 14
5: StackMap locals:
StackMap stack:
aload 3
checkcast org.apache.cassandra.db.rows.ComplexColumnData
astore 4
start local 4 6: aload 2
aload 4
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.complexDeletion:()Lorg/apache/cassandra/db/DeletionTime;
invokeinterface org.apache.cassandra.db.partitions.PartitionStatisticsCollector.update:(Lorg/apache/cassandra/db/DeletionTime;)V
7: aload 4
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.hasCells:()Z
ifeq 14
8: aload 0
invokevirtual org.apache.cassandra.utils.WrappedInt.increment:()V
9: aload 4
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.iterator:()Ljava/util/Iterator;
astore 6
goto 13
StackMap locals: org.apache.cassandra.utils.WrappedInt org.apache.cassandra.utils.WrappedInt org.apache.cassandra.db.partitions.PartitionStatisticsCollector org.apache.cassandra.db.rows.ColumnData org.apache.cassandra.db.rows.ComplexColumnData top java.util.Iterator
StackMap stack:
10: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Cell
astore 5
start local 5 11: aload 1
invokevirtual org.apache.cassandra.utils.WrappedInt.increment:()V
12: aload 5
aload 2
invokestatic org.apache.cassandra.db.rows.Cells.collectStats:(Lorg/apache/cassandra/db/rows/Cell;Lorg/apache/cassandra/db/partitions/PartitionStatisticsCollector;)V
end local 5 13: StackMap locals:
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 10
end local 4 14: StackMap locals: org.apache.cassandra.utils.WrappedInt org.apache.cassandra.utils.WrappedInt org.apache.cassandra.db.partitions.PartitionStatisticsCollector org.apache.cassandra.db.rows.ColumnData
StackMap stack:
return
end local 3 LocalVariableTable:
Start End Slot Name Signature
0 15 3 cd Lorg/apache/cassandra/db/rows/ColumnData;
6 14 4 complexData Lorg/apache/cassandra/db/rows/ComplexColumnData;
11 13 5 cell Lorg/apache/cassandra/db/rows/Cell;
}
SourceFile: "Rows.java"
NestMembers:
org.apache.cassandra.db.rows.Rows$1
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public RowBuilder = org.apache.cassandra.db.SimpleBuilders$RowBuilder of org.apache.cassandra.db.SimpleBuilders
public abstract Builder = org.apache.cassandra.db.rows.Row$Builder of org.apache.cassandra.db.rows.Row
public Deletion = org.apache.cassandra.db.rows.Row$Deletion of org.apache.cassandra.db.rows.Row
public abstract SimpleBuilder = org.apache.cassandra.db.rows.Row$SimpleBuilder of org.apache.cassandra.db.rows.Row
org.apache.cassandra.db.rows.Rows$1
public abstract Reducer = org.apache.cassandra.utils.MergeIterator$Reducer of org.apache.cassandra.utils.MergeIterator