class org.apache.cassandra.db.rows.Rows$1 extends org.apache.cassandra.utils.MergeIterator$Reducer<org.apache.cassandra.db.rows.ColumnData, java.lang.Object>
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: org.apache.cassandra.db.rows.Rows$1
super_class: org.apache.cassandra.utils.MergeIterator$Reducer
{
org.apache.cassandra.db.rows.ColumnData mergedData;
descriptor: Lorg/apache/cassandra/db/rows/ColumnData;
flags: (0x0000)
org.apache.cassandra.db.rows.ColumnData[] inputDatas;
descriptor: [Lorg/apache/cassandra/db/rows/ColumnData;
flags: (0x0000)
private final org.apache.cassandra.db.rows.RowDiffListener val$diffListener;
descriptor: Lorg/apache/cassandra/db/rows/RowDiffListener;
flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC
private final org.apache.cassandra.db.Clustering val$clustering;
descriptor: Lorg/apache/cassandra/db/Clustering;
flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC
void <init>(org.apache.cassandra.db.rows.Row[], org.apache.cassandra.db.rows.RowDiffListener, org.apache.cassandra.db.Clustering);
descriptor: ([Lorg/apache/cassandra/db/rows/Row;Lorg/apache/cassandra/db/rows/RowDiffListener;Lorg/apache/cassandra/db/Clustering;)V
flags: (0x0000)
Code:
stack=2, locals=4, args_size=4
start local 0 0: aload 0
aload 2
putfield org.apache.cassandra.db.rows.Rows$1.val$diffListener:Lorg/apache/cassandra/db/rows/RowDiffListener;
aload 0
aload 3
putfield org.apache.cassandra.db.rows.Rows$1.val$clustering:Lorg/apache/cassandra/db/Clustering;
aload 0
invokespecial org.apache.cassandra.utils.MergeIterator$Reducer.<init>:()V
1: aload 0
aload 1
arraylength
anewarray org.apache.cassandra.db.rows.ColumnData
putfield org.apache.cassandra.db.rows.Rows$1.inputDatas:[Lorg/apache/cassandra/db/rows/ColumnData;
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/db/rows/Rows$1;
MethodParameters:
Name Flags
val$inputs final
val$diffListener final
val$clustering final
public void reduce(int, org.apache.cassandra.db.rows.ColumnData);
descriptor: (ILorg/apache/cassandra/db/rows/ColumnData;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: iload 1
ifne 2
1: aload 0
aload 2
putfield org.apache.cassandra.db.rows.Rows$1.mergedData:Lorg/apache/cassandra/db/rows/ColumnData;
goto 3
2: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.inputDatas:[Lorg/apache/cassandra/db/rows/ColumnData;
iload 1
iconst_1
isub
aload 2
aastore
3: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/db/rows/Rows$1;
0 4 1 idx I
0 4 2 current Lorg/apache/cassandra/db/rows/ColumnData;
MethodParameters:
Name Flags
idx
current
protected java.lang.Object getReduced();
descriptor: ()Ljava/lang/Object;
flags: (0x0004) ACC_PROTECTED
Code:
stack=6, locals=9, args_size=1
start local 0 0: iconst_0
istore 1
start local 1 1: goto 47
2: StackMap locals: int
StackMap stack:
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.inputDatas:[Lorg/apache/cassandra/db/rows/ColumnData;
iload 1
aaload
astore 2
start local 2 3: aload 0
getfield org.apache.cassandra.db.rows.Rows$1.mergedData:Lorg/apache/cassandra/db/rows/ColumnData;
ifnonnull 4
aload 2
ifnull 46
4: StackMap locals: org.apache.cassandra.db.rows.ColumnData
StackMap stack:
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.mergedData:Lorg/apache/cassandra/db/rows/ColumnData;
ifnull 5
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.mergedData:Lorg/apache/cassandra/db/rows/ColumnData;
goto 6
StackMap locals:
StackMap stack:
5: aload 2
StackMap locals:
StackMap stack: org.apache.cassandra.db.rows.ColumnData
6: getfield org.apache.cassandra.db.rows.ColumnData.column:Lorg/apache/cassandra/config/ColumnDefinition;
astore 3
start local 3 7: aload 3
invokevirtual org.apache.cassandra.config.ColumnDefinition.isSimple:()Z
ifeq 10
8: aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$diffListener:Lorg/apache/cassandra/db/rows/RowDiffListener;
iload 1
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$clustering:Lorg/apache/cassandra/db/Clustering;
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.mergedData:Lorg/apache/cassandra/db/rows/ColumnData;
checkcast org.apache.cassandra.db.rows.Cell
aload 2
checkcast org.apache.cassandra.db.rows.Cell
invokeinterface org.apache.cassandra.db.rows.RowDiffListener.onCell:(ILorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/db/rows/Cell;Lorg/apache/cassandra/db/rows/Cell;)V
9: goto 46
10: StackMap locals: org.apache.cassandra.config.ColumnDefinition
StackMap stack:
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.mergedData:Lorg/apache/cassandra/db/rows/ColumnData;
checkcast org.apache.cassandra.db.rows.ComplexColumnData
astore 4
start local 4 11: aload 2
checkcast org.apache.cassandra.db.rows.ComplexColumnData
astore 5
start local 5 12: aload 4
ifnonnull 20
13: aload 5
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.complexDeletion:()Lorg/apache/cassandra/db/DeletionTime;
invokevirtual org.apache.cassandra.db.DeletionTime.isLive:()Z
ifne 15
14: aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$diffListener:Lorg/apache/cassandra/db/rows/RowDiffListener;
iload 1
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$clustering:Lorg/apache/cassandra/db/Clustering;
aload 3
aconst_null
aload 5
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.complexDeletion:()Lorg/apache/cassandra/db/DeletionTime;
invokeinterface org.apache.cassandra.db.rows.RowDiffListener.onComplexDeletion:(ILorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/config/ColumnDefinition;Lorg/apache/cassandra/db/DeletionTime;Lorg/apache/cassandra/db/DeletionTime;)V
15: StackMap locals: org.apache.cassandra.db.rows.ComplexColumnData org.apache.cassandra.db.rows.ComplexColumnData
StackMap stack:
aload 5
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.iterator:()Ljava/util/Iterator;
astore 7
goto 18
StackMap locals: org.apache.cassandra.db.rows.Rows$1 int org.apache.cassandra.db.rows.ColumnData org.apache.cassandra.config.ColumnDefinition org.apache.cassandra.db.rows.ComplexColumnData org.apache.cassandra.db.rows.ComplexColumnData top java.util.Iterator
StackMap stack:
16: aload 7
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Cell
astore 6
start local 6 17: aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$diffListener:Lorg/apache/cassandra/db/rows/RowDiffListener;
iload 1
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$clustering:Lorg/apache/cassandra/db/Clustering;
aconst_null
aload 6
invokeinterface org.apache.cassandra.db.rows.RowDiffListener.onCell:(ILorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/db/rows/Cell;Lorg/apache/cassandra/db/rows/Cell;)V
end local 6 18: StackMap locals:
StackMap stack:
aload 7
invokeinterface java.util.Iterator.hasNext:()Z
ifne 16
19: goto 46
20: StackMap locals: org.apache.cassandra.db.rows.Rows$1 int org.apache.cassandra.db.rows.ColumnData org.apache.cassandra.config.ColumnDefinition org.apache.cassandra.db.rows.ComplexColumnData org.apache.cassandra.db.rows.ComplexColumnData
StackMap stack:
aload 5
ifnonnull 28
21: aload 4
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.complexDeletion:()Lorg/apache/cassandra/db/DeletionTime;
invokevirtual org.apache.cassandra.db.DeletionTime.isLive:()Z
ifne 23
22: aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$diffListener:Lorg/apache/cassandra/db/rows/RowDiffListener;
iload 1
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$clustering:Lorg/apache/cassandra/db/Clustering;
aload 3
aload 4
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.complexDeletion:()Lorg/apache/cassandra/db/DeletionTime;
aconst_null
invokeinterface org.apache.cassandra.db.rows.RowDiffListener.onComplexDeletion:(ILorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/config/ColumnDefinition;Lorg/apache/cassandra/db/DeletionTime;Lorg/apache/cassandra/db/DeletionTime;)V
23: StackMap locals:
StackMap stack:
aload 4
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.iterator:()Ljava/util/Iterator;
astore 7
goto 26
StackMap locals: org.apache.cassandra.db.rows.Rows$1 int org.apache.cassandra.db.rows.ColumnData org.apache.cassandra.config.ColumnDefinition org.apache.cassandra.db.rows.ComplexColumnData org.apache.cassandra.db.rows.ComplexColumnData top java.util.Iterator
StackMap stack:
24: aload 7
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Cell
astore 6
start local 6 25: aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$diffListener:Lorg/apache/cassandra/db/rows/RowDiffListener;
iload 1
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$clustering:Lorg/apache/cassandra/db/Clustering;
aload 6
aconst_null
invokeinterface org.apache.cassandra.db.rows.RowDiffListener.onCell:(ILorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/db/rows/Cell;Lorg/apache/cassandra/db/rows/Cell;)V
end local 6 26: StackMap locals:
StackMap stack:
aload 7
invokeinterface java.util.Iterator.hasNext:()Z
ifne 24
27: goto 46
28: StackMap locals: org.apache.cassandra.db.rows.Rows$1 int org.apache.cassandra.db.rows.ColumnData org.apache.cassandra.config.ColumnDefinition org.apache.cassandra.db.rows.ComplexColumnData org.apache.cassandra.db.rows.ComplexColumnData
StackMap stack:
aload 4
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.complexDeletion:()Lorg/apache/cassandra/db/DeletionTime;
invokevirtual org.apache.cassandra.db.DeletionTime.isLive:()Z
ifeq 29
aload 5
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.complexDeletion:()Lorg/apache/cassandra/db/DeletionTime;
invokevirtual org.apache.cassandra.db.DeletionTime.isLive:()Z
ifne 30
29: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$diffListener:Lorg/apache/cassandra/db/rows/RowDiffListener;
iload 1
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$clustering:Lorg/apache/cassandra/db/Clustering;
aload 3
aload 4
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.complexDeletion:()Lorg/apache/cassandra/db/DeletionTime;
aload 5
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.complexDeletion:()Lorg/apache/cassandra/db/DeletionTime;
invokeinterface org.apache.cassandra.db.rows.RowDiffListener.onComplexDeletion:(ILorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/config/ColumnDefinition;Lorg/apache/cassandra/db/DeletionTime;Lorg/apache/cassandra/db/DeletionTime;)V
30: StackMap locals:
StackMap stack:
aload 4
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.iterator:()Ljava/util/Iterator;
invokestatic com.google.common.collect.Iterators.peekingIterator:(Ljava/util/Iterator;)Lcom/google/common/collect/PeekingIterator;
astore 6
start local 6 31: aload 5
invokevirtual org.apache.cassandra.db.rows.ComplexColumnData.iterator:()Ljava/util/Iterator;
invokestatic com.google.common.collect.Iterators.peekingIterator:(Ljava/util/Iterator;)Lcom/google/common/collect/PeekingIterator;
astore 7
start local 7 32: goto 39
33: StackMap locals: com.google.common.collect.PeekingIterator com.google.common.collect.PeekingIterator
StackMap stack:
aload 3
invokevirtual org.apache.cassandra.config.ColumnDefinition.cellPathComparator:()Ljava/util/Comparator;
aload 6
invokeinterface com.google.common.collect.PeekingIterator.peek:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Cell
invokevirtual org.apache.cassandra.db.rows.Cell.path:()Lorg/apache/cassandra/db/rows/CellPath;
aload 7
invokeinterface com.google.common.collect.PeekingIterator.peek:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Cell
invokevirtual org.apache.cassandra.db.rows.Cell.path:()Lorg/apache/cassandra/db/rows/CellPath;
invokeinterface java.util.Comparator.compare:(Ljava/lang/Object;Ljava/lang/Object;)I
istore 8
start local 8 34: iload 8
ifne 36
35: aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$diffListener:Lorg/apache/cassandra/db/rows/RowDiffListener;
iload 1
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$clustering:Lorg/apache/cassandra/db/Clustering;
aload 6
invokeinterface com.google.common.collect.PeekingIterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Cell
aload 7
invokeinterface com.google.common.collect.PeekingIterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Cell
invokeinterface org.apache.cassandra.db.rows.RowDiffListener.onCell:(ILorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/db/rows/Cell;Lorg/apache/cassandra/db/rows/Cell;)V
goto 39
36: StackMap locals: int
StackMap stack:
iload 8
ifge 38
37: aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$diffListener:Lorg/apache/cassandra/db/rows/RowDiffListener;
iload 1
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$clustering:Lorg/apache/cassandra/db/Clustering;
aload 6
invokeinterface com.google.common.collect.PeekingIterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Cell
aconst_null
invokeinterface org.apache.cassandra.db.rows.RowDiffListener.onCell:(ILorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/db/rows/Cell;Lorg/apache/cassandra/db/rows/Cell;)V
goto 39
38: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$diffListener:Lorg/apache/cassandra/db/rows/RowDiffListener;
iload 1
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$clustering:Lorg/apache/cassandra/db/Clustering;
aconst_null
aload 7
invokeinterface com.google.common.collect.PeekingIterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Cell
invokeinterface org.apache.cassandra.db.rows.RowDiffListener.onCell:(ILorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/db/rows/Cell;Lorg/apache/cassandra/db/rows/Cell;)V
end local 8 39: StackMap locals:
StackMap stack:
aload 6
invokeinterface com.google.common.collect.PeekingIterator.hasNext:()Z
ifeq 42
aload 7
invokeinterface com.google.common.collect.PeekingIterator.hasNext:()Z
ifne 33
40: goto 42
41: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$diffListener:Lorg/apache/cassandra/db/rows/RowDiffListener;
iload 1
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$clustering:Lorg/apache/cassandra/db/Clustering;
aload 6
invokeinterface com.google.common.collect.PeekingIterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Cell
aconst_null
invokeinterface org.apache.cassandra.db.rows.RowDiffListener.onCell:(ILorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/db/rows/Cell;Lorg/apache/cassandra/db/rows/Cell;)V
42: StackMap locals:
StackMap stack:
aload 6
invokeinterface com.google.common.collect.PeekingIterator.hasNext:()Z
ifne 41
43: goto 45
44: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$diffListener:Lorg/apache/cassandra/db/rows/RowDiffListener;
iload 1
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.val$clustering:Lorg/apache/cassandra/db/Clustering;
aconst_null
aload 7
invokeinterface com.google.common.collect.PeekingIterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Cell
invokeinterface org.apache.cassandra.db.rows.RowDiffListener.onCell:(ILorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/db/rows/Cell;Lorg/apache/cassandra/db/rows/Cell;)V
45: StackMap locals:
StackMap stack:
aload 7
invokeinterface com.google.common.collect.PeekingIterator.hasNext:()Z
ifne 44
end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 46: StackMap locals: org.apache.cassandra.db.rows.Rows$1 int
StackMap stack:
iinc 1 1
StackMap locals:
StackMap stack:
47: iload 1
aload 0
getfield org.apache.cassandra.db.rows.Rows$1.inputDatas:[Lorg/apache/cassandra/db/rows/ColumnData;
arraylength
if_icmpne 2
end local 1 48: aconst_null
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 49 0 this Lorg/apache/cassandra/db/rows/Rows$1;
1 48 1 i I
3 46 2 input Lorg/apache/cassandra/db/rows/ColumnData;
7 46 3 column Lorg/apache/cassandra/config/ColumnDefinition;
11 46 4 mergedData Lorg/apache/cassandra/db/rows/ComplexColumnData;
12 46 5 inputData Lorg/apache/cassandra/db/rows/ComplexColumnData;
17 18 6 inputCell Lorg/apache/cassandra/db/rows/Cell;
25 26 6 mergedCell Lorg/apache/cassandra/db/rows/Cell;
31 46 6 mergedCells Lcom/google/common/collect/PeekingIterator<Lorg/apache/cassandra/db/rows/Cell;>;
32 46 7 inputCells Lcom/google/common/collect/PeekingIterator<Lorg/apache/cassandra/db/rows/Cell;>;
34 39 8 cmp I
protected void onKeyChange();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
aconst_null
putfield org.apache.cassandra.db.rows.Rows$1.mergedData:Lorg/apache/cassandra/db/rows/ColumnData;
1: aload 0
getfield org.apache.cassandra.db.rows.Rows$1.inputDatas:[Lorg/apache/cassandra/db/rows/ColumnData;
aconst_null
invokestatic java.util.Arrays.fill:([Ljava/lang/Object;Ljava/lang/Object;)V
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/db/rows/Rows$1;
public void reduce(int, java.lang.Object);
descriptor: (ILjava/lang/Object;)V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
iload 1
aload 2
checkcast org.apache.cassandra.db.rows.ColumnData
invokevirtual org.apache.cassandra.db.rows.Rows$1.reduce:(ILorg/apache/cassandra/db/rows/ColumnData;)V
return
LocalVariableTable:
Start End Slot Name Signature
}
Signature: Lorg/apache/cassandra/utils/MergeIterator$Reducer<Lorg/apache/cassandra/db/rows/ColumnData;Ljava/lang/Object;>;
SourceFile: "Rows.java"
EnclosingMethod: org.apache.cassandra.db.rows.Rows.diff:(Lorg/apache/cassandra/db/rows/RowDiffListener;Lorg/apache/cassandra/db/rows/Row;[Lorg/apache/cassandra/db/rows/Row;)V
NestHost: org.apache.cassandra.db.rows.Rows
InnerClasses:
org.apache.cassandra.db.rows.Rows$1
public abstract Reducer = org.apache.cassandra.utils.MergeIterator$Reducer of org.apache.cassandra.utils.MergeIterator