public class org.apache.cassandra.db.SinglePartitionReadCommand extends org.apache.cassandra.db.ReadCommand
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.db.SinglePartitionReadCommand
super_class: org.apache.cassandra.db.ReadCommand
{
protected static final org.apache.cassandra.db.ReadCommand$SelectionDeserializer selectionDeserializer;
descriptor: Lorg/apache/cassandra/db/ReadCommand$SelectionDeserializer;
flags: (0x001c) ACC_PROTECTED, ACC_STATIC, ACC_FINAL
private final org.apache.cassandra.db.DecoratedKey partitionKey;
descriptor: Lorg/apache/cassandra/db/DecoratedKey;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.cassandra.db.filter.ClusteringIndexFilter clusteringIndexFilter;
descriptor: Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private int oldestUnrepairedTombstone;
descriptor: I
flags: (0x0002) ACC_PRIVATE
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=2, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/db/SinglePartitionReadCommand;
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.SinglePartitionReadCommand.$assertionsDisabled:Z
3: new org.apache.cassandra.db.SinglePartitionReadCommand$Deserializer
dup
invokespecial org.apache.cassandra.db.SinglePartitionReadCommand$Deserializer.<init>:()V
putstatic org.apache.cassandra.db.SinglePartitionReadCommand.selectionDeserializer:Lorg/apache/cassandra/db/ReadCommand$SelectionDeserializer;
return
LocalVariableTable:
Start End Slot Name Signature
private void <init>(boolean, int, boolean, org.apache.cassandra.config.CFMetaData, int, org.apache.cassandra.db.filter.ColumnFilter, org.apache.cassandra.db.filter.RowFilter, org.apache.cassandra.db.filter.DataLimits, org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.db.filter.ClusteringIndexFilter, org.apache.cassandra.schema.IndexMetadata);
descriptor: (ZIZLorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/RowFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/schema/IndexMetadata;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=11, locals=12, args_size=12
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 start local 8 start local 9 start local 10 start local 11 0: aload 0
getstatic org.apache.cassandra.db.ReadCommand$Kind.SINGLE_PARTITION:Lorg/apache/cassandra/db/ReadCommand$Kind;
iload 1
iload 2
iload 3
aload 4
iload 5
aload 6
aload 7
aload 8
aload 11
invokespecial org.apache.cassandra.db.ReadCommand.<init>:(Lorg/apache/cassandra/db/ReadCommand$Kind;ZIZLorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/RowFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/schema/IndexMetadata;)V
1: aload 0
ldc 2147483647
putfield org.apache.cassandra.db.SinglePartitionReadCommand.oldestUnrepairedTombstone:I
2: getstatic org.apache.cassandra.db.SinglePartitionReadCommand.$assertionsDisabled:Z
ifne 3
aload 9
invokevirtual org.apache.cassandra.db.DecoratedKey.getPartitioner:()Lorg/apache/cassandra/dht/IPartitioner;
aload 4
getfield org.apache.cassandra.config.CFMetaData.partitioner:Lorg/apache/cassandra/dht/IPartitioner;
if_acmpeq 3
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
3: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand int int int org.apache.cassandra.config.CFMetaData int org.apache.cassandra.db.filter.ColumnFilter org.apache.cassandra.db.filter.RowFilter org.apache.cassandra.db.filter.DataLimits org.apache.cassandra.db.DecoratedKey org.apache.cassandra.db.filter.ClusteringIndexFilter org.apache.cassandra.schema.IndexMetadata
StackMap stack:
aload 0
aload 9
putfield org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:Lorg/apache/cassandra/db/DecoratedKey;
4: aload 0
aload 10
putfield org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
5: return
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 6 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 6 1 isDigest Z
0 6 2 digestVersion I
0 6 3 isForThrift Z
0 6 4 metadata Lorg/apache/cassandra/config/CFMetaData;
0 6 5 nowInSec I
0 6 6 columnFilter Lorg/apache/cassandra/db/filter/ColumnFilter;
0 6 7 rowFilter Lorg/apache/cassandra/db/filter/RowFilter;
0 6 8 limits Lorg/apache/cassandra/db/filter/DataLimits;
0 6 9 partitionKey Lorg/apache/cassandra/db/DecoratedKey;
0 6 10 clusteringIndexFilter Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
0 6 11 index Lorg/apache/cassandra/schema/IndexMetadata;
MethodParameters:
Name Flags
isDigest
digestVersion
isForThrift
metadata
nowInSec
columnFilter
rowFilter
limits
partitionKey
clusteringIndexFilter
index
public static org.apache.cassandra.db.SinglePartitionReadCommand create(boolean, org.apache.cassandra.config.CFMetaData, int, org.apache.cassandra.db.filter.ColumnFilter, org.apache.cassandra.db.filter.RowFilter, org.apache.cassandra.db.filter.DataLimits, org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.db.filter.ClusteringIndexFilter, org.apache.cassandra.schema.IndexMetadata);
descriptor: (ZLorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/RowFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/schema/IndexMetadata;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=13, locals=9, args_size=9
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 start local 8 0: new org.apache.cassandra.db.SinglePartitionReadCommand
dup
iconst_0
1: iconst_0
2: iload 0
3: aload 1
4: iload 2
5: aload 3
6: aload 4
7: aload 5
8: aload 6
9: aload 7
10: aload 8
11: invokespecial org.apache.cassandra.db.SinglePartitionReadCommand.<init>:(ZIZLorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/RowFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/schema/IndexMetadata;)V
areturn
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 12 0 isForThrift Z
0 12 1 metadata Lorg/apache/cassandra/config/CFMetaData;
0 12 2 nowInSec I
0 12 3 columnFilter Lorg/apache/cassandra/db/filter/ColumnFilter;
0 12 4 rowFilter Lorg/apache/cassandra/db/filter/RowFilter;
0 12 5 limits Lorg/apache/cassandra/db/filter/DataLimits;
0 12 6 partitionKey Lorg/apache/cassandra/db/DecoratedKey;
0 12 7 clusteringIndexFilter Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
0 12 8 indexMetadata Lorg/apache/cassandra/schema/IndexMetadata;
MethodParameters:
Name Flags
isForThrift
metadata
nowInSec
columnFilter
rowFilter
limits
partitionKey
clusteringIndexFilter
indexMetadata
public static org.apache.cassandra.db.SinglePartitionReadCommand create(org.apache.cassandra.config.CFMetaData, int, org.apache.cassandra.db.filter.ColumnFilter, org.apache.cassandra.db.filter.RowFilter, org.apache.cassandra.db.filter.DataLimits, org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.db.filter.ClusteringIndexFilter);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/RowFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=8, locals=7, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: iconst_0
aload 0
iload 1
aload 2
aload 3
aload 4
aload 5
aload 6
invokestatic org.apache.cassandra.db.SinglePartitionReadCommand.create:(ZLorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/RowFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
areturn
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 1 0 metadata Lorg/apache/cassandra/config/CFMetaData;
0 1 1 nowInSec I
0 1 2 columnFilter Lorg/apache/cassandra/db/filter/ColumnFilter;
0 1 3 rowFilter Lorg/apache/cassandra/db/filter/RowFilter;
0 1 4 limits Lorg/apache/cassandra/db/filter/DataLimits;
0 1 5 partitionKey Lorg/apache/cassandra/db/DecoratedKey;
0 1 6 clusteringIndexFilter Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
MethodParameters:
Name Flags
metadata
nowInSec
columnFilter
rowFilter
limits
partitionKey
clusteringIndexFilter
public static org.apache.cassandra.db.SinglePartitionReadCommand create(boolean, org.apache.cassandra.config.CFMetaData, int, org.apache.cassandra.db.filter.ColumnFilter, org.apache.cassandra.db.filter.RowFilter, org.apache.cassandra.db.filter.DataLimits, org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.db.filter.ClusteringIndexFilter);
descriptor: (ZLorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/RowFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=10, locals=8, args_size=8
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 0: iload 0
1: aload 1
2: iload 2
3: aload 3
4: aload 4
5: aload 5
6: aload 6
7: aload 7
8: aload 1
aload 4
invokestatic org.apache.cassandra.db.SinglePartitionReadCommand.findIndex:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/filter/RowFilter;)Lorg/apache/cassandra/schema/IndexMetadata;
9: invokestatic org.apache.cassandra.db.SinglePartitionReadCommand.create:(ZLorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/RowFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/schema/IndexMetadata;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
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 10 0 isForThrift Z
0 10 1 metadata Lorg/apache/cassandra/config/CFMetaData;
0 10 2 nowInSec I
0 10 3 columnFilter Lorg/apache/cassandra/db/filter/ColumnFilter;
0 10 4 rowFilter Lorg/apache/cassandra/db/filter/RowFilter;
0 10 5 limits Lorg/apache/cassandra/db/filter/DataLimits;
0 10 6 partitionKey Lorg/apache/cassandra/db/DecoratedKey;
0 10 7 clusteringIndexFilter Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
MethodParameters:
Name Flags
isForThrift
metadata
nowInSec
columnFilter
rowFilter
limits
partitionKey
clusteringIndexFilter
public static org.apache.cassandra.db.SinglePartitionReadCommand create(org.apache.cassandra.config.CFMetaData, int, org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.db.filter.ColumnFilter, org.apache.cassandra.db.filter.ClusteringIndexFilter);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=7, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
iload 1
aload 3
getstatic org.apache.cassandra.db.filter.RowFilter.NONE:Lorg/apache/cassandra/db/filter/RowFilter;
getstatic org.apache.cassandra.db.filter.DataLimits.NONE:Lorg/apache/cassandra/db/filter/DataLimits;
aload 2
aload 4
invokestatic org.apache.cassandra.db.SinglePartitionReadCommand.create:(Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/RowFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 metadata Lorg/apache/cassandra/config/CFMetaData;
0 1 1 nowInSec I
0 1 2 key Lorg/apache/cassandra/db/DecoratedKey;
0 1 3 columnFilter Lorg/apache/cassandra/db/filter/ColumnFilter;
0 1 4 filter Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
MethodParameters:
Name Flags
metadata
nowInSec
key
columnFilter
filter
public static org.apache.cassandra.db.SinglePartitionReadCommand fullPartitionRead(org.apache.cassandra.config.CFMetaData, int, org.apache.cassandra.db.DecoratedKey);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/DecoratedKey;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
iload 1
aload 2
getstatic org.apache.cassandra.db.Slices.ALL:Lorg/apache/cassandra/db/Slices;
invokestatic org.apache.cassandra.db.SinglePartitionReadCommand.create:(Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/Slices;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 metadata Lorg/apache/cassandra/config/CFMetaData;
0 1 1 nowInSec I
0 1 2 key Lorg/apache/cassandra/db/DecoratedKey;
MethodParameters:
Name Flags
metadata
nowInSec
key
public static org.apache.cassandra.db.SinglePartitionReadCommand fullPartitionRead(org.apache.cassandra.config.CFMetaData, int, java.nio.ByteBuffer);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;ILjava/nio/ByteBuffer;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
iload 1
aload 0
aload 2
invokevirtual org.apache.cassandra.config.CFMetaData.decorateKey:(Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/db/DecoratedKey;
getstatic org.apache.cassandra.db.Slices.ALL:Lorg/apache/cassandra/db/Slices;
invokestatic org.apache.cassandra.db.SinglePartitionReadCommand.create:(Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/Slices;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 metadata Lorg/apache/cassandra/config/CFMetaData;
0 1 1 nowInSec I
0 1 2 key Ljava/nio/ByteBuffer;
MethodParameters:
Name Flags
metadata
nowInSec
key
public static org.apache.cassandra.db.SinglePartitionReadCommand create(org.apache.cassandra.config.CFMetaData, int, org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.db.Slice);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/Slice;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
iload 1
aload 2
aload 0
getfield org.apache.cassandra.config.CFMetaData.comparator:Lorg/apache/cassandra/db/ClusteringComparator;
aload 3
invokestatic org.apache.cassandra.db.Slices.with:(Lorg/apache/cassandra/db/ClusteringComparator;Lorg/apache/cassandra/db/Slice;)Lorg/apache/cassandra/db/Slices;
invokestatic org.apache.cassandra.db.SinglePartitionReadCommand.create:(Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/Slices;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 metadata Lorg/apache/cassandra/config/CFMetaData;
0 1 1 nowInSec I
0 1 2 key Lorg/apache/cassandra/db/DecoratedKey;
0 1 3 slice Lorg/apache/cassandra/db/Slice;
MethodParameters:
Name Flags
metadata
nowInSec
key
slice
public static org.apache.cassandra.db.SinglePartitionReadCommand create(org.apache.cassandra.config.CFMetaData, int, org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.db.Slices);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/Slices;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=7, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new org.apache.cassandra.db.filter.ClusteringIndexSliceFilter
dup
aload 3
iconst_0
invokespecial org.apache.cassandra.db.filter.ClusteringIndexSliceFilter.<init>:(Lorg/apache/cassandra/db/Slices;Z)V
astore 4
start local 4 1: aload 0
iload 1
aload 0
invokestatic org.apache.cassandra.db.filter.ColumnFilter.all:(Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/db/filter/ColumnFilter;
getstatic org.apache.cassandra.db.filter.RowFilter.NONE:Lorg/apache/cassandra/db/filter/RowFilter;
getstatic org.apache.cassandra.db.filter.DataLimits.NONE:Lorg/apache/cassandra/db/filter/DataLimits;
aload 2
aload 4
invokestatic org.apache.cassandra.db.SinglePartitionReadCommand.create:(Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/RowFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
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 metadata Lorg/apache/cassandra/config/CFMetaData;
0 2 1 nowInSec I
0 2 2 key Lorg/apache/cassandra/db/DecoratedKey;
0 2 3 slices Lorg/apache/cassandra/db/Slices;
1 2 4 filter Lorg/apache/cassandra/db/filter/ClusteringIndexSliceFilter;
MethodParameters:
Name Flags
metadata
nowInSec
key
slices
public static org.apache.cassandra.db.SinglePartitionReadCommand create(org.apache.cassandra.config.CFMetaData, int, java.nio.ByteBuffer, org.apache.cassandra.db.Slices);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;ILjava/nio/ByteBuffer;Lorg/apache/cassandra/db/Slices;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
iload 1
aload 0
aload 2
invokevirtual org.apache.cassandra.config.CFMetaData.decorateKey:(Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/db/DecoratedKey;
aload 3
invokestatic org.apache.cassandra.db.SinglePartitionReadCommand.create:(Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/Slices;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 metadata Lorg/apache/cassandra/config/CFMetaData;
0 1 1 nowInSec I
0 1 2 key Ljava/nio/ByteBuffer;
0 1 3 slices Lorg/apache/cassandra/db/Slices;
MethodParameters:
Name Flags
metadata
nowInSec
key
slices
public static org.apache.cassandra.db.SinglePartitionReadCommand create(org.apache.cassandra.config.CFMetaData, int, org.apache.cassandra.db.DecoratedKey, java.util.NavigableSet<org.apache.cassandra.db.Clustering>);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/DecoratedKey;Ljava/util/NavigableSet;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=7, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new org.apache.cassandra.db.filter.ClusteringIndexNamesFilter
dup
aload 3
iconst_0
invokespecial org.apache.cassandra.db.filter.ClusteringIndexNamesFilter.<init>:(Ljava/util/NavigableSet;Z)V
astore 4
start local 4 1: aload 0
iload 1
aload 0
invokestatic org.apache.cassandra.db.filter.ColumnFilter.all:(Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/db/filter/ColumnFilter;
getstatic org.apache.cassandra.db.filter.RowFilter.NONE:Lorg/apache/cassandra/db/filter/RowFilter;
getstatic org.apache.cassandra.db.filter.DataLimits.NONE:Lorg/apache/cassandra/db/filter/DataLimits;
aload 2
aload 4
invokestatic org.apache.cassandra.db.SinglePartitionReadCommand.create:(Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/RowFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
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 metadata Lorg/apache/cassandra/config/CFMetaData;
0 2 1 nowInSec I
0 2 2 key Lorg/apache/cassandra/db/DecoratedKey;
0 2 3 names Ljava/util/NavigableSet<Lorg/apache/cassandra/db/Clustering;>;
1 2 4 filter Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;
Signature: (Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/DecoratedKey;Ljava/util/NavigableSet<Lorg/apache/cassandra/db/Clustering;>;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
MethodParameters:
Name Flags
metadata
nowInSec
key
names
public static org.apache.cassandra.db.SinglePartitionReadCommand create(org.apache.cassandra.config.CFMetaData, int, org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.db.Clustering);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/Clustering;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
iload 1
aload 2
aload 3
aload 0
getfield org.apache.cassandra.config.CFMetaData.comparator:Lorg/apache/cassandra/db/ClusteringComparator;
invokestatic org.apache.cassandra.utils.FBUtilities.singleton:(Ljava/lang/Object;Ljava/util/Comparator;)Ljava/util/NavigableSet;
invokestatic org.apache.cassandra.db.SinglePartitionReadCommand.create:(Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/DecoratedKey;Ljava/util/NavigableSet;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 metadata Lorg/apache/cassandra/config/CFMetaData;
0 1 1 nowInSec I
0 1 2 key Lorg/apache/cassandra/db/DecoratedKey;
0 1 3 name Lorg/apache/cassandra/db/Clustering;
MethodParameters:
Name Flags
metadata
nowInSec
key
name
public org.apache.cassandra.db.SinglePartitionReadCommand copy();
descriptor: ()Lorg/apache/cassandra/db/SinglePartitionReadCommand;
flags: (0x0001) ACC_PUBLIC
Code:
stack=13, locals=1, args_size=1
start local 0 0: new org.apache.cassandra.db.SinglePartitionReadCommand
dup
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.isDigestQuery:()Z
1: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.digestVersion:()I
2: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.isForThrift:()Z
3: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
4: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.nowInSec:()I
5: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
6: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.rowFilter:()Lorg/apache/cassandra/db/filter/RowFilter;
7: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
8: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
9: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
10: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.indexMetadata:()Lorg/apache/cassandra/schema/IndexMetadata;
11: invokespecial org.apache.cassandra.db.SinglePartitionReadCommand.<init>:(ZIZLorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/RowFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/schema/IndexMetadata;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
public org.apache.cassandra.db.SinglePartitionReadCommand copyAsDigestQuery();
descriptor: ()Lorg/apache/cassandra/db/SinglePartitionReadCommand;
flags: (0x0001) ACC_PUBLIC
Code:
stack=13, locals=1, args_size=1
start local 0 0: new org.apache.cassandra.db.SinglePartitionReadCommand
dup
iconst_1
1: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.digestVersion:()I
2: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.isForThrift:()Z
3: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
4: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.nowInSec:()I
5: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
6: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.rowFilter:()Lorg/apache/cassandra/db/filter/RowFilter;
7: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
8: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
9: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
10: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.indexMetadata:()Lorg/apache/cassandra/schema/IndexMetadata;
11: invokespecial org.apache.cassandra.db.SinglePartitionReadCommand.<init>:(ZIZLorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/RowFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/schema/IndexMetadata;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
public org.apache.cassandra.db.SinglePartitionReadCommand withUpdatedLimit(org.apache.cassandra.db.filter.DataLimits);
descriptor: (Lorg/apache/cassandra/db/filter/DataLimits;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
flags: (0x0001) ACC_PUBLIC
Code:
stack=13, locals=2, args_size=2
start local 0 start local 1 0: new org.apache.cassandra.db.SinglePartitionReadCommand
dup
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.isDigestQuery:()Z
1: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.digestVersion:()I
2: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.isForThrift:()Z
3: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
4: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.nowInSec:()I
5: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
6: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.rowFilter:()Lorg/apache/cassandra/db/filter/RowFilter;
7: aload 1
8: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
9: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
10: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.indexMetadata:()Lorg/apache/cassandra/schema/IndexMetadata;
11: invokespecial org.apache.cassandra.db.SinglePartitionReadCommand.<init>:(ZIZLorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/RowFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/schema/IndexMetadata;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 12 1 newLimits Lorg/apache/cassandra/db/filter/DataLimits;
MethodParameters:
Name Flags
newLimits
public org.apache.cassandra.db.SinglePartitionReadCommand withUpdatedClusteringIndexFilter(org.apache.cassandra.db.filter.ClusteringIndexFilter);
descriptor: (Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
flags: (0x0001) ACC_PUBLIC
Code:
stack=13, locals=2, args_size=2
start local 0 start local 1 0: new org.apache.cassandra.db.SinglePartitionReadCommand
dup
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.isDigestQuery:()Z
1: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.digestVersion:()I
2: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.isForThrift:()Z
3: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
4: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.nowInSec:()I
5: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
6: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.rowFilter:()Lorg/apache/cassandra/db/filter/RowFilter;
7: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
8: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
9: aload 1
10: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.indexMetadata:()Lorg/apache/cassandra/schema/IndexMetadata;
11: invokespecial org.apache.cassandra.db.SinglePartitionReadCommand.<init>:(ZIZLorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/RowFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/schema/IndexMetadata;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 12 1 filter Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
MethodParameters:
Name Flags
filter
static org.apache.cassandra.db.SinglePartitionReadCommand legacySliceCommand(boolean, int, org.apache.cassandra.config.CFMetaData, int, org.apache.cassandra.db.filter.ColumnFilter, org.apache.cassandra.db.filter.DataLimits, org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.db.filter.ClusteringIndexSliceFilter);
descriptor: (ZILorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ClusteringIndexSliceFilter;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
flags: (0x0008) ACC_STATIC
Code:
stack=13, locals=8, args_size=8
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 0: new org.apache.cassandra.db.SinglePartitionReadCommand
dup
iload 0
1: iload 1
2: iconst_1
3: aload 2
4: iload 3
5: aload 4
6: getstatic org.apache.cassandra.db.filter.RowFilter.NONE:Lorg/apache/cassandra/db/filter/RowFilter;
7: aload 5
8: aload 6
9: aload 7
10: aconst_null
11: invokespecial org.apache.cassandra.db.SinglePartitionReadCommand.<init>:(ZIZLorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/RowFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/schema/IndexMetadata;)V
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 12 0 isDigest Z
0 12 1 digestVersion I
0 12 2 metadata Lorg/apache/cassandra/config/CFMetaData;
0 12 3 nowInSec I
0 12 4 columnFilter Lorg/apache/cassandra/db/filter/ColumnFilter;
0 12 5 limits Lorg/apache/cassandra/db/filter/DataLimits;
0 12 6 partitionKey Lorg/apache/cassandra/db/DecoratedKey;
0 12 7 filter Lorg/apache/cassandra/db/filter/ClusteringIndexSliceFilter;
MethodParameters:
Name Flags
isDigest
digestVersion
metadata
nowInSec
columnFilter
limits
partitionKey
filter
static org.apache.cassandra.db.SinglePartitionReadCommand legacyNamesCommand(boolean, int, org.apache.cassandra.config.CFMetaData, int, org.apache.cassandra.db.filter.ColumnFilter, org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.db.filter.ClusteringIndexNamesFilter);
descriptor: (ZILorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
flags: (0x0008) ACC_STATIC
Code:
stack=13, locals=7, args_size=7
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 0: new org.apache.cassandra.db.SinglePartitionReadCommand
dup
iload 0
iload 1
iconst_1
aload 2
iload 3
aload 4
getstatic org.apache.cassandra.db.filter.RowFilter.NONE:Lorg/apache/cassandra/db/filter/RowFilter;
getstatic org.apache.cassandra.db.filter.DataLimits.NONE:Lorg/apache/cassandra/db/filter/DataLimits;
aload 5
aload 6
aconst_null
invokespecial org.apache.cassandra.db.SinglePartitionReadCommand.<init>:(ZIZLorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/RowFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/schema/IndexMetadata;)V
areturn
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 1 0 isDigest Z
0 1 1 digestVersion I
0 1 2 metadata Lorg/apache/cassandra/config/CFMetaData;
0 1 3 nowInSec I
0 1 4 columnFilter Lorg/apache/cassandra/db/filter/ColumnFilter;
0 1 5 partitionKey Lorg/apache/cassandra/db/DecoratedKey;
0 1 6 filter Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;
MethodParameters:
Name Flags
isDigest
digestVersion
metadata
nowInSec
columnFilter
partitionKey
filter
public org.apache.cassandra.db.DecoratedKey partitionKey();
descriptor: ()Lorg/apache/cassandra/db/DecoratedKey;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:Lorg/apache/cassandra/db/DecoratedKey;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
public org.apache.cassandra.db.filter.ClusteringIndexFilter clusteringIndexFilter();
descriptor: ()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
public org.apache.cassandra.db.filter.ClusteringIndexFilter clusteringIndexFilter(org.apache.cassandra.db.DecoratedKey);
descriptor: (Lorg/apache/cassandra/db/DecoratedKey;)Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 1 1 key Lorg/apache/cassandra/db/DecoratedKey;
MethodParameters:
Name Flags
key
public long getTimeout();
descriptor: ()J
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: invokestatic org.apache.cassandra.config.DatabaseDescriptor.getReadRpcTimeout:()J
lreturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
public boolean selectsKey(org.apache.cassandra.db.DecoratedKey);
descriptor: (Lorg/apache/cassandra/db/DecoratedKey;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
aload 1
invokevirtual org.apache.cassandra.db.DecoratedKey.equals:(Ljava/lang/Object;)Z
ifne 2
1: iconst_0
ireturn
2: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.rowFilter:()Lorg/apache/cassandra/db/filter/RowFilter;
aload 1
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.getKeyValidator:()Lorg/apache/cassandra/db/marshal/AbstractType;
invokevirtual org.apache.cassandra.db.filter.RowFilter.partitionKeyRestrictionsAreSatisfiedBy:(Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/marshal/AbstractType;)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 3 1 key Lorg/apache/cassandra/db/DecoratedKey;
MethodParameters:
Name Flags
key
public boolean selectsClustering(org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.db.Clustering);
descriptor: (Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/Clustering;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 2
getstatic org.apache.cassandra.db.Clustering.STATIC_CLUSTERING:Lorg/apache/cassandra/db/Clustering;
if_acmpne 4
1: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
invokevirtual org.apache.cassandra.db.filter.ColumnFilter.fetchedColumns:()Lorg/apache/cassandra/db/PartitionColumns;
getfield org.apache.cassandra.db.PartitionColumns.statics:Lorg/apache/cassandra/db/Columns;
invokevirtual org.apache.cassandra.db.Columns.isEmpty:()Z
ifeq 2
iconst_0
goto 3
StackMap locals:
StackMap stack:
2: iconst_1
StackMap locals:
StackMap stack: int
3: ireturn
4: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
aload 2
invokeinterface org.apache.cassandra.db.filter.ClusteringIndexFilter.selects:(Lorg/apache/cassandra/db/Clustering;)Z
ifne 6
5: iconst_0
ireturn
6: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.rowFilter:()Lorg/apache/cassandra/db/filter/RowFilter;
aload 2
invokevirtual org.apache.cassandra.db.filter.RowFilter.clusteringKeyRestrictionsAreSatisfiedBy:(Lorg/apache/cassandra/db/Clustering;)Z
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 7 1 key Lorg/apache/cassandra/db/DecoratedKey;
0 7 2 clustering Lorg/apache/cassandra/db/Clustering;
MethodParameters:
Name Flags
key
clustering
public org.apache.cassandra.db.SinglePartitionReadCommand forPaging(org.apache.cassandra.db.Clustering, org.apache.cassandra.db.filter.DataLimits);
descriptor: (Lorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/db/filter/DataLimits;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
flags: (0x0001) ACC_PUBLIC
Code:
stack=11, locals=3, args_size=3
start local 0 start local 1 start local 2 0: getstatic org.apache.cassandra.db.SinglePartitionReadCommand.$assertionsDisabled:Z
ifne 1
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.isDigestQuery:()Z
ifeq 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.isForThrift:()Z
2: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
3: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.nowInSec:()I
4: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
5: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.rowFilter:()Lorg/apache/cassandra/db/filter/RowFilter;
6: aload 2
7: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
8: aload 1
ifnonnull 9
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
goto 10
StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.Clustering org.apache.cassandra.db.filter.DataLimits
StackMap stack: int org.apache.cassandra.config.CFMetaData int org.apache.cassandra.db.filter.ColumnFilter org.apache.cassandra.db.filter.RowFilter org.apache.cassandra.db.filter.DataLimits org.apache.cassandra.db.DecoratedKey
9: aload 0
getfield org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.comparator:Lorg/apache/cassandra/db/ClusteringComparator;
aload 1
iconst_0
invokeinterface org.apache.cassandra.db.filter.ClusteringIndexFilter.forPaging:(Lorg/apache/cassandra/db/ClusteringComparator;Lorg/apache/cassandra/db/Clustering;Z)Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
10: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.Clustering org.apache.cassandra.db.filter.DataLimits
StackMap stack: int org.apache.cassandra.config.CFMetaData int org.apache.cassandra.db.filter.ColumnFilter org.apache.cassandra.db.filter.RowFilter org.apache.cassandra.db.filter.DataLimits org.apache.cassandra.db.DecoratedKey org.apache.cassandra.db.filter.ClusteringIndexFilter
invokestatic org.apache.cassandra.db.SinglePartitionReadCommand.create:(ZLorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/RowFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 11 1 lastReturned Lorg/apache/cassandra/db/Clustering;
0 11 2 limits Lorg/apache/cassandra/db/filter/DataLimits;
MethodParameters:
Name Flags
lastReturned
limits
public org.apache.cassandra.db.partitions.PartitionIterator execute(org.apache.cassandra.db.ConsistencyLevel, org.apache.cassandra.service.ClientState, long);
descriptor: (Lorg/apache/cassandra/db/ConsistencyLevel;Lorg/apache/cassandra/service/ClientState;J)Lorg/apache/cassandra/db/partitions/PartitionIterator;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokestatic org.apache.cassandra.db.SinglePartitionReadCommand$Group.one:(Lorg/apache/cassandra/db/SinglePartitionReadCommand;)Lorg/apache/cassandra/db/SinglePartitionReadCommand$Group;
aload 1
aload 2
lload 3
invokestatic org.apache.cassandra.service.StorageProxy.read:(Lorg/apache/cassandra/db/SinglePartitionReadCommand$Group;Lorg/apache/cassandra/db/ConsistencyLevel;Lorg/apache/cassandra/service/ClientState;J)Lorg/apache/cassandra/db/partitions/PartitionIterator;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 1 1 consistency Lorg/apache/cassandra/db/ConsistencyLevel;
0 1 2 clientState Lorg/apache/cassandra/service/ClientState;
0 1 3 queryStartNanoTime J
Exceptions:
throws org.apache.cassandra.exceptions.RequestExecutionException
MethodParameters:
Name Flags
consistency
clientState
queryStartNanoTime
public org.apache.cassandra.service.pager.SinglePartitionPager getPager(org.apache.cassandra.service.pager.PagingState, org.apache.cassandra.transport.ProtocolVersion);
descriptor: (Lorg/apache/cassandra/service/pager/PagingState;Lorg/apache/cassandra/transport/ProtocolVersion;)Lorg/apache/cassandra/service/pager/SinglePartitionPager;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
invokestatic org.apache.cassandra.db.SinglePartitionReadCommand.getPager:(Lorg/apache/cassandra/db/SinglePartitionReadCommand;Lorg/apache/cassandra/service/pager/PagingState;Lorg/apache/cassandra/transport/ProtocolVersion;)Lorg/apache/cassandra/service/pager/SinglePartitionPager;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 1 1 pagingState Lorg/apache/cassandra/service/pager/PagingState;
0 1 2 protocolVersion Lorg/apache/cassandra/transport/ProtocolVersion;
MethodParameters:
Name Flags
pagingState
protocolVersion
private static org.apache.cassandra.service.pager.SinglePartitionPager getPager(org.apache.cassandra.db.SinglePartitionReadCommand, org.apache.cassandra.service.pager.PagingState, org.apache.cassandra.transport.ProtocolVersion);
descriptor: (Lorg/apache/cassandra/db/SinglePartitionReadCommand;Lorg/apache/cassandra/service/pager/PagingState;Lorg/apache/cassandra/transport/ProtocolVersion;)Lorg/apache/cassandra/service/pager/SinglePartitionPager;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: new org.apache.cassandra.service.pager.SinglePartitionPager
dup
aload 0
aload 1
aload 2
invokespecial org.apache.cassandra.service.pager.SinglePartitionPager.<init>:(Lorg/apache/cassandra/db/SinglePartitionReadCommand;Lorg/apache/cassandra/service/pager/PagingState;Lorg/apache/cassandra/transport/ProtocolVersion;)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 command Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 1 1 pagingState Lorg/apache/cassandra/service/pager/PagingState;
0 1 2 protocolVersion Lorg/apache/cassandra/transport/ProtocolVersion;
MethodParameters:
Name Flags
command
pagingState
protocolVersion
protected void recordLatency(org.apache.cassandra.metrics.TableMetrics, long);
descriptor: (Lorg/apache/cassandra/metrics/TableMetrics;J)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 1
getfield org.apache.cassandra.metrics.TableMetrics.readLatency:Lorg/apache/cassandra/metrics/LatencyMetrics;
lload 2
invokevirtual org.apache.cassandra.metrics.LatencyMetrics.addNano:(J)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 2 1 metric Lorg/apache/cassandra/metrics/TableMetrics;
0 2 2 latencyNanos J
MethodParameters:
Name Flags
metric
latencyNanos
protected org.apache.cassandra.db.partitions.UnfilteredPartitionIterator queryStorage(org.apache.cassandra.db.ColumnFamilyStore, org.apache.cassandra.db.ReadExecutionController);
descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
flags: (0x0004) ACC_PROTECTED
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.isRowCacheEnabled:()Z
ifeq 2
1: aload 0
aload 1
aload 2
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.getThroughCache:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
goto 3
2: StackMap locals:
StackMap stack:
aload 0
aload 1
aload 2
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.queryMemtableAndDisk:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
3: StackMap locals:
StackMap stack: org.apache.cassandra.db.rows.UnfilteredRowIterator
astore 3
start local 3 4: new org.apache.cassandra.db.partitions.SingletonUnfilteredPartitionIterator
dup
aload 3
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.isForThrift:()Z
invokespecial org.apache.cassandra.db.partitions.SingletonUnfilteredPartitionIterator.<init>:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Z)V
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 5 1 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
0 5 2 executionController Lorg/apache/cassandra/db/ReadExecutionController;
4 5 3 partition Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
MethodParameters:
Name Flags
cfs final
executionController
private org.apache.cassandra.db.rows.UnfilteredRowIterator getThroughCache(org.apache.cassandra.db.ColumnFamilyStore, org.apache.cassandra.db.ReadExecutionController);
descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
flags: (0x0002) ACC_PRIVATE
Code:
stack=7, locals=17, args_size=3
start local 0 start local 1 start local 2 0: getstatic org.apache.cassandra.db.SinglePartitionReadCommand.$assertionsDisabled:Z
ifne 1
aload 1
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.isIndex:()Z
ifeq 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.db.SinglePartitionReadCommand.$assertionsDisabled:Z
ifne 2
aload 1
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.isRowCacheEnabled:()Z
ifne 2
new java.lang.AssertionError
dup
ldc "Row cache is not enabled on table [%s]"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 1
getfield org.apache.cassandra.db.ColumnFamilyStore.name:Ljava/lang/String;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
2: StackMap locals:
StackMap stack:
new org.apache.cassandra.cache.RowCacheKey
dup
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.ksAndCFName:Lorg/apache/cassandra/utils/Pair;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokespecial org.apache.cassandra.cache.RowCacheKey.<init>:(Lorg/apache/cassandra/utils/Pair;Lorg/apache/cassandra/db/DecoratedKey;)V
astore 3
start local 3 3: getstatic org.apache.cassandra.service.CacheService.instance:Lorg/apache/cassandra/service/CacheService;
getfield org.apache.cassandra.service.CacheService.rowCache:Lorg/apache/cassandra/cache/AutoSavingCache;
aload 3
invokevirtual org.apache.cassandra.cache.AutoSavingCache.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.cache.IRowCacheEntry
astore 4
start local 4 4: aload 4
ifnull 19
5: aload 4
instanceof org.apache.cassandra.cache.RowCacheSentinel
ifeq 9
6: ldc "Row cache miss (race)"
invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;)V
7: aload 1
getfield org.apache.cassandra.db.ColumnFamilyStore.metric:Lorg/apache/cassandra/metrics/TableMetrics;
getfield org.apache.cassandra.metrics.TableMetrics.rowCacheMiss:Lcom/codahale/metrics/Counter;
invokevirtual com.codahale.metrics.Counter.inc:()V
8: aload 0
aload 1
aload 2
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.queryMemtableAndDisk:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
areturn
9: StackMap locals: org.apache.cassandra.cache.RowCacheKey org.apache.cassandra.cache.IRowCacheEntry
StackMap stack:
aload 4
checkcast org.apache.cassandra.db.partitions.CachedPartition
astore 5
start local 5 10: aload 1
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
aload 5
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.nowInSec:()I
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.isFilterFullyCoveredBy:(Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/db/filter/DataLimits;Lorg/apache/cassandra/db/partitions/CachedPartition;I)Z
ifeq 16
11: aload 1
getfield org.apache.cassandra.db.ColumnFamilyStore.metric:Lorg/apache/cassandra/metrics/TableMetrics;
getfield org.apache.cassandra.metrics.TableMetrics.rowCacheHit:Lcom/codahale/metrics/Counter;
invokevirtual com.codahale.metrics.Counter.inc:()V
12: ldc "Row cache hit"
invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;)V
13: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
aload 5
invokeinterface org.apache.cassandra.db.filter.ClusteringIndexFilter.getUnfilteredRowIterator:(Lorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/partitions/Partition;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
astore 6
start local 6 14: aload 1
getfield org.apache.cassandra.db.ColumnFamilyStore.metric:Lorg/apache/cassandra/metrics/TableMetrics;
iconst_0
invokevirtual org.apache.cassandra.metrics.TableMetrics.updateSSTableIterated:(I)V
15: aload 6
areturn
end local 6 16: StackMap locals: org.apache.cassandra.db.partitions.CachedPartition
StackMap stack:
aload 1
getfield org.apache.cassandra.db.ColumnFamilyStore.metric:Lorg/apache/cassandra/metrics/TableMetrics;
getfield org.apache.cassandra.metrics.TableMetrics.rowCacheHitOutOfRange:Lcom/codahale/metrics/Counter;
invokevirtual com.codahale.metrics.Counter.inc:()V
17: ldc "Ignoring row cache as cached value could not satisfy query"
invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;)V
18: aload 0
aload 1
aload 2
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.queryMemtableAndDisk:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
areturn
end local 5 19: StackMap locals:
StackMap stack:
aload 1
getfield org.apache.cassandra.db.ColumnFamilyStore.metric:Lorg/apache/cassandra/metrics/TableMetrics;
getfield org.apache.cassandra.metrics.TableMetrics.rowCacheMiss:Lcom/codahale/metrics/Counter;
invokevirtual com.codahale.metrics.Counter.inc:()V
20: ldc "Row cache miss"
invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;)V
21: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.clusteringColumns:()Ljava/util/List;
invokeinterface java.util.List.size:()I
ifle 23
22: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.params:Lorg/apache/cassandra/schema/TableParams;
getfield org.apache.cassandra.schema.TableParams.caching:Lorg/apache/cassandra/schema/CachingParams;
invokevirtual org.apache.cassandra.schema.CachingParams.cacheAllRows:()Z
goto 24
23: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.params:Lorg/apache/cassandra/schema/TableParams;
getfield org.apache.cassandra.schema.TableParams.caching:Lorg/apache/cassandra/schema/CachingParams;
invokevirtual org.apache.cassandra.schema.CachingParams.cacheRows:()Z
24: StackMap locals:
StackMap stack: int
istore 5
start local 5 25: iload 5
ifne 26
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
invokeinterface org.apache.cassandra.db.filter.ClusteringIndexFilter.isHeadFilter:()Z
ifeq 57
26: StackMap locals: int
StackMap stack:
new org.apache.cassandra.cache.RowCacheSentinel
dup
invokespecial org.apache.cassandra.cache.RowCacheSentinel.<init>:()V
astore 6
start local 6 27: getstatic org.apache.cassandra.service.CacheService.instance:Lorg/apache/cassandra/service/CacheService;
getfield org.apache.cassandra.service.CacheService.rowCache:Lorg/apache/cassandra/cache/AutoSavingCache;
aload 3
aload 6
invokevirtual org.apache.cassandra.cache.AutoSavingCache.putIfAbsent:(Ljava/lang/Object;Ljava/lang/Object;)Z
istore 7
start local 7 28: iconst_0
istore 8
start local 8 29: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.params:Lorg/apache/cassandra/schema/TableParams;
getfield org.apache.cassandra.schema.TableParams.caching:Lorg/apache/cassandra/schema/CachingParams;
invokevirtual org.apache.cassandra.schema.CachingParams.rowsPerPartitionToCache:()I
istore 9
start local 9 30: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.enforceStrictLiveness:()Z
istore 10
start local 10 31: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.nowInSec:()I
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokestatic org.apache.cassandra.db.SinglePartitionReadCommand.fullPartitionRead:(Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/DecoratedKey;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
aload 1
aload 2
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.queryMemtableAndDisk:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
astore 11
start local 11 32: new org.apache.cassandra.db.SinglePartitionReadCommand$1
dup
aload 0
aload 11
iload 9
iload 10
invokespecial org.apache.cassandra.db.SinglePartitionReadCommand$1.<init>:(Lorg/apache/cassandra/db/SinglePartitionReadCommand;Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;IZ)V
astore 12
start local 12 33: aload 12
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.nowInSec:()I
invokestatic org.apache.cassandra.db.partitions.CachedBTreePartition.create:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;I)Lorg/apache/cassandra/db/partitions/CachedBTreePartition;
astore 13
start local 13 34: iload 7
ifeq 38
aload 13
invokeinterface org.apache.cassandra.db.partitions.CachedPartition.isEmpty:()Z
ifne 38
35: ldc "Caching {} rows"
aload 13
invokeinterface org.apache.cassandra.db.partitions.CachedPartition.rowCount:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;Ljava/lang/Object;)V
36: getstatic org.apache.cassandra.service.CacheService.instance:Lorg/apache/cassandra/service/CacheService;
getfield org.apache.cassandra.service.CacheService.rowCache:Lorg/apache/cassandra/cache/AutoSavingCache;
aload 3
aload 6
aload 13
invokevirtual org.apache.cassandra.cache.AutoSavingCache.replace:(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
pop
37: iconst_1
istore 8
38: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ReadExecutionController org.apache.cassandra.cache.RowCacheKey org.apache.cassandra.cache.IRowCacheEntry int org.apache.cassandra.cache.RowCacheSentinel int int int int org.apache.cassandra.db.rows.UnfilteredRowIterator org.apache.cassandra.db.rows.UnfilteredRowIterator org.apache.cassandra.db.partitions.CachedPartition
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
aload 13
invokeinterface org.apache.cassandra.db.filter.ClusteringIndexFilter.getUnfilteredRowIterator:(Lorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/partitions/Partition;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
astore 14
start local 14 39: iload 5
ifeq 46
40: getstatic org.apache.cassandra.db.SinglePartitionReadCommand.$assertionsDisabled:Z
ifne 41
aload 11
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.hasNext:()Z
ifeq 41
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
41: StackMap locals: org.apache.cassandra.db.rows.UnfilteredRowIterator
StackMap stack:
aload 11
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
42: aload 14
astore 16
43: iload 7
ifeq 45
iload 8
ifne 45
44: aload 1
aload 3
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.invalidateCachedPartition:(Lorg/apache/cassandra/cache/RowCacheKey;)V
45: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ReadExecutionController org.apache.cassandra.cache.RowCacheKey org.apache.cassandra.cache.IRowCacheEntry int org.apache.cassandra.cache.RowCacheSentinel int int int int org.apache.cassandra.db.rows.UnfilteredRowIterator org.apache.cassandra.db.rows.UnfilteredRowIterator org.apache.cassandra.db.partitions.CachedPartition org.apache.cassandra.db.rows.UnfilteredRowIterator top org.apache.cassandra.db.rows.UnfilteredRowIterator
StackMap stack:
aload 16
areturn
46: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ReadExecutionController org.apache.cassandra.cache.RowCacheKey org.apache.cassandra.cache.IRowCacheEntry int org.apache.cassandra.cache.RowCacheSentinel int int int int org.apache.cassandra.db.rows.UnfilteredRowIterator org.apache.cassandra.db.rows.UnfilteredRowIterator org.apache.cassandra.db.partitions.CachedPartition org.apache.cassandra.db.rows.UnfilteredRowIterator
StackMap stack:
aload 14
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
aload 11
invokeinterface org.apache.cassandra.db.filter.ClusteringIndexFilter.filterNotIndexed:(Lorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
invokestatic org.apache.cassandra.db.rows.UnfilteredRowIterators.concat:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
astore 16
47: iload 7
ifeq 49
iload 8
ifne 49
48: aload 1
aload 3
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.invalidateCachedPartition:(Lorg/apache/cassandra/cache/RowCacheKey;)V
49: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ReadExecutionController org.apache.cassandra.cache.RowCacheKey org.apache.cassandra.cache.IRowCacheEntry int org.apache.cassandra.cache.RowCacheSentinel int int int int org.apache.cassandra.db.rows.UnfilteredRowIterator org.apache.cassandra.db.rows.UnfilteredRowIterator org.apache.cassandra.db.partitions.CachedPartition org.apache.cassandra.db.rows.UnfilteredRowIterator top org.apache.cassandra.db.rows.UnfilteredRowIterator
StackMap stack:
aload 16
areturn
end local 14 end local 13 end local 12 50: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ReadExecutionController org.apache.cassandra.cache.RowCacheKey org.apache.cassandra.cache.IRowCacheEntry int org.apache.cassandra.cache.RowCacheSentinel int int int int org.apache.cassandra.db.rows.UnfilteredRowIterator
StackMap stack: java.lang.Throwable
astore 12
start local 12 51: aload 11
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
52: aload 12
athrow
end local 12 end local 11 end local 10 end local 9 53: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ReadExecutionController org.apache.cassandra.cache.RowCacheKey org.apache.cassandra.cache.IRowCacheEntry int org.apache.cassandra.cache.RowCacheSentinel int int
StackMap stack: java.lang.Throwable
astore 15
54: iload 7
ifeq 56
iload 8
ifne 56
55: aload 1
aload 3
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.invalidateCachedPartition:(Lorg/apache/cassandra/cache/RowCacheKey;)V
56: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ReadExecutionController org.apache.cassandra.cache.RowCacheKey org.apache.cassandra.cache.IRowCacheEntry int org.apache.cassandra.cache.RowCacheSentinel int int top top top top top top java.lang.Throwable
StackMap stack:
aload 15
athrow
end local 8 end local 7 end local 6 57: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ReadExecutionController org.apache.cassandra.cache.RowCacheKey org.apache.cassandra.cache.IRowCacheEntry int
StackMap stack:
ldc "Fetching data but not populating cache as query does not query from the start of the partition"
invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;)V
58: aload 0
aload 1
aload 2
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.queryMemtableAndDisk:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
areturn
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 59 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 59 1 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
0 59 2 executionController Lorg/apache/cassandra/db/ReadExecutionController;
3 59 3 key Lorg/apache/cassandra/cache/RowCacheKey;
4 59 4 cached Lorg/apache/cassandra/cache/IRowCacheEntry;
10 19 5 cachedPartition Lorg/apache/cassandra/db/partitions/CachedPartition;
14 16 6 unfilteredRowIterator Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
25 59 5 cacheFullPartitions Z
27 57 6 sentinel Lorg/apache/cassandra/cache/RowCacheSentinel;
28 57 7 sentinelSuccess Z
29 57 8 sentinelReplaced Z
30 53 9 rowsToCache I
31 53 10 enforceStrictLiveness Z
32 53 11 iter Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
33 50 12 toCacheIterator Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
34 50 13 toCache Lorg/apache/cassandra/db/partitions/CachedPartition;
39 50 14 cacheIterator Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
51 53 12 e Ljava/lang/Throwable;
Exception table:
from to target type
32 43 50 Class java.lang.RuntimeException
46 47 50 Class java.lang.RuntimeException
32 43 50 Class java.lang.Error
46 47 50 Class java.lang.Error
29 43 53 any
46 47 53 any
50 53 53 any
MethodParameters:
Name Flags
cfs
executionController
public org.apache.cassandra.db.rows.UnfilteredRowIterator queryMemtableAndDisk(org.apache.cassandra.db.ColumnFamilyStore, org.apache.cassandra.db.ReadExecutionController);
descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: getstatic org.apache.cassandra.db.SinglePartitionReadCommand.$assertionsDisabled:Z
ifne 2
aload 2
ifnull 1
aload 2
aload 1
invokevirtual org.apache.cassandra.db.ReadExecutionController.validForReadOn:(Lorg/apache/cassandra/db/ColumnFamilyStore;)Z
ifne 2
StackMap locals:
StackMap stack:
1: new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
2: StackMap locals:
StackMap stack:
ldc "Executing single-partition query on {}"
aload 1
getfield org.apache.cassandra.db.ColumnFamilyStore.name:Ljava/lang/String;
invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;Ljava/lang/Object;)V
3: aload 0
aload 1
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.queryMemtableAndDiskInternal:(Lorg/apache/cassandra/db/ColumnFamilyStore;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 4 1 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
0 4 2 executionController Lorg/apache/cassandra/db/ReadExecutionController;
MethodParameters:
Name Flags
cfs
executionController
protected int oldestUnrepairedTombstone();
descriptor: ()I
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.SinglePartitionReadCommand.oldestUnrepairedTombstone:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
private org.apache.cassandra.db.rows.UnfilteredRowIterator queryMemtableAndDiskInternal(org.apache.cassandra.db.ColumnFamilyStore);
descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=16, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
instanceof org.apache.cassandra.db.filter.ClusteringIndexNamesFilter
ifeq 2
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.queriesMulticellType:()Z
ifne 2
1: aload 0
aload 1
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
checkcast org.apache.cassandra.db.filter.ClusteringIndexNamesFilter
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.queryMemtableAndSSTablesInTimestampOrder:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
areturn
2: StackMap locals:
StackMap stack:
ldc "Acquiring sstable references"
invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;)V
3: aload 1
getstatic org.apache.cassandra.db.lifecycle.SSTableSet.LIVE:Lorg/apache/cassandra/db/lifecycle/SSTableSet;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokestatic org.apache.cassandra.db.lifecycle.View.select:(Lorg/apache/cassandra/db/lifecycle/SSTableSet;Lorg/apache/cassandra/db/DecoratedKey;)Lcom/google/common/base/Function;
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.select:(Lcom/google/common/base/Function;)Lorg/apache/cassandra/db/ColumnFamilyStore$ViewFragment;
astore 2
start local 2 4: new java.util.ArrayList
dup
aload 2
getfield org.apache.cassandra.db.ColumnFamilyStore$ViewFragment.memtables:Ljava/lang/Iterable;
invokestatic com.google.common.collect.Iterables.size:(Ljava/lang/Iterable;)I
aload 2
getfield org.apache.cassandra.db.ColumnFamilyStore$ViewFragment.sstables:Ljava/util/List;
invokeinterface java.util.List.size:()I
iadd
invokespecial java.util.ArrayList.<init>:(I)V
astore 3
start local 3 5: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
astore 4
start local 4 6: ldc 9223372036854775807
lstore 5
start local 5 7: aload 2
getfield org.apache.cassandra.db.ColumnFamilyStore$ViewFragment.memtables:Ljava/lang/Iterable;
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 8
goto 18
StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ColumnFamilyStore$ViewFragment java.util.List org.apache.cassandra.db.filter.ClusteringIndexFilter long top java.util.Iterator
StackMap stack:
8: aload 8
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.Memtable
astore 7
start local 7 9: aload 7
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.Memtable.getPartition:(Lorg/apache/cassandra/db/DecoratedKey;)Lorg/apache/cassandra/db/partitions/Partition;
astore 9
start local 9 10: aload 9
ifnonnull 12
11: goto 18
12: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ColumnFamilyStore$ViewFragment java.util.List org.apache.cassandra.db.filter.ClusteringIndexFilter long org.apache.cassandra.db.Memtable java.util.Iterator org.apache.cassandra.db.partitions.Partition
StackMap stack:
lload 5
aload 7
invokevirtual org.apache.cassandra.db.Memtable.getMinTimestamp:()J
invokestatic java.lang.Math.min:(JJ)J
lstore 5
13: aload 4
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
aload 9
invokeinterface org.apache.cassandra.db.filter.ClusteringIndexFilter.getUnfilteredRowIterator:(Lorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/partitions/Partition;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
astore 10
start local 10 14: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.isForThrift:()Z
ifeq 16
15: aload 10
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.nowInSec:()I
invokestatic org.apache.cassandra.thrift.ThriftResultsMerger.maybeWrap:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;I)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
astore 10
16: StackMap locals: org.apache.cassandra.db.rows.UnfilteredRowIterator
StackMap stack:
aload 0
aload 0
getfield org.apache.cassandra.db.SinglePartitionReadCommand.oldestUnrepairedTombstone:I
aload 9
invokeinterface org.apache.cassandra.db.partitions.Partition.stats:()Lorg/apache/cassandra/db/rows/EncodingStats;
getfield org.apache.cassandra.db.rows.EncodingStats.minLocalDeletionTime:I
invokestatic java.lang.Math.min:(II)I
putfield org.apache.cassandra.db.SinglePartitionReadCommand.oldestUnrepairedTombstone:I
17: aload 3
aload 10
getstatic org.apache.cassandra.db.transform.RTBoundValidator$Stage.MEMTABLE:Lorg/apache/cassandra/db/transform/RTBoundValidator$Stage;
iconst_0
invokestatic org.apache.cassandra.db.transform.RTBoundValidator.validate:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/db/transform/RTBoundValidator$Stage;Z)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 10 end local 9 end local 7 18: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ColumnFamilyStore$ViewFragment java.util.List org.apache.cassandra.db.filter.ClusteringIndexFilter long top java.util.Iterator
StackMap stack:
aload 8
invokeinterface java.util.Iterator.hasNext:()Z
ifne 8
19: aload 2
getfield org.apache.cassandra.db.ColumnFamilyStore$ViewFragment.sstables:Ljava/util/List;
getstatic org.apache.cassandra.io.sstable.format.SSTableReader.maxTimestampDescending:Ljava/util/Comparator;
invokestatic java.util.Collections.sort:(Ljava/util/List;Ljava/util/Comparator;)V
20: ldc -9223372036854775808
lstore 7
start local 7 21: iconst_0
istore 9
start local 9 22: aconst_null
astore 10
start local 10 23: new org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector
dup
invokespecial org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector.<init>:()V
astore 11
start local 11 24: aload 2
getfield org.apache.cassandra.db.ColumnFamilyStore$ViewFragment.sstables:Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 13
goto 43
StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ColumnFamilyStore$ViewFragment java.util.List org.apache.cassandra.db.filter.ClusteringIndexFilter long long int java.util.List org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector top java.util.Iterator
StackMap stack:
25: aload 13
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 12
start local 12 26: aload 12
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getMaxTimestamp:()J
lload 7
lcmp
ifge 28
27: goto 44
28: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ColumnFamilyStore$ViewFragment java.util.List org.apache.cassandra.db.filter.ClusteringIndexFilter long long int java.util.List org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator
StackMap stack:
aload 0
aload 12
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.shouldInclude:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Z
ifne 35
29: iinc 9 1
30: aload 12
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.mayHaveTombstones:()Z
ifeq 43
31: aload 10
ifnonnull 33
32: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 10
33: StackMap locals:
StackMap stack:
aload 10
aload 12
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
34: goto 43
35: StackMap locals:
StackMap stack:
lload 5
aload 12
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getMinTimestamp:()J
invokestatic java.lang.Math.min:(JJ)J
lstore 5
36: aload 0
aload 1
aload 12
iconst_1
aload 11
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.makeIterator:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/io/sstable/format/SSTableReader;ZLorg/apache/cassandra/io/sstable/format/SSTableReadsListener;)Lorg/apache/cassandra/db/rows/UnfilteredRowIteratorWithLowerBound;
astore 14
start local 14 37: aload 12
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.isRepaired:()Z
ifne 39
38: aload 0
aload 0
getfield org.apache.cassandra.db.SinglePartitionReadCommand.oldestUnrepairedTombstone:I
aload 12
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getMinLocalDeletionTime:()I
invokestatic java.lang.Math.min:(II)I
putfield org.apache.cassandra.db.SinglePartitionReadCommand.oldestUnrepairedTombstone:I
39: StackMap locals: org.apache.cassandra.db.rows.UnfilteredRowIteratorWithLowerBound
StackMap stack:
aload 3
aload 14
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
40: lload 7
41: aload 14
invokevirtual org.apache.cassandra.db.rows.UnfilteredRowIteratorWithLowerBound.partitionLevelDeletion:()Lorg/apache/cassandra/db/DeletionTime;
invokevirtual org.apache.cassandra.db.DeletionTime.markedForDeleteAt:()J
42: invokestatic java.lang.Math.max:(JJ)J
lstore 7
end local 14 end local 12 43: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ColumnFamilyStore$ViewFragment java.util.List org.apache.cassandra.db.filter.ClusteringIndexFilter long long int java.util.List org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector top java.util.Iterator
StackMap stack:
aload 13
invokeinterface java.util.Iterator.hasNext:()Z
ifne 25
44: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ColumnFamilyStore$ViewFragment java.util.List org.apache.cassandra.db.filter.ClusteringIndexFilter long long int java.util.List org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector
StackMap stack:
iconst_0
istore 12
start local 12 45: aload 10
ifnull 56
46: aload 10
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 14
goto 55
StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ColumnFamilyStore$ViewFragment java.util.List org.apache.cassandra.db.filter.ClusteringIndexFilter long long int java.util.List org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector int top java.util.Iterator
StackMap stack:
47: aload 14
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 13
start local 13 48: aload 13
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getMaxTimestamp:()J
lload 5
lcmp
ifgt 50
49: goto 55
50: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ColumnFamilyStore$ViewFragment java.util.List org.apache.cassandra.db.filter.ClusteringIndexFilter long long int java.util.List org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector int org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator
StackMap stack:
aload 0
aload 1
aload 13
iconst_0
aload 11
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.makeIterator:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/io/sstable/format/SSTableReader;ZLorg/apache/cassandra/io/sstable/format/SSTableReadsListener;)Lorg/apache/cassandra/db/rows/UnfilteredRowIteratorWithLowerBound;
astore 15
start local 15 51: aload 13
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.isRepaired:()Z
ifne 53
52: aload 0
aload 0
getfield org.apache.cassandra.db.SinglePartitionReadCommand.oldestUnrepairedTombstone:I
aload 13
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getMinLocalDeletionTime:()I
invokestatic java.lang.Math.min:(II)I
putfield org.apache.cassandra.db.SinglePartitionReadCommand.oldestUnrepairedTombstone:I
53: StackMap locals: org.apache.cassandra.db.rows.UnfilteredRowIteratorWithLowerBound
StackMap stack:
aload 3
aload 15
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
54: iinc 12 1
end local 15 end local 13 55: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ColumnFamilyStore$ViewFragment java.util.List org.apache.cassandra.db.filter.ClusteringIndexFilter long long int java.util.List org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector int top java.util.Iterator
StackMap stack:
aload 14
invokeinterface java.util.Iterator.hasNext:()Z
ifne 47
56: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ColumnFamilyStore$ViewFragment java.util.List org.apache.cassandra.db.filter.ClusteringIndexFilter long long int java.util.List org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector int
StackMap stack:
invokestatic org.apache.cassandra.tracing.Tracing.isTracing:()Z
ifeq 60
57: ldc "Skipped {}/{} non-slice-intersecting sstables, included {} due to tombstones"
iconst_3
anewarray java.lang.Object
dup
iconst_0
58: iload 9
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
aload 2
getfield org.apache.cassandra.db.ColumnFamilyStore$ViewFragment.sstables:Ljava/util/List;
invokeinterface java.util.List.size:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_2
iload 12
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
59: invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;[Ljava/lang/Object;)V
60: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.List.isEmpty:()Z
ifeq 63
61: aload 1
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
aload 4
invokeinterface org.apache.cassandra.db.filter.ClusteringIndexFilter.isReversed:()Z
invokestatic org.apache.cassandra.db.EmptyIterators.unfilteredRow:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/DecoratedKey;Z)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
62: areturn
63: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.db.StorageHook.instance:Lorg/apache/cassandra/db/StorageHook;
aload 1
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokeinterface org.apache.cassandra.db.StorageHook.reportRead:(Ljava/util/UUID;Lorg/apache/cassandra/db/DecoratedKey;)V
64: aload 0
aload 3
aload 1
getfield org.apache.cassandra.db.ColumnFamilyStore.metric:Lorg/apache/cassandra/metrics/TableMetrics;
aload 11
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.withSSTablesIterated:(Ljava/util/List;Lorg/apache/cassandra/metrics/TableMetrics;Lorg/apache/cassandra/db/SinglePartitionReadCommand$SSTableReadMetricsCollector;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
65: areturn
end local 12 end local 11 end local 10 end local 9 end local 7 66: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ColumnFamilyStore$ViewFragment java.util.List org.apache.cassandra.db.filter.ClusteringIndexFilter long
StackMap stack: java.lang.Throwable
astore 7
start local 7 67: aload 3
invokestatic org.apache.cassandra.utils.FBUtilities.closeAll:(Ljava/util/Collection;)V
68: goto 71
69: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ColumnFamilyStore$ViewFragment java.util.List org.apache.cassandra.db.filter.ClusteringIndexFilter long java.lang.Throwable
StackMap stack: java.lang.Exception
astore 8
start local 8 70: aload 7
aload 8
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
end local 8 71: StackMap locals:
StackMap stack:
aload 7
athrow
end local 7 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 72 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 72 1 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
4 72 2 view Lorg/apache/cassandra/db/ColumnFamilyStore$ViewFragment;
5 72 3 iterators Ljava/util/List<Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;>;
6 72 4 filter Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
7 72 5 minTimestamp J
9 18 7 memtable Lorg/apache/cassandra/db/Memtable;
10 18 9 partition Lorg/apache/cassandra/db/partitions/Partition;
14 18 10 iter Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
21 66 7 mostRecentPartitionTombstone J
22 66 9 nonIntersectingSSTables I
23 66 10 skippedSSTablesWithTombstones Ljava/util/List<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
24 66 11 metricsCollector Lorg/apache/cassandra/db/SinglePartitionReadCommand$SSTableReadMetricsCollector;
26 43 12 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
37 43 14 iter Lorg/apache/cassandra/db/rows/UnfilteredRowIteratorWithLowerBound;
45 66 12 includedDueToTombstones I
48 55 13 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
51 55 15 iter Lorg/apache/cassandra/db/rows/UnfilteredRowIteratorWithLowerBound;
67 72 7 e Ljava/lang/Throwable;
70 71 8 suppressed Ljava/lang/Exception;
Exception table:
from to target type
7 62 66 Class java.lang.RuntimeException
63 65 66 Class java.lang.RuntimeException
7 62 66 Class java.lang.Error
63 65 66 Class java.lang.Error
67 68 69 Class java.lang.Exception
MethodParameters:
Name Flags
cfs
private boolean shouldInclude(org.apache.cassandra.io.sstable.format.SSTableReader);
descriptor: (Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
invokevirtual org.apache.cassandra.db.filter.ColumnFilter.fetchedColumns:()Lorg/apache/cassandra/db/PartitionColumns;
getfield org.apache.cassandra.db.PartitionColumns.statics:Lorg/apache/cassandra/db/Columns;
invokevirtual org.apache.cassandra.db.Columns.isEmpty:()Z
ifne 2
1: iconst_1
ireturn
2: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
aload 1
invokeinterface org.apache.cassandra.db.filter.ClusteringIndexFilter.shouldInclude:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 3 1 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
MethodParameters:
Name Flags
sstable
private org.apache.cassandra.db.rows.UnfilteredRowIteratorWithLowerBound makeIterator(org.apache.cassandra.db.ColumnFamilyStore, org.apache.cassandra.io.sstable.format.SSTableReader, boolean, org.apache.cassandra.io.sstable.format.SSTableReadsListener);
descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/io/sstable/format/SSTableReader;ZLorg/apache/cassandra/io/sstable/format/SSTableReadsListener;)Lorg/apache/cassandra/db/rows/UnfilteredRowIteratorWithLowerBound;
flags: (0x0002) ACC_PRIVATE
Code:
stack=10, 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.db.StorageHook.instance:Lorg/apache/cassandra/db/StorageHook;
aload 1
1: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
2: aload 2
3: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
4: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
5: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.isForThrift:()Z
6: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.nowInSec:()I
7: iload 3
8: aload 4
9: invokeinterface org.apache.cassandra.db.StorageHook.makeRowIteratorWithLowerBound:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/io/sstable/format/SSTableReader;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/db/filter/ColumnFilter;ZIZLorg/apache/cassandra/io/sstable/format/SSTableReadsListener;)Lorg/apache/cassandra/db/rows/UnfilteredRowIteratorWithLowerBound;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 10 1 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
0 10 2 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
0 10 3 applyThriftTransformation Z
0 10 4 listener Lorg/apache/cassandra/io/sstable/format/SSTableReadsListener;
MethodParameters:
Name Flags
cfs
sstable final
applyThriftTransformation
listener
private org.apache.cassandra.db.rows.UnfilteredRowIterator withSSTablesIterated(java.util.List<org.apache.cassandra.db.rows.UnfilteredRowIterator>, org.apache.cassandra.metrics.TableMetrics, org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector);
descriptor: (Ljava/util/List;Lorg/apache/cassandra/metrics/TableMetrics;Lorg/apache/cassandra/db/SinglePartitionReadCommand$SSTableReadMetricsCollector;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.nowInSec:()I
invokestatic org.apache.cassandra.db.rows.UnfilteredRowIterators.merge:(Ljava/util/List;I)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
astore 4
start local 4 1: aload 4
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.isEmpty:()Z
ifne 4
2: aload 4
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
astore 5
start local 5 3: aload 2
getfield org.apache.cassandra.metrics.TableMetrics.samplers:Ljava/util/Map;
getstatic org.apache.cassandra.metrics.TableMetrics$Sampler.READS:Lorg/apache/cassandra/metrics/TableMetrics$Sampler;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.utils.TopKSampler
aload 5
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
aload 5
invokevirtual org.apache.cassandra.db.DecoratedKey.hashCode:()I
i2l
iconst_1
invokevirtual org.apache.cassandra.utils.TopKSampler.addSample:(Ljava/lang/Object;JI)V
end local 5 4: StackMap locals: org.apache.cassandra.db.rows.UnfilteredRowIterator
StackMap stack:
aload 4
new org.apache.cassandra.db.SinglePartitionReadCommand$1UpdateSstablesIterated
dup
aload 0
aload 3
aload 2
invokespecial org.apache.cassandra.db.SinglePartitionReadCommand$1UpdateSstablesIterated.<init>:(Lorg/apache/cassandra/db/SinglePartitionReadCommand;Lorg/apache/cassandra/db/SinglePartitionReadCommand$SSTableReadMetricsCollector;Lorg/apache/cassandra/metrics/TableMetrics;)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;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 5 1 iterators Ljava/util/List<Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;>;
0 5 2 metrics Lorg/apache/cassandra/metrics/TableMetrics;
0 5 3 metricsCollector Lorg/apache/cassandra/db/SinglePartitionReadCommand$SSTableReadMetricsCollector;
1 5 4 merged Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
3 4 5 key Lorg/apache/cassandra/db/DecoratedKey;
Signature: (Ljava/util/List<Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;>;Lorg/apache/cassandra/metrics/TableMetrics;Lorg/apache/cassandra/db/SinglePartitionReadCommand$SSTableReadMetricsCollector;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
MethodParameters:
Name Flags
iterators
metrics
metricsCollector
private boolean queriesMulticellType();
descriptor: ()Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=3, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
invokevirtual org.apache.cassandra.db.filter.ColumnFilter.fetchedColumns:()Lorg/apache/cassandra/db/PartitionColumns;
invokevirtual org.apache.cassandra.db.PartitionColumns.iterator:()Ljava/util/Iterator;
astore 2
goto 4
StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand top java.util.Iterator
StackMap stack:
1: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.config.ColumnDefinition
astore 1
start local 1 2: aload 1
getfield org.apache.cassandra.config.ColumnDefinition.type:Lorg/apache/cassandra/db/marshal/AbstractType;
invokevirtual org.apache.cassandra.db.marshal.AbstractType.isMultiCell:()Z
ifne 3
aload 1
getfield org.apache.cassandra.config.ColumnDefinition.type:Lorg/apache/cassandra/db/marshal/AbstractType;
invokevirtual org.apache.cassandra.db.marshal.AbstractType.isCounter:()Z
ifeq 4
3: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.config.ColumnDefinition java.util.Iterator
StackMap stack:
iconst_1
ireturn
end local 1 4: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand top java.util.Iterator
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
5: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
2 4 1 column Lorg/apache/cassandra/config/ColumnDefinition;
private org.apache.cassandra.db.rows.UnfilteredRowIterator queryMemtableAndSSTablesInTimestampOrder(org.apache.cassandra.db.ColumnFamilyStore, org.apache.cassandra.db.filter.ClusteringIndexNamesFilter);
descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
flags: (0x0002) ACC_PRIVATE
Code:
stack=9, locals=14, args_size=3
start local 0 start local 1 start local 2 0: ldc "Acquiring sstable references"
invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;)V
1: aload 1
getstatic org.apache.cassandra.db.lifecycle.SSTableSet.LIVE:Lorg/apache/cassandra/db/lifecycle/SSTableSet;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokestatic org.apache.cassandra.db.lifecycle.View.select:(Lorg/apache/cassandra/db/lifecycle/SSTableSet;Lorg/apache/cassandra/db/DecoratedKey;)Lcom/google/common/base/Function;
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.select:(Lcom/google/common/base/Function;)Lorg/apache/cassandra/db/ColumnFamilyStore$ViewFragment;
astore 3
start local 3 2: aconst_null
astore 4
start local 4 3: ldc "Merging memtable contents"
invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;)V
4: aload 3
getfield org.apache.cassandra.db.ColumnFamilyStore$ViewFragment.memtables:Ljava/lang/Iterable;
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 6
goto 28
StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.filter.ClusteringIndexNamesFilter org.apache.cassandra.db.ColumnFamilyStore$ViewFragment org.apache.cassandra.db.partitions.ImmutableBTreePartition top java.util.Iterator
StackMap stack:
5: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.Memtable
astore 5
start local 5 6: aload 5
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.Memtable.getPartition:(Lorg/apache/cassandra/db/DecoratedKey;)Lorg/apache/cassandra/db/partitions/Partition;
astore 7
start local 7 7: aload 7
ifnonnull 9
8: goto 28
9: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.filter.ClusteringIndexNamesFilter org.apache.cassandra.db.ColumnFamilyStore$ViewFragment org.apache.cassandra.db.partitions.ImmutableBTreePartition org.apache.cassandra.db.Memtable java.util.Iterator org.apache.cassandra.db.partitions.Partition
StackMap stack:
aconst_null
astore 8
aconst_null
astore 9
10: aload 2
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
aload 7
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexNamesFilter.getUnfilteredRowIterator:(Lorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/partitions/Partition;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
astore 10
start local 10 11: aload 10
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.isEmpty:()Z
ifeq 14
12: aload 10
ifnull 28
aload 10
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
13: goto 28
14: StackMap locals: java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.rows.UnfilteredRowIterator
StackMap stack:
aload 0
15: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.isForThrift:()Z
ifeq 16
aload 10
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.nowInSec:()I
invokestatic org.apache.cassandra.thrift.ThriftResultsMerger.maybeWrap:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;I)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
goto 17
StackMap locals:
StackMap stack: org.apache.cassandra.db.SinglePartitionReadCommand
16: aload 10
StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.filter.ClusteringIndexNamesFilter org.apache.cassandra.db.ColumnFamilyStore$ViewFragment org.apache.cassandra.db.partitions.ImmutableBTreePartition org.apache.cassandra.db.Memtable java.util.Iterator org.apache.cassandra.db.partitions.Partition java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.rows.UnfilteredRowIterator
StackMap stack: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.rows.UnfilteredRowIterator
17: getstatic org.apache.cassandra.db.transform.RTBoundValidator$Stage.MEMTABLE:Lorg/apache/cassandra/db/transform/RTBoundValidator$Stage;
iconst_0
invokestatic org.apache.cassandra.db.transform.RTBoundValidator.validate:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/db/transform/RTBoundValidator$Stage;Z)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
18: aload 4
19: aload 2
20: iconst_0
21: invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.add:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/db/partitions/ImmutableBTreePartition;Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;Z)Lorg/apache/cassandra/db/partitions/ImmutableBTreePartition;
astore 4
22: aload 10
ifnull 28
aload 10
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
goto 28
StackMap locals:
StackMap stack: java.lang.Throwable
23: astore 8
aload 10
ifnull 24
aload 10
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
end local 10 StackMap locals:
StackMap stack:
24: aload 8
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
25: astore 9
aload 8
ifnonnull 26
aload 9
astore 8
goto 27
StackMap locals:
StackMap stack:
26: aload 8
aload 9
if_acmpeq 27
aload 8
aload 9
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
27: aload 8
athrow
end local 7 end local 5 28: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.filter.ClusteringIndexNamesFilter org.apache.cassandra.db.ColumnFamilyStore$ViewFragment org.apache.cassandra.db.partitions.ImmutableBTreePartition top java.util.Iterator
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 5
29: aload 3
getfield org.apache.cassandra.db.ColumnFamilyStore$ViewFragment.sstables:Ljava/util/List;
getstatic org.apache.cassandra.io.sstable.format.SSTableReader.maxTimestampDescending:Ljava/util/Comparator;
invokestatic java.util.Collections.sort:(Ljava/util/List;Ljava/util/Comparator;)V
30: iconst_1
istore 5
start local 5 31: new org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector
dup
invokespecial org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector.<init>:()V
astore 6
start local 6 32: aload 3
getfield org.apache.cassandra.db.ColumnFamilyStore$ViewFragment.sstables:Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 8
goto 107
StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.filter.ClusteringIndexNamesFilter org.apache.cassandra.db.ColumnFamilyStore$ViewFragment org.apache.cassandra.db.partitions.ImmutableBTreePartition int org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector top java.util.Iterator
StackMap stack:
33: aload 8
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.format.SSTableReader
astore 7
start local 7 34: aload 4
ifnull 36
aload 7
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getMaxTimestamp:()J
aload 4
invokevirtual org.apache.cassandra.db.partitions.ImmutableBTreePartition.partitionLevelDeletion:()Lorg/apache/cassandra/db/DeletionTime;
invokevirtual org.apache.cassandra.db.DeletionTime.markedForDeleteAt:()J
lcmp
ifge 36
35: goto 108
36: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.filter.ClusteringIndexNamesFilter org.apache.cassandra.db.ColumnFamilyStore$ViewFragment org.apache.cassandra.db.partitions.ImmutableBTreePartition int org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator
StackMap stack:
aload 7
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getMaxTimestamp:()J
lstore 9
start local 9 37: aload 0
aload 2
aload 4
lload 9
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.reduceFilter:(Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;Lorg/apache/cassandra/db/partitions/Partition;J)Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;
astore 2
38: aload 2
ifnonnull 40
39: goto 108
40: StackMap locals: long
StackMap stack:
aload 0
aload 7
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.shouldInclude:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Z
ifne 78
41: aload 7
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.mayHaveTombstones:()Z
ifne 43
42: goto 107
43: StackMap locals:
StackMap stack:
aconst_null
astore 11
aconst_null
astore 12
44: getstatic org.apache.cassandra.db.StorageHook.instance:Lorg/apache/cassandra/db/StorageHook;
aload 1
45: aload 7
46: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
47: aload 2
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexNamesFilter.getSlices:(Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/db/Slices;
48: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
49: aload 2
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexNamesFilter.isReversed:()Z
50: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.isForThrift:()Z
51: aload 6
52: invokeinterface org.apache.cassandra.db.StorageHook.makeRowIterator:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/io/sstable/format/SSTableReader;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/Slices;Lorg/apache/cassandra/db/filter/ColumnFilter;ZZLorg/apache/cassandra/io/sstable/format/SSTableReadsListener;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
astore 13
start local 13 53: aload 13
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionLevelDeletion:()Lorg/apache/cassandra/db/DeletionTime;
invokevirtual org.apache.cassandra.db.DeletionTime.isLive:()Z
ifne 66
54: aload 0
55: aload 13
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.metadata:()Lorg/apache/cassandra/config/CFMetaData;
56: aload 13
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
57: getstatic org.apache.cassandra.db.rows.Rows.EMPTY_STATIC_ROW:Lorg/apache/cassandra/db/rows/Row;
58: aload 13
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionLevelDeletion:()Lorg/apache/cassandra/db/DeletionTime;
59: aload 2
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexNamesFilter.isReversed:()Z
60: 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;
61: aload 4
62: aload 2
63: aload 7
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.isRepaired:()Z
64: invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.add:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/db/partitions/ImmutableBTreePartition;Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;Z)Lorg/apache/cassandra/db/partitions/ImmutableBTreePartition;
astore 4
65: goto 72
66: StackMap locals: java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.rows.UnfilteredRowIterator
StackMap stack:
aload 0
67: aload 13
getstatic org.apache.cassandra.db.transform.RTBoundValidator$Stage.SSTABLE:Lorg/apache/cassandra/db/transform/RTBoundValidator$Stage;
iconst_0
invokestatic org.apache.cassandra.db.transform.RTBoundValidator.validate:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/db/transform/RTBoundValidator$Stage;Z)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
68: aload 4
69: aload 2
70: aload 7
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.isRepaired:()Z
71: invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.add:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/db/partitions/ImmutableBTreePartition;Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;Z)Lorg/apache/cassandra/db/partitions/ImmutableBTreePartition;
astore 4
72: StackMap locals:
StackMap stack:
aload 13
ifnull 107
aload 13
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
goto 107
StackMap locals:
StackMap stack: java.lang.Throwable
73: astore 11
aload 13
ifnull 74
aload 13
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
end local 13 StackMap locals:
StackMap stack:
74: aload 11
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
75: astore 12
aload 11
ifnonnull 76
aload 12
astore 11
goto 77
StackMap locals:
StackMap stack:
76: aload 11
aload 12
if_acmpeq 77
aload 11
aload 12
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
77: aload 11
athrow
78: StackMap locals:
StackMap stack:
aconst_null
astore 11
aconst_null
astore 12
79: getstatic org.apache.cassandra.db.StorageHook.instance:Lorg/apache/cassandra/db/StorageHook;
aload 1
80: aload 7
81: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
82: aload 2
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexNamesFilter.getSlices:(Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/db/Slices;
83: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
84: aload 2
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexNamesFilter.isReversed:()Z
85: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.isForThrift:()Z
86: aload 6
87: invokeinterface org.apache.cassandra.db.StorageHook.makeRowIterator:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/io/sstable/format/SSTableReader;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/Slices;Lorg/apache/cassandra/db/filter/ColumnFilter;ZZLorg/apache/cassandra/io/sstable/format/SSTableReadsListener;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
astore 13
start local 13 88: aload 13
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.isEmpty:()Z
ifeq 91
89: aload 13
ifnull 107
aload 13
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
90: goto 107
91: StackMap locals: java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.rows.UnfilteredRowIterator
StackMap stack:
aload 7
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.isRepaired:()Z
ifeq 93
92: iconst_0
istore 5
93: StackMap locals:
StackMap stack:
aload 0
94: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.isForThrift:()Z
ifeq 95
aload 13
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.nowInSec:()I
invokestatic org.apache.cassandra.thrift.ThriftResultsMerger.maybeWrap:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;I)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
goto 96
StackMap locals:
StackMap stack: org.apache.cassandra.db.SinglePartitionReadCommand
95: aload 13
StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.filter.ClusteringIndexNamesFilter org.apache.cassandra.db.ColumnFamilyStore$ViewFragment org.apache.cassandra.db.partitions.ImmutableBTreePartition int org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector org.apache.cassandra.io.sstable.format.SSTableReader java.util.Iterator long java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.rows.UnfilteredRowIterator
StackMap stack: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.rows.UnfilteredRowIterator
96: getstatic org.apache.cassandra.db.transform.RTBoundValidator$Stage.SSTABLE:Lorg/apache/cassandra/db/transform/RTBoundValidator$Stage;
iconst_0
invokestatic org.apache.cassandra.db.transform.RTBoundValidator.validate:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/db/transform/RTBoundValidator$Stage;Z)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
97: aload 4
98: aload 2
99: aload 7
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.isRepaired:()Z
100: invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.add:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/db/partitions/ImmutableBTreePartition;Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;Z)Lorg/apache/cassandra/db/partitions/ImmutableBTreePartition;
astore 4
101: aload 13
ifnull 107
aload 13
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
goto 107
StackMap locals:
StackMap stack: java.lang.Throwable
102: astore 11
aload 13
ifnull 103
aload 13
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
end local 13 StackMap locals:
StackMap stack:
103: aload 11
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
104: astore 12
aload 11
ifnonnull 105
aload 12
astore 11
goto 106
StackMap locals:
StackMap stack:
105: aload 11
aload 12
if_acmpeq 106
aload 11
aload 12
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
106: aload 11
athrow
end local 9 end local 7 107: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.filter.ClusteringIndexNamesFilter org.apache.cassandra.db.ColumnFamilyStore$ViewFragment org.apache.cassandra.db.partitions.ImmutableBTreePartition int org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector top java.util.Iterator
StackMap stack:
aload 8
invokeinterface java.util.Iterator.hasNext:()Z
ifne 33
108: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.filter.ClusteringIndexNamesFilter org.apache.cassandra.db.ColumnFamilyStore$ViewFragment org.apache.cassandra.db.partitions.ImmutableBTreePartition int org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector
StackMap stack:
aload 1
getfield org.apache.cassandra.db.ColumnFamilyStore.metric:Lorg/apache/cassandra/metrics/TableMetrics;
aload 6
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector.getMergedSSTables:()I
invokevirtual org.apache.cassandra.metrics.TableMetrics.updateSSTableIterated:(I)V
109: aload 4
ifnull 110
aload 4
invokevirtual org.apache.cassandra.db.partitions.ImmutableBTreePartition.isEmpty:()Z
ifeq 111
110: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
iconst_0
invokestatic org.apache.cassandra.db.EmptyIterators.unfilteredRow:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/DecoratedKey;Z)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
areturn
111: StackMap locals:
StackMap stack:
aload 4
invokevirtual org.apache.cassandra.db.partitions.ImmutableBTreePartition.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
astore 7
start local 7 112: aload 1
getfield org.apache.cassandra.db.ColumnFamilyStore.metric:Lorg/apache/cassandra/metrics/TableMetrics;
getfield org.apache.cassandra.metrics.TableMetrics.samplers:Ljava/util/Map;
getstatic org.apache.cassandra.metrics.TableMetrics$Sampler.READS:Lorg/apache/cassandra/metrics/TableMetrics$Sampler;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.utils.TopKSampler
aload 7
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
aload 7
invokevirtual org.apache.cassandra.db.DecoratedKey.hashCode:()I
i2l
iconst_1
invokevirtual org.apache.cassandra.utils.TopKSampler.addSample:(Ljava/lang/Object;JI)V
113: getstatic org.apache.cassandra.db.StorageHook.instance:Lorg/apache/cassandra/db/StorageHook;
aload 1
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokeinterface org.apache.cassandra.db.StorageHook.reportRead:(Ljava/util/UUID;Lorg/apache/cassandra/db/DecoratedKey;)V
114: aload 6
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector.getMergedSSTables:()I
aload 1
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getMinimumCompactionThreshold:()I
if_icmple 129
115: iload 5
ifeq 129
116: aload 1
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.isAutoCompactionDisabled:()Z
ifne 129
117: aload 1
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getCompactionStrategyManager:()Lorg/apache/cassandra/db/compaction/CompactionStrategyManager;
invokevirtual org.apache.cassandra.db.compaction.CompactionStrategyManager.shouldDefragment:()Z
ifeq 129
118: ldc "Defragmenting requested data"
invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;)V
119: aconst_null
astore 8
aconst_null
astore 9
120: aload 4
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
getstatic org.apache.cassandra.db.Slices.ALL:Lorg/apache/cassandra/db/Slices;
iconst_0
invokevirtual org.apache.cassandra.db.partitions.ImmutableBTreePartition.unfilteredIterator:(Lorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/Slices;Z)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
astore 10
start local 10 121: new org.apache.cassandra.db.Mutation
dup
aload 10
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
invokestatic org.apache.cassandra.db.partitions.PartitionUpdate.fromIterator:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/db/filter/ColumnFilter;)Lorg/apache/cassandra/db/partitions/PartitionUpdate;
invokespecial org.apache.cassandra.db.Mutation.<init>:(Lorg/apache/cassandra/db/partitions/PartitionUpdate;)V
astore 11
start local 11 122: getstatic org.apache.cassandra.concurrent.Stage.MUTATION:Lorg/apache/cassandra/concurrent/Stage;
invokestatic org.apache.cassandra.concurrent.StageManager.getStage:(Lorg/apache/cassandra/concurrent/Stage;)Lorg/apache/cassandra/concurrent/LocalAwareExecutorService;
aload 11
invokedynamic run(Lorg/apache/cassandra/db/Mutation;)Ljava/lang/Runnable;
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:
()V
org/apache/cassandra/db/SinglePartitionReadCommand.lambda$0(Lorg/apache/cassandra/db/Mutation;)V (6)
()V
invokeinterface org.apache.cassandra.concurrent.LocalAwareExecutorService.execute:(Ljava/lang/Runnable;)V
end local 11 123: aload 10
ifnull 129
aload 10
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
goto 129
StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.filter.ClusteringIndexNamesFilter org.apache.cassandra.db.ColumnFamilyStore$ViewFragment org.apache.cassandra.db.partitions.ImmutableBTreePartition int org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector org.apache.cassandra.db.DecoratedKey java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.rows.UnfilteredRowIterator
StackMap stack: java.lang.Throwable
124: astore 8
aload 10
ifnull 125
aload 10
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
end local 10 StackMap locals:
StackMap stack:
125: aload 8
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
126: astore 9
aload 8
ifnonnull 127
aload 9
astore 8
goto 128
StackMap locals:
StackMap stack:
127: aload 8
aload 9
if_acmpeq 128
aload 8
aload 9
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
128: aload 8
athrow
129: StackMap locals:
StackMap stack:
aload 4
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
getstatic org.apache.cassandra.db.Slices.ALL:Lorg/apache/cassandra/db/Slices;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
invokeinterface org.apache.cassandra.db.filter.ClusteringIndexFilter.isReversed:()Z
invokevirtual org.apache.cassandra.db.partitions.ImmutableBTreePartition.unfilteredIterator:(Lorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/Slices;Z)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
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 130 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 130 1 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
0 130 2 filter Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;
2 130 3 view Lorg/apache/cassandra/db/ColumnFamilyStore$ViewFragment;
3 130 4 result Lorg/apache/cassandra/db/partitions/ImmutableBTreePartition;
6 28 5 memtable Lorg/apache/cassandra/db/Memtable;
7 28 7 partition Lorg/apache/cassandra/db/partitions/Partition;
11 24 10 iter Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
31 130 5 onlyUnrepaired Z
32 130 6 metricsCollector Lorg/apache/cassandra/db/SinglePartitionReadCommand$SSTableReadMetricsCollector;
34 107 7 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
37 107 9 currentMaxTs J
53 74 13 iter Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
88 103 13 iter Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
112 130 7 key Lorg/apache/cassandra/db/DecoratedKey;
121 125 10 iter Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
122 123 11 mutation Lorg/apache/cassandra/db/Mutation;
Exception table:
from to target type
11 12 23 any
14 22 23 any
10 13 25 any
14 25 25 any
53 72 73 any
44 75 75 any
88 89 102 any
91 101 102 any
79 90 104 any
91 104 104 any
121 123 124 any
120 126 126 any
MethodParameters:
Name Flags
cfs
filter
private org.apache.cassandra.db.partitions.ImmutableBTreePartition add(org.apache.cassandra.db.rows.UnfilteredRowIterator, org.apache.cassandra.db.partitions.ImmutableBTreePartition, org.apache.cassandra.db.filter.ClusteringIndexNamesFilter, boolean);
descriptor: (Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/db/partitions/ImmutableBTreePartition;Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;Z)Lorg/apache/cassandra/db/partitions/ImmutableBTreePartition;
flags: (0x0002) ACC_PRIVATE
Code:
stack=7, locals=9, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: iload 4
ifne 2
1: aload 0
aload 0
getfield org.apache.cassandra.db.SinglePartitionReadCommand.oldestUnrepairedTombstone:I
aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.stats:()Lorg/apache/cassandra/db/rows/EncodingStats;
getfield org.apache.cassandra.db.rows.EncodingStats.minLocalDeletionTime:I
invokestatic java.lang.Math.min:(II)I
putfield org.apache.cassandra.db.SinglePartitionReadCommand.oldestUnrepairedTombstone:I
2: StackMap locals:
StackMap stack:
aload 3
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexNamesFilter.requestedRows:()Ljava/util/NavigableSet;
invokeinterface java.util.NavigableSet.size:()I
iconst_1
invokestatic java.lang.Math.max:(II)I
istore 5
start local 5 3: aload 2
ifnonnull 5
4: aload 1
iload 5
invokestatic org.apache.cassandra.db.partitions.ImmutableBTreePartition.create:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;I)Lorg/apache/cassandra/db/partitions/ImmutableBTreePartition;
areturn
5: StackMap locals: int
StackMap stack:
aconst_null
astore 6
aconst_null
astore 7
6: iconst_2
anewarray org.apache.cassandra.db.rows.UnfilteredRowIterator
dup
iconst_0
aload 1
aastore
dup
iconst_1
aload 2
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
getstatic org.apache.cassandra.db.Slices.ALL:Lorg/apache/cassandra/db/Slices;
aload 3
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexNamesFilter.isReversed:()Z
invokevirtual org.apache.cassandra.db.partitions.ImmutableBTreePartition.unfilteredIterator:(Lorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/Slices;Z)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
aastore
invokestatic java.util.Arrays.asList:([Ljava/lang/Object;)Ljava/util/List;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.nowInSec:()I
invokestatic org.apache.cassandra.db.rows.UnfilteredRowIterators.merge:(Ljava/util/List;I)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
astore 8
start local 8 7: aload 8
iload 5
invokestatic org.apache.cassandra.db.partitions.ImmutableBTreePartition.create:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;I)Lorg/apache/cassandra/db/partitions/ImmutableBTreePartition;
8: aload 8
ifnull 9
aload 8
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
9: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.rows.UnfilteredRowIterator org.apache.cassandra.db.partitions.ImmutableBTreePartition org.apache.cassandra.db.filter.ClusteringIndexNamesFilter int int java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.rows.UnfilteredRowIterator
StackMap stack: org.apache.cassandra.db.partitions.ImmutableBTreePartition
areturn
StackMap locals:
StackMap stack: java.lang.Throwable
10: astore 6
11: aload 8
ifnull 12
aload 8
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
end local 8 StackMap locals:
StackMap stack:
12: aload 6
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
13: astore 7
aload 6
ifnonnull 14
aload 7
astore 6
goto 15
StackMap locals:
StackMap stack:
14: aload 6
aload 7
if_acmpeq 15
aload 6
aload 7
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
15: aload 6
athrow
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 16 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 16 1 iter Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
0 16 2 result Lorg/apache/cassandra/db/partitions/ImmutableBTreePartition;
0 16 3 filter Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;
0 16 4 isRepaired Z
3 16 5 maxRows I
7 12 8 merged Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
Exception table:
from to target type
7 8 10 any
6 9 13 any
10 13 13 any
MethodParameters:
Name Flags
iter
result
filter
isRepaired
private org.apache.cassandra.db.filter.ClusteringIndexNamesFilter reduceFilter(org.apache.cassandra.db.filter.ClusteringIndexNamesFilter, org.apache.cassandra.db.partitions.Partition, long);
descriptor: (Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;Lorg/apache/cassandra/db/partitions/Partition;J)Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=13, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 2
ifnonnull 2
1: aload 1
areturn
2: StackMap locals:
StackMap stack:
aload 2
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
iconst_0
invokeinterface org.apache.cassandra.db.partitions.Partition.searchIterator:(Lorg/apache/cassandra/db/filter/ColumnFilter;Z)Lorg/apache/cassandra/utils/SearchIterator;
astore 5
start local 5 3: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
invokevirtual org.apache.cassandra.db.filter.ColumnFilter.fetchedColumns:()Lorg/apache/cassandra/db/PartitionColumns;
astore 6
start local 6 4: aload 1
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexNamesFilter.requestedRows:()Ljava/util/NavigableSet;
astore 7
start local 7 5: iconst_0
istore 8
start local 8 6: aload 6
getfield org.apache.cassandra.db.PartitionColumns.statics:Lorg/apache/cassandra/db/Columns;
invokevirtual org.apache.cassandra.db.Columns.isEmpty:()Z
ifne 11
7: aload 5
getstatic org.apache.cassandra.db.Clustering.STATIC_CLUSTERING:Lorg/apache/cassandra/db/Clustering;
invokeinterface org.apache.cassandra.utils.SearchIterator.next:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Row
astore 9
start local 9 8: aload 9
ifnull 9
aload 0
aload 9
aload 6
getfield org.apache.cassandra.db.PartitionColumns.statics:Lorg/apache/cassandra/db/Columns;
lload 3
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.canRemoveRow:(Lorg/apache/cassandra/db/rows/Row;Lorg/apache/cassandra/db/Columns;J)Z
ifeq 9
iconst_1
goto 10
StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.filter.ClusteringIndexNamesFilter org.apache.cassandra.db.partitions.Partition long org.apache.cassandra.utils.SearchIterator org.apache.cassandra.db.PartitionColumns java.util.NavigableSet int org.apache.cassandra.db.rows.Row
StackMap stack:
9: iconst_0
StackMap locals:
StackMap stack: int
10: istore 8
end local 9 11: StackMap locals:
StackMap stack:
aconst_null
astore 9
start local 9 12: aload 7
invokeinterface java.util.NavigableSet.iterator:()Ljava/util/Iterator;
astore 11
goto 20
StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.filter.ClusteringIndexNamesFilter org.apache.cassandra.db.partitions.Partition long org.apache.cassandra.utils.SearchIterator org.apache.cassandra.db.PartitionColumns java.util.NavigableSet int java.util.NavigableSet top java.util.Iterator
StackMap stack:
13: aload 11
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.Clustering
astore 10
start local 10 14: aload 5
aload 10
invokeinterface org.apache.cassandra.utils.SearchIterator.next:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Row
astore 12
start local 12 15: aload 12
ifnull 20
aload 0
aload 12
aload 6
getfield org.apache.cassandra.db.PartitionColumns.regulars:Lorg/apache/cassandra/db/Columns;
lload 3
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.canRemoveRow:(Lorg/apache/cassandra/db/rows/Row;Lorg/apache/cassandra/db/Columns;J)Z
ifne 17
16: goto 20
17: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.filter.ClusteringIndexNamesFilter org.apache.cassandra.db.partitions.Partition long org.apache.cassandra.utils.SearchIterator org.apache.cassandra.db.PartitionColumns java.util.NavigableSet int java.util.NavigableSet org.apache.cassandra.db.Clustering java.util.Iterator org.apache.cassandra.db.rows.Row
StackMap stack:
aload 9
ifnonnull 19
18: new java.util.TreeSet
dup
aload 2
invokeinterface org.apache.cassandra.db.partitions.Partition.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.comparator:Lorg/apache/cassandra/db/ClusteringComparator;
invokespecial java.util.TreeSet.<init>:(Ljava/util/Comparator;)V
astore 9
19: StackMap locals:
StackMap stack:
aload 9
aload 10
invokeinterface java.util.NavigableSet.add:(Ljava/lang/Object;)Z
pop
end local 12 end local 10 20: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.filter.ClusteringIndexNamesFilter org.apache.cassandra.db.partitions.Partition long org.apache.cassandra.utils.SearchIterator org.apache.cassandra.db.PartitionColumns java.util.NavigableSet int java.util.NavigableSet top java.util.Iterator
StackMap stack:
aload 11
invokeinterface java.util.Iterator.hasNext:()Z
ifne 13
21: iload 8
ifne 23
aload 9
ifnonnull 23
22: aload 1
areturn
23: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.filter.ClusteringIndexNamesFilter org.apache.cassandra.db.partitions.Partition long org.apache.cassandra.utils.SearchIterator org.apache.cassandra.db.PartitionColumns java.util.NavigableSet int java.util.NavigableSet
StackMap stack:
aload 6
getfield org.apache.cassandra.db.PartitionColumns.statics:Lorg/apache/cassandra/db/Columns;
invokevirtual org.apache.cassandra.db.Columns.isEmpty:()Z
ifne 24
iload 8
ifne 24
iconst_0
goto 25
StackMap locals:
StackMap stack:
24: iconst_1
StackMap locals:
StackMap stack: int
25: istore 10
start local 10 26: aload 7
invokeinterface java.util.NavigableSet.isEmpty:()Z
ifne 28
aload 9
ifnull 27
aload 9
invokeinterface java.util.NavigableSet.size:()I
aload 7
invokeinterface java.util.NavigableSet.size:()I
if_icmpeq 28
StackMap locals: int
StackMap stack:
27: iconst_0
goto 29
StackMap locals:
StackMap stack:
28: iconst_1
StackMap locals:
StackMap stack: int
29: istore 11
start local 11 30: iload 10
ifeq 32
iload 11
ifeq 32
31: aconst_null
areturn
32: StackMap locals: int
StackMap stack:
aload 9
ifnull 36
33: aload 2
invokeinterface org.apache.cassandra.db.partitions.Partition.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.comparator:Lorg/apache/cassandra/db/ClusteringComparator;
invokestatic org.apache.cassandra.utils.btree.BTreeSet.builder:(Ljava/util/Comparator;)Lorg/apache/cassandra/utils/btree/BTreeSet$Builder;
astore 12
start local 12 34: aload 12
aload 7
aload 9
invokestatic com.google.common.collect.Sets.difference:(Ljava/util/Set;Ljava/util/Set;)Lcom/google/common/collect/Sets$SetView;
invokevirtual org.apache.cassandra.utils.btree.BTreeSet$Builder.addAll:(Ljava/util/Collection;)Lorg/apache/cassandra/utils/btree/BTreeSet$Builder;
pop
35: aload 12
invokevirtual org.apache.cassandra.utils.btree.BTreeSet$Builder.build:()Lorg/apache/cassandra/utils/btree/BTreeSet;
astore 7
end local 12 36: StackMap locals:
StackMap stack:
new org.apache.cassandra.db.filter.ClusteringIndexNamesFilter
dup
aload 7
aload 1
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexNamesFilter.isReversed:()Z
invokespecial org.apache.cassandra.db.filter.ClusteringIndexNamesFilter.<init>:(Ljava/util/NavigableSet;Z)V
areturn
end local 11 end local 10 end local 9 end local 8 end local 7 end local 6 end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 37 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 37 1 filter Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;
0 37 2 result Lorg/apache/cassandra/db/partitions/Partition;
0 37 3 sstableTimestamp J
3 37 5 searchIter Lorg/apache/cassandra/utils/SearchIterator<Lorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/db/rows/Row;>;
4 37 6 columns Lorg/apache/cassandra/db/PartitionColumns;
5 37 7 clusterings Ljava/util/NavigableSet<Lorg/apache/cassandra/db/Clustering;>;
6 37 8 removeStatic Z
8 11 9 staticRow Lorg/apache/cassandra/db/rows/Row;
12 37 9 toRemove Ljava/util/NavigableSet<Lorg/apache/cassandra/db/Clustering;>;
14 20 10 clustering Lorg/apache/cassandra/db/Clustering;
15 20 12 row Lorg/apache/cassandra/db/rows/Row;
26 37 10 hasNoMoreStatic Z
30 37 11 hasNoMoreClusterings Z
34 36 12 newClusterings Lorg/apache/cassandra/utils/btree/BTreeSet$Builder<Lorg/apache/cassandra/db/Clustering;>;
MethodParameters:
Name Flags
filter
result
sstableTimestamp
private boolean canRemoveRow(org.apache.cassandra.db.rows.Row, org.apache.cassandra.db.Columns, long);
descriptor: (Lorg/apache/cassandra/db/rows/Row;Lorg/apache/cassandra/db/Columns;J)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=8, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
invokeinterface org.apache.cassandra.db.rows.Row.primaryKeyLivenessInfo:()Lorg/apache/cassandra/db/LivenessInfo;
invokevirtual org.apache.cassandra.db.LivenessInfo.isEmpty:()Z
ifne 1
aload 1
invokeinterface org.apache.cassandra.db.rows.Row.primaryKeyLivenessInfo:()Lorg/apache/cassandra/db/LivenessInfo;
invokevirtual org.apache.cassandra.db.LivenessInfo.timestamp:()J
lload 3
lcmp
ifgt 2
1: StackMap locals:
StackMap stack:
iconst_0
ireturn
2: StackMap locals:
StackMap stack:
aload 2
invokevirtual org.apache.cassandra.db.Columns.iterator:()Ljava/util/Iterator;
astore 6
goto 7
StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.rows.Row org.apache.cassandra.db.Columns long top java.util.Iterator
StackMap stack:
3: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.config.ColumnDefinition
astore 5
start local 5 4: aload 1
aload 5
invokeinterface org.apache.cassandra.db.rows.Row.getCell:(Lorg/apache/cassandra/config/ColumnDefinition;)Lorg/apache/cassandra/db/rows/Cell;
astore 7
start local 7 5: aload 7
ifnull 6
aload 7
invokevirtual org.apache.cassandra.db.rows.Cell.timestamp:()J
lload 3
lcmp
ifgt 7
6: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.rows.Row org.apache.cassandra.db.Columns long org.apache.cassandra.config.ColumnDefinition java.util.Iterator org.apache.cassandra.db.rows.Cell
StackMap stack:
iconst_0
ireturn
end local 7 end local 5 7: StackMap locals: org.apache.cassandra.db.SinglePartitionReadCommand org.apache.cassandra.db.rows.Row org.apache.cassandra.db.Columns long top java.util.Iterator
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
8: iconst_1
ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 9 1 row Lorg/apache/cassandra/db/rows/Row;
0 9 2 requestedColumns Lorg/apache/cassandra/db/Columns;
0 9 3 sstableTimestamp J
4 7 5 column Lorg/apache/cassandra/config/ColumnDefinition;
5 7 7 cell Lorg/apache/cassandra/db/rows/Cell;
MethodParameters:
Name Flags
row
requestedColumns
sstableTimestamp
public boolean selectsFullPartition();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.isStaticCompactTable:()Z
ifne 3
1: aload 0
getfield org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
invokeinterface org.apache.cassandra.db.filter.ClusteringIndexFilter.selectsAllPartition:()Z
ifeq 2
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.rowFilter:()Lorg/apache/cassandra/db/filter/RowFilter;
invokevirtual org.apache.cassandra.db.filter.RowFilter.hasExpressionOnClusteringOrRegularColumns:()Z
ifeq 3
2: StackMap locals:
StackMap stack:
iconst_0
ireturn
StackMap locals:
StackMap stack:
3: iconst_1
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
public java.lang.String toString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=1, args_size=1
start local 0 0: ldc "Read(%s.%s columns=%s rowFilter=%s limits=%s key=%s filter=%s, nowInSec=%d)"
bipush 8
anewarray java.lang.Object
dup
iconst_0
1: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.ksName:Ljava/lang/String;
aastore
dup
iconst_1
2: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfName:Ljava/lang/String;
aastore
dup
iconst_2
3: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
aastore
dup
iconst_3
4: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.rowFilter:()Lorg/apache/cassandra/db/filter/RowFilter;
aastore
dup
iconst_4
5: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
aastore
dup
iconst_5
6: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.getKeyValidator:()Lorg/apache/cassandra/db/marshal/AbstractType;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
invokevirtual org.apache.cassandra.db.marshal.AbstractType.getString:(Ljava/nio/ByteBuffer;)Ljava/lang/String;
aastore
dup
bipush 6
7: aload 0
getfield org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
invokeinterface org.apache.cassandra.db.filter.ClusteringIndexFilter.toString:(Lorg/apache/cassandra/config/CFMetaData;)Ljava/lang/String;
aastore
dup
bipush 7
8: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.nowInSec:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
9: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
public org.apache.cassandra.net.MessageOut<org.apache.cassandra.db.ReadCommand> createMessage(int);
descriptor: (I)Lorg/apache/cassandra/net/MessageOut;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: new org.apache.cassandra.net.MessageOut
dup
getstatic org.apache.cassandra.net.MessagingService$Verb.READ:Lorg/apache/cassandra/net/MessagingService$Verb;
aload 0
getstatic org.apache.cassandra.db.SinglePartitionReadCommand.readSerializer:Lorg/apache/cassandra/io/IVersionedSerializer;
invokespecial org.apache.cassandra.net.MessageOut.<init>:(Lorg/apache/cassandra/net/MessagingService$Verb;Ljava/lang/Object;Lorg/apache/cassandra/io/IVersionedSerializer;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 1 1 version I
Signature: (I)Lorg/apache/cassandra/net/MessageOut<Lorg/apache/cassandra/db/ReadCommand;>;
MethodParameters:
Name Flags
version
protected void appendCQLWhereClause(java.lang.StringBuilder);
descriptor: (Ljava/lang/StringBuilder;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 1
ldc " WHERE "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
pop
1: aload 1
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.partitionKeyColumns:()Ljava/util/List;
invokestatic org.apache.cassandra.config.ColumnDefinition.toCQLString:(Ljava/lang/Iterable;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " = "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
pop
2: aload 1
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.getKeyValidator:()Lorg/apache/cassandra/db/marshal/AbstractType;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
invokestatic org.apache.cassandra.db.DataRange.appendKeyString:(Ljava/lang/StringBuilder;Lorg/apache/cassandra/db/marshal/AbstractType;Ljava/nio/ByteBuffer;)V
3: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.rowFilter:()Lorg/apache/cassandra/db/filter/RowFilter;
invokevirtual org.apache.cassandra.db.filter.RowFilter.isEmpty:()Z
ifne 5
4: aload 1
ldc " AND "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.rowFilter:()Lorg/apache/cassandra/db/filter/RowFilter;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
pop
5: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
invokeinterface org.apache.cassandra.db.filter.ClusteringIndexFilter.toCQLString:(Lorg/apache/cassandra/config/CFMetaData;)Ljava/lang/String;
astore 2
start local 2 6: aload 2
invokevirtual java.lang.String.isEmpty:()Z
ifne 8
7: aload 1
ldc " AND "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
pop
8: StackMap locals: java.lang.String
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 9 1 sb Ljava/lang/StringBuilder;
6 9 2 filterString Ljava/lang/String;
MethodParameters:
Name Flags
sb
protected void serializeSelection(org.apache.cassandra.io.util.DataOutputPlus, int);
descriptor: (Lorg/apache/cassandra/io/util/DataOutputPlus;I)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.getKeyValidator:()Lorg/apache/cassandra/db/marshal/AbstractType;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
aload 1
invokevirtual org.apache.cassandra.db.marshal.AbstractType.writeValue:(Ljava/nio/ByteBuffer;Lorg/apache/cassandra/io/util/DataOutputPlus;)V
1: getstatic org.apache.cassandra.db.filter.ClusteringIndexFilter.serializer:Lorg/apache/cassandra/db/filter/ClusteringIndexFilter$Serializer;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
aload 1
iload 2
invokeinterface org.apache.cassandra.db.filter.ClusteringIndexFilter$Serializer.serialize:(Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;Lorg/apache/cassandra/io/util/DataOutputPlus;I)V
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 3 1 out Lorg/apache/cassandra/io/util/DataOutputPlus;
0 3 2 version I
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
out
version
protected long selectionSerializedSize(int);
descriptor: (I)J
flags: (0x0004) ACC_PROTECTED
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.getKeyValidator:()Lorg/apache/cassandra/db/marshal/AbstractType;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
invokevirtual org.apache.cassandra.db.marshal.AbstractType.writtenLength:(Ljava/nio/ByteBuffer;)J
1: getstatic org.apache.cassandra.db.filter.ClusteringIndexFilter.serializer:Lorg/apache/cassandra/db/filter/ClusteringIndexFilter$Serializer;
aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.clusteringIndexFilter:()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
iload 1
invokeinterface org.apache.cassandra.db.filter.ClusteringIndexFilter$Serializer.serializedSize:(Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;I)J
2: ladd
lreturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
0 3 1 version I
MethodParameters:
Name Flags
version
public boolean isLimitedToOnePartition();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: iconst_1
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/SinglePartitionReadCommand;
public org.apache.cassandra.service.pager.QueryPager getPager(org.apache.cassandra.service.pager.PagingState, org.apache.cassandra.transport.ProtocolVersion);
descriptor: (Lorg/apache/cassandra/service/pager/PagingState;Lorg/apache/cassandra/transport/ProtocolVersion;)Lorg/apache/cassandra/service/pager/QueryPager;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
aload 2
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.getPager:(Lorg/apache/cassandra/service/pager/PagingState;Lorg/apache/cassandra/transport/ProtocolVersion;)Lorg/apache/cassandra/service/pager/SinglePartitionPager;
areturn
LocalVariableTable:
Start End Slot Name Signature
public org.apache.cassandra.db.ReadCommand copyAsDigestQuery();
descriptor: ()Lorg/apache/cassandra/db/ReadCommand;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.copyAsDigestQuery:()Lorg/apache/cassandra/db/SinglePartitionReadCommand;
areturn
LocalVariableTable:
Start End Slot Name Signature
public org.apache.cassandra.db.ReadCommand copy();
descriptor: ()Lorg/apache/cassandra/db/ReadCommand;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.copy:()Lorg/apache/cassandra/db/SinglePartitionReadCommand;
areturn
LocalVariableTable:
Start End Slot Name Signature
public org.apache.cassandra.db.ReadCommand withUpdatedLimit(org.apache.cassandra.db.filter.DataLimits);
descriptor: (Lorg/apache/cassandra/db/filter/DataLimits;)Lorg/apache/cassandra/db/ReadCommand;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.withUpdatedLimit:(Lorg/apache/cassandra/db/filter/DataLimits;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static void lambda$0(org.apache.cassandra.db.Mutation);
descriptor: (Lorg/apache/cassandra/db/Mutation;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
0: aload 0
invokevirtual org.apache.cassandra.db.Mutation.getKeyspaceName:()Ljava/lang/String;
invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
aload 0
iconst_0
iconst_0
invokevirtual org.apache.cassandra.db.Keyspace.apply:(Lorg/apache/cassandra/db/Mutation;ZZ)V
1: return
LocalVariableTable:
Start End Slot Name Signature
}
SourceFile: "SinglePartitionReadCommand.java"
NestMembers:
org.apache.cassandra.db.SinglePartitionReadCommand$1 org.apache.cassandra.db.SinglePartitionReadCommand$1UpdateSstablesIterated org.apache.cassandra.db.SinglePartitionReadCommand$Deserializer org.apache.cassandra.db.SinglePartitionReadCommand$Group org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector
InnerClasses:
public abstract SetView = com.google.common.collect.Sets$SetView of com.google.common.collect.Sets
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public ViewFragment = org.apache.cassandra.db.ColumnFamilyStore$ViewFragment of org.apache.cassandra.db.ColumnFamilyStore
protected final Kind = org.apache.cassandra.db.ReadCommand$Kind of org.apache.cassandra.db.ReadCommand
protected abstract SelectionDeserializer = org.apache.cassandra.db.ReadCommand$SelectionDeserializer of org.apache.cassandra.db.ReadCommand
org.apache.cassandra.db.SinglePartitionReadCommand$1
UpdateSstablesIterated = org.apache.cassandra.db.SinglePartitionReadCommand$1UpdateSstablesIterated
private Deserializer = org.apache.cassandra.db.SinglePartitionReadCommand$Deserializer of org.apache.cassandra.db.SinglePartitionReadCommand
public Group = org.apache.cassandra.db.SinglePartitionReadCommand$Group of org.apache.cassandra.db.SinglePartitionReadCommand
private final SSTableReadMetricsCollector = org.apache.cassandra.db.SinglePartitionReadCommand$SSTableReadMetricsCollector of org.apache.cassandra.db.SinglePartitionReadCommand
public abstract Serializer = org.apache.cassandra.db.filter.ClusteringIndexFilter$Serializer of org.apache.cassandra.db.filter.ClusteringIndexFilter
public final Stage = org.apache.cassandra.db.transform.RTBoundValidator$Stage of org.apache.cassandra.db.transform.RTBoundValidator
public final Sampler = org.apache.cassandra.metrics.TableMetrics$Sampler of org.apache.cassandra.metrics.TableMetrics
public Verb = org.apache.cassandra.net.MessagingService$Verb of org.apache.cassandra.net.MessagingService
public Builder = org.apache.cassandra.utils.btree.BTreeSet$Builder of org.apache.cassandra.utils.btree.BTreeSet