public class org.apache.cassandra.index.internal.composites.CompositesSearcher extends org.apache.cassandra.index.internal.CassandraIndexSearcher
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.index.internal.composites.CompositesSearcher
super_class: org.apache.cassandra.index.internal.CassandraIndexSearcher
{
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/index/internal/composites/CompositesSearcher;
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.index.internal.composites.CompositesSearcher.$assertionsDisabled:Z
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(org.apache.cassandra.db.ReadCommand, org.apache.cassandra.db.filter.RowFilter$Expression, org.apache.cassandra.index.internal.CassandraIndex);
descriptor: (Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/db/filter/RowFilter$Expression;Lorg/apache/cassandra/index/internal/CassandraIndex;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
aload 3
invokespecial org.apache.cassandra.index.internal.CassandraIndexSearcher.<init>:(Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/db/filter/RowFilter$Expression;Lorg/apache/cassandra/index/internal/CassandraIndex;)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/index/internal/composites/CompositesSearcher;
0 2 1 command Lorg/apache/cassandra/db/ReadCommand;
0 2 2 expression Lorg/apache/cassandra/db/filter/RowFilter$Expression;
0 2 3 index Lorg/apache/cassandra/index/internal/CassandraIndex;
MethodParameters:
Name Flags
command
expression
index
private boolean isMatchingEntry(org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.index.internal.IndexEntry, org.apache.cassandra.db.ReadCommand);
descriptor: (Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/index/internal/IndexEntry;Lorg/apache/cassandra/db/ReadCommand;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 3
aload 1
invokevirtual org.apache.cassandra.db.ReadCommand.selectsKey:(Lorg/apache/cassandra/db/DecoratedKey;)Z
ifeq 1
aload 3
aload 1
aload 2
getfield org.apache.cassandra.index.internal.IndexEntry.indexedEntryClustering:Lorg/apache/cassandra/db/Clustering;
invokevirtual org.apache.cassandra.db.ReadCommand.selectsClustering:(Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/Clustering;)Z
ifeq 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/index/internal/composites/CompositesSearcher;
0 2 1 partitionKey Lorg/apache/cassandra/db/DecoratedKey;
0 2 2 entry Lorg/apache/cassandra/index/internal/IndexEntry;
0 2 3 command Lorg/apache/cassandra/db/ReadCommand;
MethodParameters:
Name Flags
partitionKey
entry
command
private boolean isStaticColumn();
descriptor: ()Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.index.internal.composites.CompositesSearcher.index:Lorg/apache/cassandra/index/internal/CassandraIndex;
invokevirtual org.apache.cassandra.index.internal.CassandraIndex.getIndexedColumn:()Lorg/apache/cassandra/config/ColumnDefinition;
invokevirtual org.apache.cassandra.config.ColumnDefinition.isStatic:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/index/internal/composites/CompositesSearcher;
protected org.apache.cassandra.db.partitions.UnfilteredPartitionIterator queryDataFromIndex(org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.db.rows.RowIterator, org.apache.cassandra.db.ReadCommand, org.apache.cassandra.db.ReadExecutionController);
descriptor: (Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/rows/RowIterator;Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
flags: (0x0004) ACC_PROTECTED
Code:
stack=7, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: getstatic org.apache.cassandra.index.internal.composites.CompositesSearcher.$assertionsDisabled:Z
ifne 1
aload 2
invokeinterface org.apache.cassandra.db.rows.RowIterator.staticRow:()Lorg/apache/cassandra/db/rows/Row;
getstatic org.apache.cassandra.db.rows.Rows.EMPTY_STATIC_ROW:Lorg/apache/cassandra/db/rows/Row;
if_acmpeq 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
new org.apache.cassandra.index.internal.composites.CompositesSearcher$1
dup
aload 0
aload 3
aload 2
aload 1
aload 4
invokespecial org.apache.cassandra.index.internal.composites.CompositesSearcher$1.<init>:(Lorg/apache/cassandra/index/internal/composites/CompositesSearcher;Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/db/rows/RowIterator;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/ReadExecutionController;)V
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/index/internal/composites/CompositesSearcher;
0 2 1 indexKey Lorg/apache/cassandra/db/DecoratedKey;
0 2 2 indexHits Lorg/apache/cassandra/db/rows/RowIterator;
0 2 3 command Lorg/apache/cassandra/db/ReadCommand;
0 2 4 executionController Lorg/apache/cassandra/db/ReadExecutionController;
MethodParameters:
Name Flags
indexKey final
indexHits final
command final
executionController final
private void deleteAllEntries(java.util.List<org.apache.cassandra.index.internal.IndexEntry>, org.apache.cassandra.utils.concurrent.OpOrder$Group, );
descriptor: (Ljava/util/List;Lorg/apache/cassandra/utils/concurrent/OpOrder$Group;I)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
aload 0
iload 3
aload 2
invokedynamic accept(Lorg/apache/cassandra/index/internal/composites/CompositesSearcher;ILorg/apache/cassandra/utils/concurrent/OpOrder$Group;)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/index/internal/composites/CompositesSearcher.lambda$0(ILorg/apache/cassandra/utils/concurrent/OpOrder$Group;Lorg/apache/cassandra/index/internal/IndexEntry;)V (7)
(Lorg/apache/cassandra/index/internal/IndexEntry;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/index/internal/composites/CompositesSearcher;
0 2 1 entries Ljava/util/List<Lorg/apache/cassandra/index/internal/IndexEntry;>;
0 2 2 writeOp Lorg/apache/cassandra/utils/concurrent/OpOrder$Group;
0 2 3 nowInSec I
Signature: (Ljava/util/List<Lorg/apache/cassandra/index/internal/IndexEntry;>;Lorg/apache/cassandra/utils/concurrent/OpOrder$Group;I)V
MethodParameters:
Name Flags
entries final
writeOp final
nowInSec final
private org.apache.cassandra.db.rows.UnfilteredRowIterator filterStaleEntries(org.apache.cassandra.db.rows.UnfilteredRowIterator, java.nio.ByteBuffer, java.util.List<org.apache.cassandra.index.internal.IndexEntry>, org.apache.cassandra.utils.concurrent.OpOrder$Group, int);
descriptor: (Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Ljava/nio/ByteBuffer;Ljava/util/List;Lorg/apache/cassandra/utils/concurrent/OpOrder$Group;I)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
flags: (0x0002) ACC_PRIVATE
Code:
stack=10, locals=9, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 6
start local 6 1: aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionLevelDeletion:()Lorg/apache/cassandra/db/DeletionTime;
invokevirtual org.apache.cassandra.db.DeletionTime.isLive:()Z
ifne 4
2: aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionLevelDeletion:()Lorg/apache/cassandra/db/DeletionTime;
astore 7
start local 7 3: aload 3
aload 7
aload 6
invokedynamic accept(Lorg/apache/cassandra/db/DeletionTime;Ljava/util/List;)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/index/internal/composites/CompositesSearcher.lambda$1(Lorg/apache/cassandra/db/DeletionTime;Ljava/util/List;Lorg/apache/cassandra/index/internal/IndexEntry;)V (6)
(Lorg/apache/cassandra/index/internal/IndexEntry;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
end local 7 4: StackMap locals: java.util.List
StackMap stack:
aconst_null
astore 7
start local 7 5: aload 0
invokevirtual org.apache.cassandra.index.internal.composites.CompositesSearcher.isStaticColumn:()Z
ifeq 19
6: aload 3
invokeinterface java.util.List.size:()I
iconst_1
if_icmpeq 8
7: new java.lang.AssertionError
dup
ldc "A partition should have at most one index within a static column index"
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
8: StackMap locals: org.apache.cassandra.db.rows.UnfilteredRowIterator
StackMap stack:
aload 1
astore 7
9: aload 0
getfield org.apache.cassandra.index.internal.composites.CompositesSearcher.index:Lorg/apache/cassandra/index/internal/CassandraIndex;
aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.staticRow:()Lorg/apache/cassandra/db/rows/Row;
aload 2
iload 5
invokevirtual org.apache.cassandra.index.internal.CassandraIndex.isStale:(Lorg/apache/cassandra/db/rows/Row;Ljava/nio/ByteBuffer;I)Z
ifeq 17
10: aload 6
aload 3
invokeinterface java.util.List.addAll:(Ljava/util/Collection;)Z
pop
11: aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.metadata:()Lorg/apache/cassandra/config/CFMetaData;
12: aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
13: getstatic org.apache.cassandra.db.rows.Rows.EMPTY_STATIC_ROW:Lorg/apache/cassandra/db/rows/Row;
14: aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionLevelDeletion:()Lorg/apache/cassandra/db/DeletionTime;
15: aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.isReverseOrder:()Z
16: invokestatic org.apache.cassandra.db.rows.UnfilteredRowIterators.noRowsIterator:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/rows/Row;Lorg/apache/cassandra/db/DeletionTime;Z)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
astore 7
17: StackMap locals:
StackMap stack:
aload 0
aload 6
aload 4
iload 5
invokevirtual org.apache.cassandra.index.internal.composites.CompositesSearcher.deleteAllEntries:(Ljava/util/List;Lorg/apache/cassandra/utils/concurrent/OpOrder$Group;I)V
18: goto 21
19: StackMap locals:
StackMap stack:
aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.comparator:Lorg/apache/cassandra/db/ClusteringComparator;
astore 8
start local 8 20: aload 1
new org.apache.cassandra.index.internal.composites.CompositesSearcher$1Transform
dup
aload 0
aload 2
iload 5
aload 6
aload 3
aload 8
aload 4
invokespecial org.apache.cassandra.index.internal.composites.CompositesSearcher$1Transform.<init>:(Lorg/apache/cassandra/index/internal/composites/CompositesSearcher;Ljava/nio/ByteBuffer;ILjava/util/List;Ljava/util/List;Lorg/apache/cassandra/db/ClusteringComparator;Lorg/apache/cassandra/utils/concurrent/OpOrder$Group;)V
invokestatic org.apache.cassandra.db.transform.Transformation.apply:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/db/transform/Transformation;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
astore 7
end local 8 21: StackMap locals:
StackMap stack:
aload 7
areturn
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 22 0 this Lorg/apache/cassandra/index/internal/composites/CompositesSearcher;
0 22 1 dataIter Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
0 22 2 indexValue Ljava/nio/ByteBuffer;
0 22 3 entries Ljava/util/List<Lorg/apache/cassandra/index/internal/IndexEntry;>;
0 22 4 writeOp Lorg/apache/cassandra/utils/concurrent/OpOrder$Group;
0 22 5 nowInSec I
1 22 6 staleEntries Ljava/util/List<Lorg/apache/cassandra/index/internal/IndexEntry;>;
3 4 7 deletion Lorg/apache/cassandra/db/DeletionTime;
5 22 7 iteratorToReturn Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
20 21 8 comparator Lorg/apache/cassandra/db/ClusteringComparator;
Signature: (Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Ljava/nio/ByteBuffer;Ljava/util/List<Lorg/apache/cassandra/index/internal/IndexEntry;>;Lorg/apache/cassandra/utils/concurrent/OpOrder$Group;I)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
MethodParameters:
Name Flags
dataIter
indexValue final
entries final
writeOp final
nowInSec final
static org.apache.cassandra.index.internal.CassandraIndex access$0(org.apache.cassandra.index.internal.composites.CompositesSearcher);
descriptor: (Lorg/apache/cassandra/index/internal/composites/CompositesSearcher;)Lorg/apache/cassandra/index/internal/CassandraIndex;
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
getfield org.apache.cassandra.index.internal.composites.CompositesSearcher.index:Lorg/apache/cassandra/index/internal/CassandraIndex;
areturn
LocalVariableTable:
Start End Slot Name Signature
private void lambda$0(int, org.apache.cassandra.utils.concurrent.OpOrder$Group, org.apache.cassandra.index.internal.IndexEntry);
descriptor: (ILorg/apache/cassandra/utils/concurrent/OpOrder$Group;Lorg/apache/cassandra/index/internal/IndexEntry;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=8, locals=4, args_size=4
start local 0 start local 3 0: aload 0
getfield org.apache.cassandra.index.internal.composites.CompositesSearcher.index:Lorg/apache/cassandra/index/internal/CassandraIndex;
aload 3
getfield org.apache.cassandra.index.internal.IndexEntry.indexValue:Lorg/apache/cassandra/db/DecoratedKey;
1: aload 3
getfield org.apache.cassandra.index.internal.IndexEntry.indexClustering:Lorg/apache/cassandra/db/Clustering;
2: new org.apache.cassandra.db.DeletionTime
dup
aload 3
getfield org.apache.cassandra.index.internal.IndexEntry.timestamp:J
iload 1
invokespecial org.apache.cassandra.db.DeletionTime.<init>:(JI)V
3: aload 2
4: invokevirtual org.apache.cassandra.index.internal.CassandraIndex.deleteStaleEntry:(Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/db/DeletionTime;Lorg/apache/cassandra/utils/concurrent/OpOrder$Group;)V
5: return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/index/internal/composites/CompositesSearcher;
0 6 3 entry Lorg/apache/cassandra/index/internal/IndexEntry;
private static void lambda$1(org.apache.cassandra.db.DeletionTime, java.util.List, org.apache.cassandra.index.internal.IndexEntry);
descriptor: (Lorg/apache/cassandra/db/DeletionTime;Ljava/util/List;Lorg/apache/cassandra/index/internal/IndexEntry;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 2 0: aload 0
aload 2
getfield org.apache.cassandra.index.internal.IndexEntry.timestamp:J
invokevirtual org.apache.cassandra.db.DeletionTime.deletes:(J)Z
ifeq 2
1: aload 1
aload 2
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
2: StackMap locals:
StackMap stack:
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 3 2 e Lorg/apache/cassandra/index/internal/IndexEntry;
}
SourceFile: "CompositesSearcher.java"
NestMembers:
org.apache.cassandra.index.internal.composites.CompositesSearcher$1 org.apache.cassandra.index.internal.composites.CompositesSearcher$1Transform
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract Expression = org.apache.cassandra.db.filter.RowFilter$Expression of org.apache.cassandra.db.filter.RowFilter
org.apache.cassandra.index.internal.composites.CompositesSearcher$1
Transform = org.apache.cassandra.index.internal.composites.CompositesSearcher$1Transform
public final Group = org.apache.cassandra.utils.concurrent.OpOrder$Group of org.apache.cassandra.utils.concurrent.OpOrder