- 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
class org.apache.cassandra.db.compaction.CompactionIterator$1 implements org.apache.cassandra.db.partitions.UnfilteredPartitionIterators$MergeListener
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: org.apache.cassandra.db.compaction.CompactionIterator$1
super_class: java.lang.Object
{
final org.apache.cassandra.db.compaction.CompactionIterator this$0;
descriptor: Lorg/apache/cassandra/db/compaction/CompactionIterator;
flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC
void <init>(org.apache.cassandra.db.compaction.CompactionIterator);
descriptor: (Lorg/apache/cassandra/db/compaction/CompactionIterator;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 // org.apache.cassandra.db.compaction.CompactionIterator$1 this
0: .line 148
aload 0 /* this */
aload 1
putfield org.apache.cassandra.db.compaction.CompactionIterator$1.this$0:Lorg/apache/cassandra/db/compaction/CompactionIterator;
aload 0 /* this */
invokespecial java.lang.Object.<init>:()V
return
end local 0 // org.apache.cassandra.db.compaction.CompactionIterator$1 this
LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/compaction/CompactionIterator$1;
MethodParameters:
Name Flags
this$0 final
public org.apache.cassandra.db.rows.UnfilteredRowIterators$MergeListener getRowMergeListener(org.apache.cassandra.db.DecoratedKey, java.util.List<org.apache.cassandra.db.rows.UnfilteredRowIterator>);
descriptor: (Lorg/apache/cassandra/db/DecoratedKey;Ljava/util/List;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterators$MergeListener;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=8, args_size=3
start local 0 // org.apache.cassandra.db.compaction.CompactionIterator$1 this
start local 1 // org.apache.cassandra.db.DecoratedKey partitionKey
start local 2 // java.util.List versions
0: .line 152
iconst_0
istore 3 /* merged */
start local 3 // int merged
1: .line 153
aload 2 /* versions */
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 5
goto 5
StackMap locals: org.apache.cassandra.db.compaction.CompactionIterator$1 org.apache.cassandra.db.DecoratedKey java.util.List int top java.util.Iterator
StackMap stack:
2: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.UnfilteredRowIterator
astore 4 /* iter */
start local 4 // org.apache.cassandra.db.rows.UnfilteredRowIterator iter
3: .line 155
aload 4 /* iter */
ifnull 5
4: .line 156
iinc 3 /* merged */ 1
end local 4 // org.apache.cassandra.db.rows.UnfilteredRowIterator iter
5: .line 153
StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
6: .line 159
getstatic org.apache.cassandra.db.compaction.CompactionIterator.$assertionsDisabled:Z
ifne 7
iload 3 /* merged */
ifgt 7
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
7: .line 161
StackMap locals: org.apache.cassandra.db.compaction.CompactionIterator$1 org.apache.cassandra.db.DecoratedKey java.util.List int
StackMap stack:
aload 0 /* this */
getfield org.apache.cassandra.db.compaction.CompactionIterator$1.this$0:Lorg/apache/cassandra/db/compaction/CompactionIterator;
iload 3 /* merged */
invokevirtual org.apache.cassandra.db.compaction.CompactionIterator.updateCounterFor:(I)V
8: .line 163
aload 0 /* this */
getfield org.apache.cassandra.db.compaction.CompactionIterator$1.this$0:Lorg/apache/cassandra/db/compaction/CompactionIterator;
getfield org.apache.cassandra.db.compaction.CompactionIterator.type:Lorg/apache/cassandra/db/compaction/OperationType;
getstatic org.apache.cassandra.db.compaction.OperationType.COMPACTION:Lorg/apache/cassandra/db/compaction/OperationType;
if_acmpne 9
aload 0 /* this */
getfield org.apache.cassandra.db.compaction.CompactionIterator$1.this$0:Lorg/apache/cassandra/db/compaction/CompactionIterator;
getfield org.apache.cassandra.db.compaction.CompactionIterator.controller:Lorg/apache/cassandra/db/compaction/CompactionController;
getfield org.apache.cassandra.db.compaction.CompactionController.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.indexManager:Lorg/apache/cassandra/index/SecondaryIndexManager;
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.hasIndexes:()Z
ifne 10
9: .line 164
StackMap locals:
StackMap stack:
aconst_null
areturn
10: .line 166
StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.db.Columns.NONE:Lorg/apache/cassandra/db/Columns;
astore 4 /* statics */
start local 4 // org.apache.cassandra.db.Columns statics
11: .line 167
getstatic org.apache.cassandra.db.Columns.NONE:Lorg/apache/cassandra/db/Columns;
astore 5 /* regulars */
start local 5 // org.apache.cassandra.db.Columns regulars
12: .line 168
aload 2 /* versions */
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 7
goto 17
StackMap locals: org.apache.cassandra.db.compaction.CompactionIterator$1 org.apache.cassandra.db.DecoratedKey java.util.List int org.apache.cassandra.db.Columns org.apache.cassandra.db.Columns top java.util.Iterator
StackMap stack:
13: aload 7
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.UnfilteredRowIterator
astore 6 /* iter */
start local 6 // org.apache.cassandra.db.rows.UnfilteredRowIterator iter
14: .line 170
aload 6 /* iter */
ifnull 17
15: .line 172
aload 4 /* statics */
aload 6 /* iter */
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.columns:()Lorg/apache/cassandra/db/PartitionColumns;
getfield org.apache.cassandra.db.PartitionColumns.statics:Lorg/apache/cassandra/db/Columns;
invokevirtual org.apache.cassandra.db.Columns.mergeTo:(Lorg/apache/cassandra/db/Columns;)Lorg/apache/cassandra/db/Columns;
astore 4 /* statics */
16: .line 173
aload 5 /* regulars */
aload 6 /* iter */
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.columns:()Lorg/apache/cassandra/db/PartitionColumns;
getfield org.apache.cassandra.db.PartitionColumns.regulars:Lorg/apache/cassandra/db/Columns;
invokevirtual org.apache.cassandra.db.Columns.mergeTo:(Lorg/apache/cassandra/db/Columns;)Lorg/apache/cassandra/db/Columns;
astore 5 /* regulars */
end local 6 // org.apache.cassandra.db.rows.UnfilteredRowIterator iter
17: .line 168
StackMap locals:
StackMap stack:
aload 7
invokeinterface java.util.Iterator.hasNext:()Z
ifne 13
18: .line 176
new org.apache.cassandra.db.PartitionColumns
dup
aload 4 /* statics */
aload 5 /* regulars */
invokespecial org.apache.cassandra.db.PartitionColumns.<init>:(Lorg/apache/cassandra/db/Columns;Lorg/apache/cassandra/db/Columns;)V
astore 6 /* partitionColumns */
start local 6 // org.apache.cassandra.db.PartitionColumns partitionColumns
19: .line 189
aload 0 /* this */
getfield org.apache.cassandra.db.compaction.CompactionIterator$1.this$0:Lorg/apache/cassandra/db/compaction/CompactionIterator;
getfield org.apache.cassandra.db.compaction.CompactionIterator.controller:Lorg/apache/cassandra/db/compaction/CompactionController;
getfield org.apache.cassandra.db.compaction.CompactionController.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.indexManager:Lorg/apache/cassandra/index/SecondaryIndexManager;
aload 1 /* partitionKey */
20: .line 190
aload 6 /* partitionColumns */
21: .line 191
aload 2 /* versions */
invokeinterface java.util.List.size:()I
22: .line 192
aload 0 /* this */
getfield org.apache.cassandra.db.compaction.CompactionIterator$1.this$0:Lorg/apache/cassandra/db/compaction/CompactionIterator;
getfield org.apache.cassandra.db.compaction.CompactionIterator.nowInSec:I
23: .line 189
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.newCompactionTransaction:(Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/PartitionColumns;II)Lorg/apache/cassandra/index/transactions/CompactionTransaction;
24: .line 188
astore 7 /* indexTransaction */
start local 7 // org.apache.cassandra.index.transactions.CompactionTransaction indexTransaction
25: .line 194
new org.apache.cassandra.db.compaction.CompactionIterator$1$1
dup
aload 0 /* this */
aload 7 /* indexTransaction */
invokespecial org.apache.cassandra.db.compaction.CompactionIterator$1$1.<init>:(Lorg/apache/cassandra/db/compaction/CompactionIterator$1;Lorg/apache/cassandra/index/transactions/CompactionTransaction;)V
areturn
end local 7 // org.apache.cassandra.index.transactions.CompactionTransaction indexTransaction
end local 6 // org.apache.cassandra.db.PartitionColumns partitionColumns
end local 5 // org.apache.cassandra.db.Columns regulars
end local 4 // org.apache.cassandra.db.Columns statics
end local 3 // int merged
end local 2 // java.util.List versions
end local 1 // org.apache.cassandra.db.DecoratedKey partitionKey
end local 0 // org.apache.cassandra.db.compaction.CompactionIterator$1 this
LocalVariableTable:
Start End Slot Name Signature
0 26 0 this Lorg/apache/cassandra/db/compaction/CompactionIterator$1;
0 26 1 partitionKey Lorg/apache/cassandra/db/DecoratedKey;
0 26 2 versions Ljava/util/List<Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;>;
1 26 3 merged I
3 5 4 iter Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
11 26 4 statics Lorg/apache/cassandra/db/Columns;
12 26 5 regulars Lorg/apache/cassandra/db/Columns;
14 17 6 iter Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
19 26 6 partitionColumns Lorg/apache/cassandra/db/PartitionColumns;
25 26 7 indexTransaction Lorg/apache/cassandra/index/transactions/CompactionTransaction;
Signature: (Lorg/apache/cassandra/db/DecoratedKey;Ljava/util/List<Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;>;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterators$MergeListener;
MethodParameters:
Name Flags
partitionKey
versions
public void close();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=0, locals=1, args_size=1
start local 0 // org.apache.cassandra.db.compaction.CompactionIterator$1 this
0: .line 219
return
end local 0 // org.apache.cassandra.db.compaction.CompactionIterator$1 this
LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/compaction/CompactionIterator$1;
}
SourceFile: "CompactionIterator.java"
EnclosingMethod: org.apache.cassandra.db.compaction.CompactionIterator.listener:()Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterators$MergeListener;
NestHost: org.apache.cassandra.db.compaction.CompactionIterator
InnerClasses:
org.apache.cassandra.db.compaction.CompactionIterator$1
org.apache.cassandra.db.compaction.CompactionIterator$1$1
public abstract MergeListener = org.apache.cassandra.db.partitions.UnfilteredPartitionIterators$MergeListener of org.apache.cassandra.db.partitions.UnfilteredPartitionIterators
public abstract MergeListener = org.apache.cassandra.db.rows.UnfilteredRowIterators$MergeListener of org.apache.cassandra.db.rows.UnfilteredRowIterators