class org.apache.cassandra.db.ReadCommand$LegacyPagedRangeCommandSerializer implements org.apache.cassandra.io.IVersionedSerializer<org.apache.cassandra.db.ReadCommand>
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: org.apache.cassandra.db.ReadCommand$LegacyPagedRangeCommandSerializer
super_class: java.lang.Object
{
static final boolean $assertionsDisabled;
descriptor: Z
flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/db/ReadCommand;
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.ReadCommand$LegacyPagedRangeCommandSerializer.$assertionsDisabled:Z
return
LocalVariableTable:
Start End Slot Name Signature
private void <init>();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/ReadCommand$LegacyPagedRangeCommandSerializer;
public void serialize(org.apache.cassandra.db.ReadCommand, org.apache.cassandra.io.util.DataOutputPlus, int);
descriptor: (Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/io/util/DataOutputPlus;I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=17, args_size=4
start local 0 start local 1 start local 2 start local 3 0: getstatic org.apache.cassandra.db.ReadCommand$LegacyPagedRangeCommandSerializer.$assertionsDisabled:Z
ifne 1
iload 3
bipush 10
if_icmplt 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 1
checkcast org.apache.cassandra.db.PartitionRangeReadCommand
astore 4
start local 4 2: getstatic org.apache.cassandra.db.ReadCommand$LegacyPagedRangeCommandSerializer.$assertionsDisabled:Z
ifne 3
aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.dataRange:()Lorg/apache/cassandra/db/DataRange;
invokevirtual org.apache.cassandra.db.DataRange.isPaging:()Z
ifne 3
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
3: StackMap locals: org.apache.cassandra.db.PartitionRangeReadCommand
StackMap stack:
aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
astore 5
start local 5 4: aload 2
aload 5
getfield org.apache.cassandra.config.CFMetaData.ksName:Ljava/lang/String;
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeUTF:(Ljava/lang/String;)V
5: aload 2
aload 5
getfield org.apache.cassandra.config.CFMetaData.cfName:Ljava/lang/String;
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeUTF:(Ljava/lang/String;)V
6: aload 2
aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.nowInSec:()I
i2l
ldc 1000
lmul
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeLong:(J)V
7: getstatic org.apache.cassandra.dht.AbstractBounds.rowPositionSerializer:Lorg/apache/cassandra/dht/IPartitionerDependentSerializer;
aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.dataRange:()Lorg/apache/cassandra/db/DataRange;
invokevirtual org.apache.cassandra.db.DataRange.keyRange:()Lorg/apache/cassandra/dht/AbstractBounds;
aload 2
iload 3
invokeinterface org.apache.cassandra.dht.IPartitionerDependentSerializer.serialize:(Ljava/lang/Object;Lorg/apache/cassandra/io/util/DataOutputPlus;I)V
8: aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.dataRange:()Lorg/apache/cassandra/db/DataRange;
getfield org.apache.cassandra.db.DataRange.clusteringIndexFilter:Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
invokeinterface org.apache.cassandra.db.filter.ClusteringIndexFilter.kind:()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter$Kind;
getstatic org.apache.cassandra.db.filter.ClusteringIndexFilter$Kind.NAMES:Lorg/apache/cassandra/db/filter/ClusteringIndexFilter$Kind;
if_acmpne 11
9: aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.dataRange:()Lorg/apache/cassandra/db/DataRange;
getfield org.apache.cassandra.db.DataRange.clusteringIndexFilter:Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
checkcast org.apache.cassandra.db.filter.ClusteringIndexNamesFilter
aload 5
invokestatic org.apache.cassandra.db.ReadCommand$LegacyReadCommandSerializer.convertNamesFilterToSliceFilter:(Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/db/filter/ClusteringIndexSliceFilter;
astore 6
start local 6 10: goto 12
end local 6 11: StackMap locals: org.apache.cassandra.config.CFMetaData
StackMap stack:
aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.dataRange:()Lorg/apache/cassandra/db/DataRange;
getfield org.apache.cassandra.db.DataRange.clusteringIndexFilter:Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
checkcast org.apache.cassandra.db.filter.ClusteringIndexSliceFilter
astore 6
start local 6 12: StackMap locals: org.apache.cassandra.db.filter.ClusteringIndexSliceFilter
StackMap stack:
aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.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 13
aload 6
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexSliceFilter.requestedSlices:()Lorg/apache/cassandra/db/Slices;
getstatic org.apache.cassandra.db.Clustering.STATIC_CLUSTERING:Lorg/apache/cassandra/db/Clustering;
invokevirtual org.apache.cassandra.db.Slices.selects:(Lorg/apache/cassandra/db/Clustering;)Z
ifne 13
iconst_1
goto 14
StackMap locals:
StackMap stack:
13: iconst_0
StackMap locals:
StackMap stack: int
14: istore 7
start local 7 15: aload 2
aload 6
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexSliceFilter.requestedSlices:()Lorg/apache/cassandra/db/Slices;
aload 6
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexSliceFilter.isReversed:()Z
iload 7
aload 5
invokestatic org.apache.cassandra.db.ReadCommand$LegacyReadCommandSerializer.serializeSlices:(Lorg/apache/cassandra/io/util/DataOutputPlus;Lorg/apache/cassandra/db/Slices;ZZLorg/apache/cassandra/config/CFMetaData;)V
16: aload 2
aload 6
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexSliceFilter.isReversed:()Z
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeBoolean:(Z)V
17: aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
invokevirtual org.apache.cassandra.db.filter.DataLimits.kind:()Lorg/apache/cassandra/db/filter/DataLimits$Kind;
astore 8
start local 8 18: aload 8
getstatic org.apache.cassandra.db.filter.DataLimits$Kind.CQL_LIMIT:Lorg/apache/cassandra/db/filter/DataLimits$Kind;
if_acmpeq 19
aload 8
getstatic org.apache.cassandra.db.filter.DataLimits$Kind.CQL_PAGING_LIMIT:Lorg/apache/cassandra/db/filter/DataLimits$Kind;
if_acmpne 20
StackMap locals: int org.apache.cassandra.db.filter.DataLimits$Kind
StackMap stack:
19: aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
invokevirtual org.apache.cassandra.db.filter.DataLimits.perPartitionCount:()I
iconst_1
if_icmpne 20
iconst_1
goto 21
StackMap locals:
StackMap stack:
20: iconst_0
StackMap locals:
StackMap stack: int
21: istore 9
start local 9 22: iload 9
ifeq 24
23: aload 2
iconst_1
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeInt:(I)V
goto 25
24: StackMap locals: int
StackMap stack:
aload 2
aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
invokevirtual org.apache.cassandra.db.filter.DataLimits.perPartitionCount:()I
aload 6
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexSliceFilter.requestedSlices:()Lorg/apache/cassandra/db/Slices;
invokestatic org.apache.cassandra.db.ReadCommand$LegacyReadCommandSerializer.updateLimitForQuery:(ILorg/apache/cassandra/db/Slices;)I
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeInt:(I)V
25: StackMap locals:
StackMap stack:
aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.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 26
aload 6
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexSliceFilter.requestedSlices:()Lorg/apache/cassandra/db/Slices;
getstatic org.apache.cassandra.db.Clustering.STATIC_CLUSTERING:Lorg/apache/cassandra/db/Clustering;
invokevirtual org.apache.cassandra.db.Slices.selects:(Lorg/apache/cassandra/db/Clustering;)Z
ifne 26
iconst_0
goto 27
StackMap locals:
StackMap stack:
26: iconst_1
StackMap locals:
StackMap stack: int
27: istore 10
start local 10 28: aload 8
getstatic org.apache.cassandra.db.filter.DataLimits$Kind.THRIFT_LIMIT:Lorg/apache/cassandra/db/filter/DataLimits$Kind;
if_acmpne 31
29: iconst_m1
istore 11
start local 11 30: goto 37
end local 11 31: StackMap locals: int
StackMap stack:
iload 9
ifeq 34
iload 10
ifne 34
32: bipush -2
istore 11
start local 11 33: goto 37
end local 11 34: StackMap locals:
StackMap stack:
aload 5
invokevirtual org.apache.cassandra.config.CFMetaData.isDense:()Z
ifeq 35
iconst_m1
goto 36
StackMap locals:
StackMap stack:
35: aload 5
invokevirtual org.apache.cassandra.config.CFMetaData.clusteringColumns:()Ljava/util/List;
invokeinterface java.util.List.size:()I
StackMap locals:
StackMap stack: int
36: istore 11
start local 11 37: StackMap locals: int
StackMap stack:
aload 2
iload 11
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeInt:(I)V
38: aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.dataRange:()Lorg/apache/cassandra/db/DataRange;
checkcast org.apache.cassandra.db.DataRange$Paging
astore 12
start local 12 39: aload 12
invokevirtual org.apache.cassandra.db.DataRange$Paging.getLastReturned:()Lorg/apache/cassandra/db/Clustering;
astore 13
start local 13 40: aload 13
invokestatic org.apache.cassandra.db.ClusteringBound.inclusiveStartOf:(Lorg/apache/cassandra/db/ClusteringPrefix;)Lorg/apache/cassandra/db/ClusteringBound;
astore 14
start local 14 41: aload 6
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexSliceFilter.requestedSlices:()Lorg/apache/cassandra/db/Slices;
aload 6
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexSliceFilter.requestedSlices:()Lorg/apache/cassandra/db/Slices;
invokevirtual org.apache.cassandra.db.Slices.size:()I
iconst_1
isub
invokevirtual org.apache.cassandra.db.Slices.get:(I)Lorg/apache/cassandra/db/Slice;
astore 15
start local 15 42: aload 5
aload 14
iconst_1
invokestatic org.apache.cassandra.db.LegacyLayout.encodeBound:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/ClusteringBound;Z)Ljava/nio/ByteBuffer;
aload 2
invokestatic org.apache.cassandra.utils.ByteBufferUtil.writeWithShortLength:(Ljava/nio/ByteBuffer;Lorg/apache/cassandra/io/util/DataOutputPlus;)V
43: aload 5
aload 15
invokevirtual org.apache.cassandra.db.Slice.end:()Lorg/apache/cassandra/db/ClusteringBound;
invokevirtual org.apache.cassandra.db.ClusteringBound.clustering:()Lorg/apache/cassandra/db/ClusteringPrefix;
invokestatic org.apache.cassandra.db.LegacyLayout.encodeClustering:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/ClusteringPrefix;)Ljava/nio/ByteBuffer;
aload 2
invokestatic org.apache.cassandra.utils.ByteBufferUtil.writeWithShortLength:(Ljava/nio/ByteBuffer;Lorg/apache/cassandra/io/util/DataOutputPlus;)V
44: aload 2
aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.rowFilter:()Lorg/apache/cassandra/db/filter/RowFilter;
invokestatic org.apache.cassandra.db.ReadCommand$LegacyRangeSliceCommandSerializer.serializeRowFilter:(Lorg/apache/cassandra/io/util/DataOutputPlus;Lorg/apache/cassandra/db/filter/RowFilter;)V
45: aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
invokevirtual org.apache.cassandra.db.filter.DataLimits.count:()I
iconst_1
iadd
istore 16
start local 16 46: aload 2
iload 16
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeInt:(I)V
47: aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.isForThrift:()Z
ifne 48
aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
invokevirtual org.apache.cassandra.db.filter.DataLimits.perPartitionCount:()I
iconst_1
if_icmpne 49
48: StackMap locals: org.apache.cassandra.db.ReadCommand$LegacyPagedRangeCommandSerializer org.apache.cassandra.db.ReadCommand org.apache.cassandra.io.util.DataOutputPlus int org.apache.cassandra.db.PartitionRangeReadCommand org.apache.cassandra.config.CFMetaData org.apache.cassandra.db.filter.ClusteringIndexSliceFilter int org.apache.cassandra.db.filter.DataLimits$Kind int int int org.apache.cassandra.db.DataRange$Paging org.apache.cassandra.db.Clustering org.apache.cassandra.db.ClusteringBound org.apache.cassandra.db.Slice int
StackMap stack:
aload 2
iconst_0
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeBoolean:(Z)V
goto 50
49: StackMap locals:
StackMap stack:
aload 2
iconst_1
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeBoolean:(Z)V
50: StackMap locals:
StackMap stack:
return
end local 16 end local 15 end local 14 end local 13 end local 12 end local 11 end local 10 end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 51 0 this Lorg/apache/cassandra/db/ReadCommand$LegacyPagedRangeCommandSerializer;
0 51 1 command Lorg/apache/cassandra/db/ReadCommand;
0 51 2 out Lorg/apache/cassandra/io/util/DataOutputPlus;
0 51 3 version I
2 51 4 rangeCommand Lorg/apache/cassandra/db/PartitionRangeReadCommand;
4 51 5 metadata Lorg/apache/cassandra/config/CFMetaData;
10 11 6 filter Lorg/apache/cassandra/db/filter/ClusteringIndexSliceFilter;
12 51 6 filter Lorg/apache/cassandra/db/filter/ClusteringIndexSliceFilter;
15 51 7 makeStaticSlice Z
18 51 8 kind Lorg/apache/cassandra/db/filter/DataLimits$Kind;
22 51 9 isDistinct Z
28 51 10 selectsStatics Z
30 31 11 compositesToGroup I
33 34 11 compositesToGroup I
37 51 11 compositesToGroup I
39 51 12 pagingRange Lorg/apache/cassandra/db/DataRange$Paging;
40 51 13 lastReturned Lorg/apache/cassandra/db/Clustering;
41 51 14 newStart Lorg/apache/cassandra/db/ClusteringBound;
42 51 15 lastSlice Lorg/apache/cassandra/db/Slice;
46 51 16 maxResults I
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
command
out
version
public org.apache.cassandra.db.ReadCommand deserialize(org.apache.cassandra.io.util.DataInputPlus, int);
descriptor: (Lorg/apache/cassandra/io/util/DataInputPlus;I)Lorg/apache/cassandra/db/ReadCommand;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=21, args_size=3
start local 0 start local 1 start local 2 0: getstatic org.apache.cassandra.db.ReadCommand$LegacyPagedRangeCommandSerializer.$assertionsDisabled:Z
ifne 1
iload 2
bipush 10
if_icmplt 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 1
invokeinterface org.apache.cassandra.io.util.DataInputPlus.readUTF:()Ljava/lang/String;
astore 3
start local 3 2: aload 1
invokeinterface org.apache.cassandra.io.util.DataInputPlus.readUTF:()Ljava/lang/String;
astore 4
start local 4 3: getstatic org.apache.cassandra.config.Schema.instance:Lorg/apache/cassandra/config/Schema;
aload 3
aload 4
invokevirtual org.apache.cassandra.config.Schema.getCFMetaData:(Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
astore 5
start local 5 4: aload 5
ifnonnull 7
5: ldc "Got legacy paged range command for nonexistent table %s.%s."
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 3
aastore
dup
iconst_1
aload 4
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 6
start local 6 6: new org.apache.cassandra.db.UnknownColumnFamilyException
dup
aload 6
aconst_null
invokespecial org.apache.cassandra.db.UnknownColumnFamilyException.<init>:(Ljava/lang/String;Ljava/util/UUID;)V
athrow
end local 6 7: StackMap locals: java.lang.String java.lang.String org.apache.cassandra.config.CFMetaData
StackMap stack:
aload 1
invokeinterface org.apache.cassandra.io.util.DataInputPlus.readLong:()J
ldc 1000
ldiv
l2i
istore 6
start local 6 8: getstatic org.apache.cassandra.dht.AbstractBounds.rowPositionSerializer:Lorg/apache/cassandra/dht/IPartitionerDependentSerializer;
aload 1
aload 5
getfield org.apache.cassandra.config.CFMetaData.partitioner:Lorg/apache/cassandra/dht/IPartitioner;
iload 2
invokeinterface org.apache.cassandra.dht.IPartitionerDependentSerializer.deserialize:(Ljava/io/DataInput;Lorg/apache/cassandra/dht/IPartitioner;I)Ljava/lang/Object;
checkcast org.apache.cassandra.dht.AbstractBounds
astore 7
start local 7 9: aload 1
aload 5
invokestatic org.apache.cassandra.db.ReadCommand$LegacyReadCommandSerializer.deserializeSlicePartitionFilter:(Lorg/apache/cassandra/io/util/DataInputPlus;Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/utils/Pair;
astore 8
start local 8 10: aload 8
getfield org.apache.cassandra.utils.Pair.left:Ljava/lang/Object;
checkcast org.apache.cassandra.db.filter.ClusteringIndexSliceFilter
astore 9
start local 9 11: aload 8
getfield org.apache.cassandra.utils.Pair.right:Ljava/lang/Object;
checkcast java.lang.Boolean
invokevirtual java.lang.Boolean.booleanValue:()Z
istore 10
start local 10 12: aload 1
invokeinterface org.apache.cassandra.io.util.DataInputPlus.readInt:()I
pop
13: aload 1
invokeinterface org.apache.cassandra.io.util.DataInputPlus.readInt:()I
istore 11
start local 11 14: aload 5
aload 1
invokestatic org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength:(Ljava/io/DataInput;)Ljava/nio/ByteBuffer;
iconst_1
invokestatic org.apache.cassandra.db.LegacyLayout.decodeSliceBound:(Lorg/apache/cassandra/config/CFMetaData;Ljava/nio/ByteBuffer;Z)Lorg/apache/cassandra/db/LegacyLayout$LegacyBound;
astore 12
start local 12 15: aload 1
invokestatic org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength:(Ljava/io/DataInput;)Ljava/nio/ByteBuffer;
pop
16: iload 10
iload 11
aload 5
invokestatic org.apache.cassandra.db.ReadCommand$LegacyRangeSliceCommandSerializer.getColumnSelectionForSlice:(ZILorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/db/filter/ColumnFilter;
astore 13
start local 13 17: aload 1
aload 5
invokestatic org.apache.cassandra.db.ReadCommand$LegacyRangeSliceCommandSerializer.deserializeRowFilter:(Lorg/apache/cassandra/io/util/DataInputPlus;Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/db/filter/RowFilter;
astore 14
start local 14 18: aload 1
invokeinterface org.apache.cassandra.io.util.DataInputPlus.readInt:()I
istore 15
start local 15 19: aload 1
invokeinterface org.apache.cassandra.io.util.DataInputPlus.readBoolean:()Z
istore 16
start local 16 20: iload 11
bipush -2
if_icmpeq 22
iload 11
iconst_m1
if_icmpeq 21
iload 16
ifeq 22
StackMap locals: org.apache.cassandra.db.ReadCommand$LegacyPagedRangeCommandSerializer org.apache.cassandra.io.util.DataInputPlus int java.lang.String java.lang.String org.apache.cassandra.config.CFMetaData int org.apache.cassandra.dht.AbstractBounds org.apache.cassandra.utils.Pair org.apache.cassandra.db.filter.ClusteringIndexSliceFilter int int org.apache.cassandra.db.LegacyLayout$LegacyBound org.apache.cassandra.db.filter.ColumnFilter org.apache.cassandra.db.filter.RowFilter int int
StackMap stack:
21: iconst_0
goto 23
StackMap locals:
StackMap stack:
22: iconst_1
StackMap locals:
StackMap stack: int
23: istore 17
start local 17 24: iload 17
ifeq 27
25: iload 15
invokestatic org.apache.cassandra.db.filter.DataLimits.distinctLimits:(I)Lorg/apache/cassandra/db/filter/DataLimits;
astore 18
start local 18 26: goto 28
end local 18 27: StackMap locals: int
StackMap stack:
iload 15
invokestatic org.apache.cassandra.db.filter.DataLimits.cqlLimits:(I)Lorg/apache/cassandra/db/filter/DataLimits;
astore 18
start local 18 28: StackMap locals: org.apache.cassandra.db.filter.DataLimits
StackMap stack:
aload 18
iload 15
invokevirtual org.apache.cassandra.db.filter.DataLimits.forPaging:(I)Lorg/apache/cassandra/db/filter/DataLimits;
astore 18
29: new org.apache.cassandra.db.DataRange
dup
aload 7
aload 9
invokespecial org.apache.cassandra.db.DataRange.<init>:(Lorg/apache/cassandra/dht/AbstractBounds;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;)V
astore 19
start local 19 30: aload 9
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexSliceFilter.requestedSlices:()Lorg/apache/cassandra/db/Slices;
astore 20
start local 20 31: iload 17
ifne 33
aload 12
getstatic org.apache.cassandra.db.LegacyLayout$LegacyBound.BOTTOM:Lorg/apache/cassandra/db/LegacyLayout$LegacyBound;
if_acmpeq 33
aload 12
getfield org.apache.cassandra.db.LegacyLayout$LegacyBound.bound:Lorg/apache/cassandra/db/ClusteringBound;
aload 20
iconst_0
invokevirtual org.apache.cassandra.db.Slices.get:(I)Lorg/apache/cassandra/db/Slice;
invokevirtual org.apache.cassandra.db.Slice.start:()Lorg/apache/cassandra/db/ClusteringBound;
invokevirtual org.apache.cassandra.db.ClusteringBound.equals:(Ljava/lang/Object;)Z
ifne 33
32: aload 19
aload 7
aload 5
getfield org.apache.cassandra.config.CFMetaData.comparator:Lorg/apache/cassandra/db/ClusteringComparator;
aload 12
aload 5
invokevirtual org.apache.cassandra.db.LegacyLayout$LegacyBound.getAsClustering:(Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/db/Clustering;
iconst_0
invokevirtual org.apache.cassandra.db.DataRange.forPaging:(Lorg/apache/cassandra/dht/AbstractBounds;Lorg/apache/cassandra/db/ClusteringComparator;Lorg/apache/cassandra/db/Clustering;Z)Lorg/apache/cassandra/db/DataRange;
astore 19
33: StackMap locals: org.apache.cassandra.db.DataRange org.apache.cassandra.db.Slices
StackMap stack:
iconst_1
aload 5
iload 6
aload 13
aload 14
aload 18
aload 19
invokestatic org.apache.cassandra.db.PartitionRangeReadCommand.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/DataRange;)Lorg/apache/cassandra/db/PartitionRangeReadCommand;
areturn
end local 20 end local 19 end local 18 end local 17 end local 16 end local 15 end local 14 end local 13 end local 12 end local 11 end local 10 end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 34 0 this Lorg/apache/cassandra/db/ReadCommand$LegacyPagedRangeCommandSerializer;
0 34 1 in Lorg/apache/cassandra/io/util/DataInputPlus;
0 34 2 version I
2 34 3 keyspace Ljava/lang/String;
3 34 4 columnFamily Ljava/lang/String;
4 34 5 metadata Lorg/apache/cassandra/config/CFMetaData;
6 7 6 message Ljava/lang/String;
8 34 6 nowInSec I
9 34 7 keyRange Lorg/apache/cassandra/dht/AbstractBounds<Lorg/apache/cassandra/db/PartitionPosition;>;
10 34 8 p Lorg/apache/cassandra/utils/Pair<Lorg/apache/cassandra/db/filter/ClusteringIndexSliceFilter;Ljava/lang/Boolean;>;
11 34 9 filter Lorg/apache/cassandra/db/filter/ClusteringIndexSliceFilter;
12 34 10 selectsStatics Z
14 34 11 compositesToGroup I
15 34 12 startBound Lorg/apache/cassandra/db/LegacyLayout$LegacyBound;
17 34 13 selection Lorg/apache/cassandra/db/filter/ColumnFilter;
18 34 14 rowFilter Lorg/apache/cassandra/db/filter/RowFilter;
19 34 15 maxResults I
20 34 16 countCQL3Rows Z
24 34 17 isDistinct Z
26 27 18 limits Lorg/apache/cassandra/db/filter/DataLimits;
28 34 18 limits Lorg/apache/cassandra/db/filter/DataLimits;
30 34 19 dataRange Lorg/apache/cassandra/db/DataRange;
31 34 20 slices Lorg/apache/cassandra/db/Slices;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
in
version
public long serializedSize(org.apache.cassandra.db.ReadCommand, int);
descriptor: (Lorg/apache/cassandra/db/ReadCommand;I)J
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=12, args_size=3
start local 0 start local 1 start local 2 0: getstatic org.apache.cassandra.db.ReadCommand$LegacyPagedRangeCommandSerializer.$assertionsDisabled:Z
ifne 1
iload 2
bipush 10
if_icmplt 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.db.ReadCommand$LegacyPagedRangeCommandSerializer.$assertionsDisabled:Z
ifne 2
aload 1
getfield org.apache.cassandra.db.ReadCommand.kind:Lorg/apache/cassandra/db/ReadCommand$Kind;
getstatic org.apache.cassandra.db.ReadCommand$Kind.PARTITION_RANGE:Lorg/apache/cassandra/db/ReadCommand$Kind;
if_acmpeq 2
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
2: StackMap locals:
StackMap stack:
aload 1
checkcast org.apache.cassandra.db.PartitionRangeReadCommand
astore 3
start local 3 3: aload 3
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
astore 4
start local 4 4: getstatic org.apache.cassandra.db.ReadCommand$LegacyPagedRangeCommandSerializer.$assertionsDisabled:Z
ifne 5
aload 3
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.dataRange:()Lorg/apache/cassandra/db/DataRange;
invokevirtual org.apache.cassandra.db.DataRange.isPaging:()Z
ifne 5
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
5: StackMap locals: org.apache.cassandra.db.PartitionRangeReadCommand org.apache.cassandra.config.CFMetaData
StackMap stack:
aload 4
getfield org.apache.cassandra.config.CFMetaData.ksName:Ljava/lang/String;
invokestatic org.apache.cassandra.db.TypeSizes.sizeof:(Ljava/lang/String;)I
i2l
lstore 5
start local 5 6: lload 5
aload 4
getfield org.apache.cassandra.config.CFMetaData.cfName:Ljava/lang/String;
invokestatic org.apache.cassandra.db.TypeSizes.sizeof:(Ljava/lang/String;)I
i2l
ladd
lstore 5
7: lload 5
aload 3
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.nowInSec:()I
i2l
invokestatic org.apache.cassandra.db.TypeSizes.sizeof:(J)I
i2l
ladd
lstore 5
8: lload 5
getstatic org.apache.cassandra.dht.AbstractBounds.rowPositionSerializer:Lorg/apache/cassandra/dht/IPartitionerDependentSerializer;
aload 3
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.dataRange:()Lorg/apache/cassandra/db/DataRange;
invokevirtual org.apache.cassandra.db.DataRange.keyRange:()Lorg/apache/cassandra/dht/AbstractBounds;
iload 2
invokeinterface org.apache.cassandra.dht.IPartitionerDependentSerializer.serializedSize:(Ljava/lang/Object;I)J
ladd
lstore 5
9: aload 3
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.dataRange:()Lorg/apache/cassandra/db/DataRange;
getfield org.apache.cassandra.db.DataRange.clusteringIndexFilter:Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
invokeinterface org.apache.cassandra.db.filter.ClusteringIndexFilter.kind:()Lorg/apache/cassandra/db/filter/ClusteringIndexFilter$Kind;
getstatic org.apache.cassandra.db.filter.ClusteringIndexFilter$Kind.NAMES:Lorg/apache/cassandra/db/filter/ClusteringIndexFilter$Kind;
if_acmpne 12
10: aload 3
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.dataRange:()Lorg/apache/cassandra/db/DataRange;
getfield org.apache.cassandra.db.DataRange.clusteringIndexFilter:Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
checkcast org.apache.cassandra.db.filter.ClusteringIndexNamesFilter
aload 4
invokestatic org.apache.cassandra.db.ReadCommand$LegacyReadCommandSerializer.convertNamesFilterToSliceFilter:(Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/db/filter/ClusteringIndexSliceFilter;
astore 7
start local 7 11: goto 13
end local 7 12: StackMap locals: long
StackMap stack:
aload 3
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.dataRange:()Lorg/apache/cassandra/db/DataRange;
getfield org.apache.cassandra.db.DataRange.clusteringIndexFilter:Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
checkcast org.apache.cassandra.db.filter.ClusteringIndexSliceFilter
astore 7
start local 7 13: StackMap locals: org.apache.cassandra.db.filter.ClusteringIndexSliceFilter
StackMap stack:
aload 3
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.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 14
aload 7
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexSliceFilter.requestedSlices:()Lorg/apache/cassandra/db/Slices;
getstatic org.apache.cassandra.db.Clustering.STATIC_CLUSTERING:Lorg/apache/cassandra/db/Clustering;
invokevirtual org.apache.cassandra.db.Slices.selects:(Lorg/apache/cassandra/db/Clustering;)Z
ifne 14
iconst_1
goto 15
StackMap locals:
StackMap stack:
14: iconst_0
StackMap locals:
StackMap stack: int
15: istore 8
start local 8 16: lload 5
aload 7
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexSliceFilter.requestedSlices:()Lorg/apache/cassandra/db/Slices;
iload 8
aload 4
invokestatic org.apache.cassandra.db.ReadCommand$LegacyReadCommandSerializer.serializedSlicesSize:(Lorg/apache/cassandra/db/Slices;ZLorg/apache/cassandra/config/CFMetaData;)J
ladd
lstore 5
17: lload 5
aload 7
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexSliceFilter.isReversed:()Z
invokestatic org.apache.cassandra.db.TypeSizes.sizeof:(Z)I
i2l
ladd
lstore 5
18: lload 5
aload 3
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
invokevirtual org.apache.cassandra.db.filter.DataLimits.perPartitionCount:()I
invokestatic org.apache.cassandra.db.TypeSizes.sizeof:(I)I
i2l
ladd
lstore 5
19: lload 5
iconst_0
invokestatic org.apache.cassandra.db.TypeSizes.sizeof:(I)I
i2l
ladd
lstore 5
20: aload 3
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.dataRange:()Lorg/apache/cassandra/db/DataRange;
checkcast org.apache.cassandra.db.DataRange$Paging
astore 9
start local 9 21: aload 9
invokevirtual org.apache.cassandra.db.DataRange$Paging.getLastReturned:()Lorg/apache/cassandra/db/Clustering;
astore 10
start local 10 22: aload 7
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexSliceFilter.requestedSlices:()Lorg/apache/cassandra/db/Slices;
aload 7
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexSliceFilter.requestedSlices:()Lorg/apache/cassandra/db/Slices;
invokevirtual org.apache.cassandra.db.Slices.size:()I
iconst_1
isub
invokevirtual org.apache.cassandra.db.Slices.get:(I)Lorg/apache/cassandra/db/Slice;
astore 11
start local 11 23: lload 5
aload 4
aload 10
invokestatic org.apache.cassandra.db.LegacyLayout.encodeClustering:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/ClusteringPrefix;)Ljava/nio/ByteBuffer;
invokestatic org.apache.cassandra.utils.ByteBufferUtil.serializedSizeWithShortLength:(Ljava/nio/ByteBuffer;)I
i2l
ladd
lstore 5
24: lload 5
aload 4
aload 11
invokevirtual org.apache.cassandra.db.Slice.end:()Lorg/apache/cassandra/db/ClusteringBound;
invokevirtual org.apache.cassandra.db.ClusteringBound.clustering:()Lorg/apache/cassandra/db/ClusteringPrefix;
invokestatic org.apache.cassandra.db.LegacyLayout.encodeClustering:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/ClusteringPrefix;)Ljava/nio/ByteBuffer;
invokestatic org.apache.cassandra.utils.ByteBufferUtil.serializedSizeWithShortLength:(Ljava/nio/ByteBuffer;)I
i2l
ladd
lstore 5
25: lload 5
aload 3
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.rowFilter:()Lorg/apache/cassandra/db/filter/RowFilter;
invokestatic org.apache.cassandra.db.ReadCommand$LegacyRangeSliceCommandSerializer.serializedRowFilterSize:(Lorg/apache/cassandra/db/filter/RowFilter;)J
ladd
lstore 5
26: lload 5
aload 3
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
invokevirtual org.apache.cassandra.db.filter.DataLimits.count:()I
invokestatic org.apache.cassandra.db.TypeSizes.sizeof:(I)I
i2l
ladd
lstore 5
27: lload 5
iconst_1
invokestatic org.apache.cassandra.db.TypeSizes.sizeof:(Z)I
i2l
ladd
lreturn
end local 11 end local 10 end local 9 end local 8 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 28 0 this Lorg/apache/cassandra/db/ReadCommand$LegacyPagedRangeCommandSerializer;
0 28 1 command Lorg/apache/cassandra/db/ReadCommand;
0 28 2 version I
3 28 3 rangeCommand Lorg/apache/cassandra/db/PartitionRangeReadCommand;
4 28 4 metadata Lorg/apache/cassandra/config/CFMetaData;
6 28 5 size J
11 12 7 filter Lorg/apache/cassandra/db/filter/ClusteringIndexSliceFilter;
13 28 7 filter Lorg/apache/cassandra/db/filter/ClusteringIndexSliceFilter;
16 28 8 makeStaticSlice Z
21 28 9 pagingRange Lorg/apache/cassandra/db/DataRange$Paging;
22 28 10 lastReturned Lorg/apache/cassandra/db/Clustering;
23 28 11 lastSlice Lorg/apache/cassandra/db/Slice;
MethodParameters:
Name Flags
command
version
public void serialize(java.lang.Object, org.apache.cassandra.io.util.DataOutputPlus, int);
descriptor: (Ljava/lang/Object;Lorg/apache/cassandra/io/util/DataOutputPlus;I)V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=4
0: aload 0
aload 1
checkcast org.apache.cassandra.db.ReadCommand
aload 2
iload 3
invokevirtual org.apache.cassandra.db.ReadCommand$LegacyPagedRangeCommandSerializer.serialize:(Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/io/util/DataOutputPlus;I)V
return
LocalVariableTable:
Start End Slot Name Signature
Exceptions:
throws java.io.IOException
public long serializedSize(java.lang.Object, int);
descriptor: (Ljava/lang/Object;I)J
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
checkcast org.apache.cassandra.db.ReadCommand
iload 2
invokevirtual org.apache.cassandra.db.ReadCommand$LegacyPagedRangeCommandSerializer.serializedSize:(Lorg/apache/cassandra/db/ReadCommand;I)J
lreturn
LocalVariableTable:
Start End Slot Name Signature
public java.lang.Object deserialize(org.apache.cassandra.io.util.DataInputPlus, int);
descriptor: (Lorg/apache/cassandra/io/util/DataInputPlus;I)Ljava/lang/Object;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
iload 2
invokevirtual org.apache.cassandra.db.ReadCommand$LegacyPagedRangeCommandSerializer.deserialize:(Lorg/apache/cassandra/io/util/DataInputPlus;I)Lorg/apache/cassandra/db/ReadCommand;
areturn
LocalVariableTable:
Start End Slot Name Signature
Exceptions:
throws java.io.IOException
}
Signature: Ljava/lang/Object;Lorg/apache/cassandra/io/IVersionedSerializer<Lorg/apache/cassandra/db/ReadCommand;>;
SourceFile: "ReadCommand.java"
NestHost: org.apache.cassandra.db.ReadCommand
InnerClasses:
public Paging = org.apache.cassandra.db.DataRange$Paging of org.apache.cassandra.db.DataRange
public LegacyBound = org.apache.cassandra.db.LegacyLayout$LegacyBound of org.apache.cassandra.db.LegacyLayout
protected final Kind = org.apache.cassandra.db.ReadCommand$Kind of org.apache.cassandra.db.ReadCommand
private LegacyPagedRangeCommandSerializer = org.apache.cassandra.db.ReadCommand$LegacyPagedRangeCommandSerializer of org.apache.cassandra.db.ReadCommand
private LegacyRangeSliceCommandSerializer = org.apache.cassandra.db.ReadCommand$LegacyRangeSliceCommandSerializer of org.apache.cassandra.db.ReadCommand
LegacyReadCommandSerializer = org.apache.cassandra.db.ReadCommand$LegacyReadCommandSerializer of org.apache.cassandra.db.ReadCommand
public final Kind = org.apache.cassandra.db.filter.ClusteringIndexFilter$Kind of org.apache.cassandra.db.filter.ClusteringIndexFilter
public final Kind = org.apache.cassandra.db.filter.DataLimits$Kind of org.apache.cassandra.db.filter.DataLimits