class org.apache.cassandra.db.ReadCommand$LegacyRangeSliceCommandSerializer 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$LegacyRangeSliceCommandSerializer
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$LegacyRangeSliceCommandSerializer.$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$LegacyRangeSliceCommandSerializer;
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=11, args_size=4
start local 0 start local 1 start local 2 start local 3 0: getstatic org.apache.cassandra.db.ReadCommand$LegacyRangeSliceCommandSerializer.$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$LegacyRangeSliceCommandSerializer.$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
ifeq 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
invokestatic org.apache.cassandra.db.ReadCommand$LegacyRangeSliceCommandSerializer.maybeConvertNamesToSlice:(Lorg/apache/cassandra/db/PartitionRangeReadCommand;)Lorg/apache/cassandra/db/PartitionRangeReadCommand;
astore 4
4: aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
astore 5
start local 5 5: 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
6: 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
7: 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
8: aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.isNamesQuery:()Z
ifeq 13
9: aload 2
iconst_1
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeByte:(I)V
10: 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
astore 6
start local 6 11: aload 4
aload 6
aload 2
invokestatic org.apache.cassandra.db.ReadCommand$LegacyReadCommandSerializer.serializeNamesFilter:(Lorg/apache/cassandra/db/ReadCommand;Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;Lorg/apache/cassandra/io/util/DataOutputPlus;)V
end local 6 12: goto 37
13: StackMap locals: org.apache.cassandra.config.CFMetaData
StackMap stack:
aload 2
iconst_0
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeByte:(I)V
14: 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 15: 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 16
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 16
iconst_1
goto 17
StackMap locals: org.apache.cassandra.db.filter.ClusteringIndexSliceFilter
StackMap stack:
16: iconst_0
StackMap locals:
StackMap stack: int
17: istore 7
start local 7 18: 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
19: aload 2
aload 6
invokevirtual org.apache.cassandra.db.filter.ClusteringIndexSliceFilter.isReversed:()Z
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeBoolean:(Z)V
20: aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
astore 8
start local 8 21: aload 8
invokevirtual org.apache.cassandra.db.filter.DataLimits.isDistinct:()Z
ifeq 23
22: aload 2
iconst_1
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeInt:(I)V
goto 24
23: StackMap locals: int org.apache.cassandra.db.filter.DataLimits
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.count:()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
24: 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
ifne 25
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
ifeq 25
iconst_1
goto 26
StackMap locals:
StackMap stack:
25: iconst_0
StackMap locals:
StackMap stack: int
26: istore 10
start local 10 27: aload 8
invokevirtual org.apache.cassandra.db.filter.DataLimits.kind:()Lorg/apache/cassandra/db/filter/DataLimits$Kind;
getstatic org.apache.cassandra.db.filter.DataLimits$Kind.THRIFT_LIMIT:Lorg/apache/cassandra/db/filter/DataLimits$Kind;
if_acmpne 30
28: iconst_m1
istore 9
start local 9 29: goto 36
end local 9 30: StackMap locals: org.apache.cassandra.db.ReadCommand$LegacyRangeSliceCommandSerializer 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 top int
StackMap stack:
aload 8
invokevirtual org.apache.cassandra.db.filter.DataLimits.isDistinct:()Z
ifeq 33
iload 10
ifne 33
31: bipush -2
istore 9
start local 9 32: goto 36
end local 9 33: StackMap locals:
StackMap stack:
aload 5
invokevirtual org.apache.cassandra.config.CFMetaData.isDense:()Z
ifeq 34
iconst_m1
goto 35
StackMap locals:
StackMap stack:
34: aload 5
invokevirtual org.apache.cassandra.config.CFMetaData.clusteringColumns:()Ljava/util/List;
invokeinterface java.util.List.size:()I
StackMap locals:
StackMap stack: int
35: istore 9
start local 9 36: StackMap locals: org.apache.cassandra.db.ReadCommand$LegacyRangeSliceCommandSerializer 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 int int
StackMap stack:
aload 2
iload 9
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeInt:(I)V
end local 10 end local 9 end local 8 end local 7 end local 6 37: StackMap locals: org.apache.cassandra.db.ReadCommand$LegacyRangeSliceCommandSerializer org.apache.cassandra.db.ReadCommand org.apache.cassandra.io.util.DataOutputPlus int org.apache.cassandra.db.PartitionRangeReadCommand org.apache.cassandra.config.CFMetaData
StackMap stack:
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
38: 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
39: aload 2
aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.limits:()Lorg/apache/cassandra/db/filter/DataLimits;
invokevirtual org.apache.cassandra.db.filter.DataLimits.count:()I
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeInt:(I)V
40: aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.isForThrift:()Z
ifne 41
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 42
41: StackMap locals:
StackMap stack:
aload 2
iconst_0
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeBoolean:(Z)V
goto 43
42: StackMap locals:
StackMap stack:
aload 2
iconst_1
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeBoolean:(Z)V
43: StackMap locals:
StackMap stack:
aload 2
iconst_0
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeBoolean:(Z)V
44: return
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 45 0 this Lorg/apache/cassandra/db/ReadCommand$LegacyRangeSliceCommandSerializer;
0 45 1 command Lorg/apache/cassandra/db/ReadCommand;
0 45 2 out Lorg/apache/cassandra/io/util/DataOutputPlus;
0 45 3 version I
2 45 4 rangeCommand Lorg/apache/cassandra/db/PartitionRangeReadCommand;
5 45 5 metadata Lorg/apache/cassandra/config/CFMetaData;
11 12 6 filter Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;
15 37 6 filter Lorg/apache/cassandra/db/filter/ClusteringIndexSliceFilter;
18 37 7 makeStaticSlice Z
21 37 8 limits Lorg/apache/cassandra/db/filter/DataLimits;
29 30 9 compositesToGroup I
32 33 9 compositesToGroup I
36 37 9 compositesToGroup I
27 37 10 selectsStatics Z
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=10, locals=18, args_size=3
start local 0 start local 1 start local 2 0: getstatic org.apache.cassandra.db.ReadCommand$LegacyRangeSliceCommandSerializer.$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 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: iconst_0
istore 9
start local 9 9: iconst_m1
istore 10
start local 10 10: aload 1
invokeinterface org.apache.cassandra.io.util.DataInputPlus.readByte:()B
istore 11
start local 11 11: iload 11
iconst_1
if_icmpne 16
12: aload 1
aload 5
invokestatic org.apache.cassandra.db.ReadCommand$LegacyReadCommandSerializer.deserializeNamesSelectionAndFilter:(Lorg/apache/cassandra/io/util/DataInputPlus;Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/utils/Pair;
astore 12
start local 12 13: aload 12
getfield org.apache.cassandra.utils.Pair.left:Ljava/lang/Object;
checkcast org.apache.cassandra.db.filter.ColumnFilter
astore 8
start local 8 14: aload 12
getfield org.apache.cassandra.utils.Pair.right:Ljava/lang/Object;
checkcast org.apache.cassandra.db.filter.ClusteringIndexFilter
astore 7
end local 12 start local 7 15: goto 21
end local 8 end local 7 16: StackMap locals: org.apache.cassandra.db.ReadCommand$LegacyRangeSliceCommandSerializer org.apache.cassandra.io.util.DataInputPlus int java.lang.String java.lang.String org.apache.cassandra.config.CFMetaData int top top int int int
StackMap stack:
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 12
start local 12 17: aload 12
getfield org.apache.cassandra.utils.Pair.left:Ljava/lang/Object;
checkcast org.apache.cassandra.db.filter.ClusteringIndexFilter
astore 7
start local 7 18: aload 1
invokeinterface org.apache.cassandra.io.util.DataInputPlus.readInt:()I
istore 10
19: aload 1
invokeinterface org.apache.cassandra.io.util.DataInputPlus.readInt:()I
istore 9
20: aload 12
getfield org.apache.cassandra.utils.Pair.right:Ljava/lang/Object;
checkcast java.lang.Boolean
invokevirtual java.lang.Boolean.booleanValue:()Z
iload 9
aload 5
invokestatic org.apache.cassandra.db.ReadCommand$LegacyRangeSliceCommandSerializer.getColumnSelectionForSlice:(ZILorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/db/filter/ColumnFilter;
astore 8
end local 12 start local 8 21: StackMap locals: org.apache.cassandra.db.ReadCommand$LegacyRangeSliceCommandSerializer org.apache.cassandra.io.util.DataInputPlus int java.lang.String java.lang.String org.apache.cassandra.config.CFMetaData int org.apache.cassandra.db.filter.ClusteringIndexFilter org.apache.cassandra.db.filter.ColumnFilter int int int
StackMap stack:
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 12
start local 12 22: 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 13
start local 13 23: aload 1
invokeinterface org.apache.cassandra.io.util.DataInputPlus.readInt:()I
istore 14
start local 14 24: aload 1
invokeinterface org.apache.cassandra.io.util.DataInputPlus.readBoolean:()Z
istore 15
start local 15 25: aload 1
invokeinterface org.apache.cassandra.io.util.DataInputPlus.readBoolean:()Z
pop
26: aload 8
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 27
aload 7
getstatic org.apache.cassandra.db.Clustering.STATIC_CLUSTERING:Lorg/apache/cassandra/db/Clustering;
invokeinterface org.apache.cassandra.db.filter.ClusteringIndexFilter.selects:(Lorg/apache/cassandra/db/Clustering;)Z
pop
27: StackMap locals: org.apache.cassandra.db.ReadCommand$LegacyRangeSliceCommandSerializer org.apache.cassandra.io.util.DataInputPlus int java.lang.String java.lang.String org.apache.cassandra.config.CFMetaData int org.apache.cassandra.db.filter.ClusteringIndexFilter org.apache.cassandra.db.filter.ColumnFilter int int int org.apache.cassandra.db.filter.RowFilter org.apache.cassandra.dht.AbstractBounds int int
StackMap stack:
iload 9
bipush -2
if_icmpeq 29
iload 9
iconst_m1
if_icmpeq 28
iload 15
ifeq 29
StackMap locals:
StackMap stack:
28: iconst_0
goto 30
StackMap locals:
StackMap stack:
29: iconst_1
StackMap locals:
StackMap stack: int
30: istore 16
start local 16 31: iload 16
ifeq 34
32: iload 14
invokestatic org.apache.cassandra.db.filter.DataLimits.distinctLimits:(I)Lorg/apache/cassandra/db/filter/DataLimits;
astore 17
start local 17 33: goto 41
end local 17 34: StackMap locals: int
StackMap stack:
iload 9
iconst_m1
if_icmpne 37
35: iload 14
iload 10
invokestatic org.apache.cassandra.db.filter.DataLimits.thriftLimits:(II)Lorg/apache/cassandra/db/filter/DataLimits;
astore 17
start local 17 36: goto 41
end local 17 37: StackMap locals:
StackMap stack:
aload 5
invokevirtual org.apache.cassandra.config.CFMetaData.isStaticCompactTable:()Z
ifeq 40
38: iload 14
invokestatic org.apache.cassandra.db.filter.DataLimits.legacyCompactStaticCqlLimits:(I)Lorg/apache/cassandra/db/filter/DataLimits;
astore 17
start local 17 39: goto 41
end local 17 40: StackMap locals:
StackMap stack:
iload 14
invokestatic org.apache.cassandra.db.filter.DataLimits.cqlLimits:(I)Lorg/apache/cassandra/db/filter/DataLimits;
astore 17
start local 17 41: StackMap locals: org.apache.cassandra.db.filter.DataLimits
StackMap stack:
iconst_1
aload 5
iload 6
aload 8
aload 12
aload 17
new org.apache.cassandra.db.DataRange
dup
aload 13
aload 7
invokespecial org.apache.cassandra.db.DataRange.<init>:(Lorg/apache/cassandra/dht/AbstractBounds;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;)V
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 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 42 0 this Lorg/apache/cassandra/db/ReadCommand$LegacyRangeSliceCommandSerializer;
0 42 1 in Lorg/apache/cassandra/io/util/DataInputPlus;
0 42 2 version I
2 42 3 keyspace Ljava/lang/String;
3 42 4 columnFamily Ljava/lang/String;
4 42 5 metadata Lorg/apache/cassandra/config/CFMetaData;
6 7 6 message Ljava/lang/String;
8 42 6 nowInSec I
15 16 7 filter Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
18 42 7 filter Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
14 16 8 selection Lorg/apache/cassandra/db/filter/ColumnFilter;
21 42 8 selection Lorg/apache/cassandra/db/filter/ColumnFilter;
9 42 9 compositesToGroup I
10 42 10 perPartitionLimit I
11 42 11 readType B
13 15 12 selectionAndFilter Lorg/apache/cassandra/utils/Pair<Lorg/apache/cassandra/db/filter/ColumnFilter;Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;>;
17 21 12 p Lorg/apache/cassandra/utils/Pair<Lorg/apache/cassandra/db/filter/ClusteringIndexSliceFilter;Ljava/lang/Boolean;>;
22 42 12 rowFilter Lorg/apache/cassandra/db/filter/RowFilter;
23 42 13 keyRange Lorg/apache/cassandra/dht/AbstractBounds<Lorg/apache/cassandra/db/PartitionPosition;>;
24 42 14 maxResults I
25 42 15 countCQL3Rows Z
31 42 16 isDistinct Z
33 34 17 limits Lorg/apache/cassandra/db/filter/DataLimits;
36 37 17 limits Lorg/apache/cassandra/db/filter/DataLimits;
39 40 17 limits Lorg/apache/cassandra/db/filter/DataLimits;
41 42 17 limits Lorg/apache/cassandra/db/filter/DataLimits;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
in
version
static void serializeRowFilter(org.apache.cassandra.io.util.DataOutputPlus, org.apache.cassandra.db.filter.RowFilter);
descriptor: (Lorg/apache/cassandra/io/util/DataOutputPlus;Lorg/apache/cassandra/db/filter/RowFilter;)V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual org.apache.cassandra.db.filter.RowFilter.iterator:()Ljava/util/Iterator;
invokestatic com.google.common.collect.Lists.newArrayList:(Ljava/util/Iterator;)Ljava/util/ArrayList;
astore 2
start local 2 1: aload 0
aload 2
invokevirtual java.util.ArrayList.size:()I
invokeinterface org.apache.cassandra.io.util.DataOutputPlus.writeInt:(I)V
2: aload 2
invokevirtual java.util.ArrayList.iterator:()Ljava/util/Iterator;
astore 4
goto 7
StackMap locals: org.apache.cassandra.io.util.DataOutputPlus org.apache.cassandra.db.filter.RowFilter java.util.ArrayList top java.util.Iterator
StackMap stack:
3: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.filter.RowFilter$Expression
astore 3
start local 3 4: aload 3
invokevirtual org.apache.cassandra.db.filter.RowFilter$Expression.column:()Lorg/apache/cassandra/config/ColumnDefinition;
getfield org.apache.cassandra.config.ColumnDefinition.name:Lorg/apache/cassandra/cql3/ColumnIdentifier;
getfield org.apache.cassandra.cql3.ColumnIdentifier.bytes:Ljava/nio/ByteBuffer;
aload 0
invokestatic org.apache.cassandra.utils.ByteBufferUtil.writeWithShortLength:(Ljava/nio/ByteBuffer;Lorg/apache/cassandra/io/util/DataOutputPlus;)V
5: aload 3
invokevirtual org.apache.cassandra.db.filter.RowFilter$Expression.operator:()Lorg/apache/cassandra/cql3/Operator;
aload 0
invokevirtual org.apache.cassandra.cql3.Operator.writeTo:(Ljava/io/DataOutput;)V
6: aload 3
invokevirtual org.apache.cassandra.db.filter.RowFilter$Expression.getIndexValue:()Ljava/nio/ByteBuffer;
aload 0
invokestatic org.apache.cassandra.utils.ByteBufferUtil.writeWithShortLength:(Ljava/nio/ByteBuffer;Lorg/apache/cassandra/io/util/DataOutputPlus;)V
end local 3 7: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
8: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 out Lorg/apache/cassandra/io/util/DataOutputPlus;
0 9 1 rowFilter Lorg/apache/cassandra/db/filter/RowFilter;
1 9 2 indexExpressions Ljava/util/ArrayList<Lorg/apache/cassandra/db/filter/RowFilter$Expression;>;
4 7 3 expression Lorg/apache/cassandra/db/filter/RowFilter$Expression;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
out
rowFilter
static org.apache.cassandra.db.filter.RowFilter deserializeRowFilter(org.apache.cassandra.io.util.DataInputPlus, org.apache.cassandra.config.CFMetaData);
descriptor: (Lorg/apache/cassandra/io/util/DataInputPlus;Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/db/filter/RowFilter;
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=9, args_size=2
start local 0 start local 1 0: aload 0
invokeinterface org.apache.cassandra.io.util.DataInputPlus.readInt:()I
istore 2
start local 2 1: iload 2
ifne 3
2: getstatic org.apache.cassandra.db.filter.RowFilter.NONE:Lorg/apache/cassandra/db/filter/RowFilter;
areturn
3: StackMap locals: int
StackMap stack:
iload 2
invokestatic org.apache.cassandra.db.filter.RowFilter.create:(I)Lorg/apache/cassandra/db/filter/RowFilter;
astore 3
start local 3 4: iconst_0
istore 4
start local 4 5: goto 12
6: StackMap locals: org.apache.cassandra.db.filter.RowFilter int
StackMap stack:
aload 0
invokestatic org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength:(Ljava/io/DataInput;)Ljava/nio/ByteBuffer;
astore 5
start local 5 7: aload 1
aload 5
invokevirtual org.apache.cassandra.config.CFMetaData.getColumnDefinition:(Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/config/ColumnDefinition;
astore 6
start local 6 8: aload 0
invokestatic org.apache.cassandra.cql3.Operator.readFrom:(Ljava/io/DataInput;)Lorg/apache/cassandra/cql3/Operator;
astore 7
start local 7 9: aload 0
invokestatic org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength:(Ljava/io/DataInput;)Ljava/nio/ByteBuffer;
astore 8
start local 8 10: aload 3
aload 6
aload 7
aload 8
invokevirtual org.apache.cassandra.db.filter.RowFilter.add:(Lorg/apache/cassandra/config/ColumnDefinition;Lorg/apache/cassandra/cql3/Operator;Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/db/filter/RowFilter$SimpleExpression;
pop
end local 8 end local 7 end local 6 end local 5 11: iinc 4 1
StackMap locals:
StackMap stack:
12: iload 4
iload 2
if_icmplt 6
end local 4 13: aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 in Lorg/apache/cassandra/io/util/DataInputPlus;
0 14 1 metadata Lorg/apache/cassandra/config/CFMetaData;
1 14 2 numRowFilters I
4 14 3 rowFilter Lorg/apache/cassandra/db/filter/RowFilter;
5 13 4 i I
7 11 5 columnName Ljava/nio/ByteBuffer;
8 11 6 column Lorg/apache/cassandra/config/ColumnDefinition;
9 11 7 op Lorg/apache/cassandra/cql3/Operator;
10 11 8 indexValue Ljava/nio/ByteBuffer;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
in
metadata
static long serializedRowFilterSize(org.apache.cassandra.db.filter.RowFilter);
descriptor: (Lorg/apache/cassandra/db/filter/RowFilter;)J
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=5, args_size=1
start local 0 0: iconst_0
invokestatic org.apache.cassandra.db.TypeSizes.sizeof:(I)I
i2l
lstore 1
start local 1 1: aload 0
invokevirtual org.apache.cassandra.db.filter.RowFilter.iterator:()Ljava/util/Iterator;
astore 4
goto 6
StackMap locals: org.apache.cassandra.db.filter.RowFilter long top java.util.Iterator
StackMap stack:
2: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.filter.RowFilter$Expression
astore 3
start local 3 3: lload 1
aload 3
invokevirtual org.apache.cassandra.db.filter.RowFilter$Expression.column:()Lorg/apache/cassandra/config/ColumnDefinition;
getfield org.apache.cassandra.config.ColumnDefinition.name:Lorg/apache/cassandra/cql3/ColumnIdentifier;
getfield org.apache.cassandra.cql3.ColumnIdentifier.bytes:Ljava/nio/ByteBuffer;
invokestatic org.apache.cassandra.utils.ByteBufferUtil.serializedSizeWithShortLength:(Ljava/nio/ByteBuffer;)I
i2l
ladd
lstore 1
4: lload 1
iconst_0
invokestatic org.apache.cassandra.db.TypeSizes.sizeof:(I)I
i2l
ladd
lstore 1
5: lload 1
aload 3
invokevirtual org.apache.cassandra.db.filter.RowFilter$Expression.getIndexValue:()Ljava/nio/ByteBuffer;
invokestatic org.apache.cassandra.utils.ByteBufferUtil.serializedSizeWithShortLength:(Ljava/nio/ByteBuffer;)I
i2l
ladd
lstore 1
end local 3 6: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
7: lload 1
lreturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 rowFilter Lorg/apache/cassandra/db/filter/RowFilter;
1 8 1 size J
3 6 3 expression Lorg/apache/cassandra/db/filter/RowFilter$Expression;
MethodParameters:
Name Flags
rowFilter
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=10, args_size=3
start local 0 start local 1 start local 2 0: getstatic org.apache.cassandra.db.ReadCommand$LegacyRangeSliceCommandSerializer.$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$LegacyRangeSliceCommandSerializer.$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
invokestatic org.apache.cassandra.db.ReadCommand$LegacyRangeSliceCommandSerializer.maybeConvertNamesToSlice:(Lorg/apache/cassandra/db/PartitionRangeReadCommand;)Lorg/apache/cassandra/db/PartitionRangeReadCommand;
astore 3
4: aload 3
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
astore 4
start local 4 5: 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
lconst_1
ladd
lstore 5
9: aload 3
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.isNamesQuery:()Z
ifeq 14
10: 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;
astore 7
start local 7 11: 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
astore 8
start local 8 12: lload 5
aload 8
aload 4
aload 7
invokestatic org.apache.cassandra.db.ReadCommand$LegacyReadCommandSerializer.serializedNamesFilterSize:(Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/PartitionColumns;)J
ladd
lstore 5
end local 8 end local 7 13: goto 22
14: StackMap locals: org.apache.cassandra.db.PartitionRangeReadCommand org.apache.cassandra.config.CFMetaData 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 15: 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 16
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 16
iconst_1
goto 17
StackMap locals: org.apache.cassandra.db.filter.ClusteringIndexSliceFilter
StackMap stack:
16: iconst_0
StackMap locals:
StackMap stack: int
17: istore 8
start local 8 18: 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
19: 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
20: 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
21: lload 5
iconst_0
invokestatic org.apache.cassandra.db.TypeSizes.sizeof:(I)I
i2l
ladd
lstore 5
end local 8 end local 7 22: StackMap locals:
StackMap stack:
aload 3
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.rowFilter:()Lorg/apache/cassandra/db/filter/RowFilter;
getstatic org.apache.cassandra.db.filter.RowFilter.NONE:Lorg/apache/cassandra/db/filter/RowFilter;
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 25
23: lload 5
iconst_0
invokestatic org.apache.cassandra.db.TypeSizes.sizeof:(I)I
i2l
ladd
lstore 5
24: goto 33
25: StackMap locals:
StackMap stack:
aload 3
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.rowFilter:()Lorg/apache/cassandra/db/filter/RowFilter;
invokevirtual org.apache.cassandra.db.filter.RowFilter.iterator:()Ljava/util/Iterator;
invokestatic com.google.common.collect.Lists.newArrayList:(Ljava/util/Iterator;)Ljava/util/ArrayList;
astore 7
start local 7 26: lload 5
aload 7
invokevirtual java.util.ArrayList.size:()I
invokestatic org.apache.cassandra.db.TypeSizes.sizeof:(I)I
i2l
ladd
lstore 5
27: aload 7
invokevirtual java.util.ArrayList.iterator:()Ljava/util/Iterator;
astore 9
goto 32
StackMap locals: org.apache.cassandra.db.ReadCommand$LegacyRangeSliceCommandSerializer org.apache.cassandra.db.ReadCommand int org.apache.cassandra.db.PartitionRangeReadCommand org.apache.cassandra.config.CFMetaData long java.util.ArrayList top java.util.Iterator
StackMap stack:
28: aload 9
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.filter.RowFilter$Expression
astore 8
start local 8 29: lload 5
aload 8
invokevirtual org.apache.cassandra.db.filter.RowFilter$Expression.column:()Lorg/apache/cassandra/config/ColumnDefinition;
getfield org.apache.cassandra.config.ColumnDefinition.name:Lorg/apache/cassandra/cql3/ColumnIdentifier;
getfield org.apache.cassandra.cql3.ColumnIdentifier.bytes:Ljava/nio/ByteBuffer;
invokestatic org.apache.cassandra.utils.ByteBufferUtil.serializedSizeWithShortLength:(Ljava/nio/ByteBuffer;)I
i2l
ladd
lstore 5
30: lload 5
aload 8
invokevirtual org.apache.cassandra.db.filter.RowFilter$Expression.operator:()Lorg/apache/cassandra/cql3/Operator;
invokevirtual org.apache.cassandra.cql3.Operator.ordinal:()I
invokestatic org.apache.cassandra.db.TypeSizes.sizeof:(I)I
i2l
ladd
lstore 5
31: lload 5
aload 8
invokevirtual org.apache.cassandra.db.filter.RowFilter$Expression.getIndexValue:()Ljava/nio/ByteBuffer;
invokestatic org.apache.cassandra.utils.ByteBufferUtil.serializedSizeWithShortLength:(Ljava/nio/ByteBuffer;)I
i2l
ladd
lstore 5
end local 8 32: StackMap locals:
StackMap stack:
aload 9
invokeinterface java.util.Iterator.hasNext:()Z
ifne 28
end local 7 33: StackMap locals: org.apache.cassandra.db.ReadCommand$LegacyRangeSliceCommandSerializer org.apache.cassandra.db.ReadCommand int org.apache.cassandra.db.PartitionRangeReadCommand org.apache.cassandra.config.CFMetaData long
StackMap stack:
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
34: 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
35: lload 5
aload 3
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.isForThrift:()Z
ifeq 36
iconst_0
goto 37
StackMap locals:
StackMap stack: long
36: iconst_1
StackMap locals: org.apache.cassandra.db.ReadCommand$LegacyRangeSliceCommandSerializer org.apache.cassandra.db.ReadCommand int org.apache.cassandra.db.PartitionRangeReadCommand org.apache.cassandra.config.CFMetaData long
StackMap stack: long int
37: invokestatic org.apache.cassandra.db.TypeSizes.sizeof:(Z)I
i2l
ladd
lstore 5
38: lload 5
aload 3
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.dataRange:()Lorg/apache/cassandra/db/DataRange;
invokevirtual org.apache.cassandra.db.DataRange.isPaging:()Z
invokestatic org.apache.cassandra.db.TypeSizes.sizeof:(Z)I
i2l
ladd
lreturn
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 39 0 this Lorg/apache/cassandra/db/ReadCommand$LegacyRangeSliceCommandSerializer;
0 39 1 command Lorg/apache/cassandra/db/ReadCommand;
0 39 2 version I
3 39 3 rangeCommand Lorg/apache/cassandra/db/PartitionRangeReadCommand;
5 39 4 metadata Lorg/apache/cassandra/config/CFMetaData;
6 39 5 size J
11 13 7 columns Lorg/apache/cassandra/db/PartitionColumns;
12 13 8 filter Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;
15 22 7 filter Lorg/apache/cassandra/db/filter/ClusteringIndexSliceFilter;
18 22 8 makeStaticSlice Z
26 33 7 indexExpressions Ljava/util/ArrayList<Lorg/apache/cassandra/db/filter/RowFilter$Expression;>;
29 32 8 expression Lorg/apache/cassandra/db/filter/RowFilter$Expression;
MethodParameters:
Name Flags
command
version
static org.apache.cassandra.db.PartitionRangeReadCommand maybeConvertNamesToSlice(org.apache.cassandra.db.PartitionRangeReadCommand);
descriptor: (Lorg/apache/cassandra/db/PartitionRangeReadCommand;)Lorg/apache/cassandra/db/PartitionRangeReadCommand;
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=5, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.dataRange:()Lorg/apache/cassandra/db/DataRange;
invokevirtual org.apache.cassandra.db.DataRange.isNamesQuery:()Z
ifne 2
1: aload 0
areturn
2: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.metadata:()Lorg/apache/cassandra/config/CFMetaData;
astore 1
start local 1 3: aload 1
aload 0
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;
invokestatic org.apache.cassandra.db.ReadCommand$LegacyReadCommandSerializer.shouldConvertNamesToSlice:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/PartitionColumns;)Z
ifne 5
4: aload 0
areturn
5: StackMap locals: org.apache.cassandra.config.CFMetaData
StackMap stack:
aload 0
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
astore 2
start local 2 6: aload 2
aload 1
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 3
start local 3 7: new org.apache.cassandra.db.DataRange
dup
aload 0
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 3
invokespecial org.apache.cassandra.db.DataRange.<init>:(Lorg/apache/cassandra/dht/AbstractBounds;Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;)V
astore 4
start local 4 8: aload 0
aload 4
invokevirtual org.apache.cassandra.db.PartitionRangeReadCommand.withUpdatedDataRange:(Lorg/apache/cassandra/db/DataRange;)Lorg/apache/cassandra/db/PartitionRangeReadCommand;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 command Lorg/apache/cassandra/db/PartitionRangeReadCommand;
3 9 1 metadata Lorg/apache/cassandra/config/CFMetaData;
6 9 2 filter Lorg/apache/cassandra/db/filter/ClusteringIndexNamesFilter;
7 9 3 sliceFilter Lorg/apache/cassandra/db/filter/ClusteringIndexSliceFilter;
8 9 4 newRange Lorg/apache/cassandra/db/DataRange;
MethodParameters:
Name Flags
command
static org.apache.cassandra.db.filter.ColumnFilter getColumnSelectionForSlice(boolean, int, org.apache.cassandra.config.CFMetaData);
descriptor: (ZILorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/db/filter/ColumnFilter;
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=4, args_size=3
start local 0 start local 1 start local 2 0: iload 1
bipush -2
if_icmpne 2
1: aload 2
invokestatic org.apache.cassandra.db.filter.ColumnFilter.all:(Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/db/filter/ColumnFilter;
areturn
2: StackMap locals:
StackMap stack:
iload 0
ifeq 4
3: aload 2
invokevirtual org.apache.cassandra.config.CFMetaData.partitionColumns:()Lorg/apache/cassandra/db/PartitionColumns;
goto 5
4: StackMap locals:
StackMap stack:
aload 2
invokevirtual org.apache.cassandra.config.CFMetaData.partitionColumns:()Lorg/apache/cassandra/db/PartitionColumns;
invokevirtual org.apache.cassandra.db.PartitionColumns.withoutStatics:()Lorg/apache/cassandra/db/PartitionColumns;
5: StackMap locals:
StackMap stack: org.apache.cassandra.db.PartitionColumns
astore 3
start local 3 6: invokestatic org.apache.cassandra.db.filter.ColumnFilter.selectionBuilder:()Lorg/apache/cassandra/db/filter/ColumnFilter$Builder;
aload 3
invokevirtual org.apache.cassandra.db.filter.ColumnFilter$Builder.addAll:(Ljava/lang/Iterable;)Lorg/apache/cassandra/db/filter/ColumnFilter$Builder;
invokevirtual org.apache.cassandra.db.filter.ColumnFilter$Builder.build:()Lorg/apache/cassandra/db/filter/ColumnFilter;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 selectsStatics Z
0 7 1 compositesToGroup I
0 7 2 metadata Lorg/apache/cassandra/config/CFMetaData;
6 7 3 columns Lorg/apache/cassandra/db/PartitionColumns;
MethodParameters:
Name Flags
selectsStatics
compositesToGroup
metadata
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$LegacyRangeSliceCommandSerializer.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$LegacyRangeSliceCommandSerializer.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$LegacyRangeSliceCommandSerializer.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:
protected final Kind = org.apache.cassandra.db.ReadCommand$Kind 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 Builder = org.apache.cassandra.db.filter.ColumnFilter$Builder of org.apache.cassandra.db.filter.ColumnFilter
public final Kind = org.apache.cassandra.db.filter.DataLimits$Kind of org.apache.cassandra.db.filter.DataLimits
public abstract Expression = org.apache.cassandra.db.filter.RowFilter$Expression of org.apache.cassandra.db.filter.RowFilter
public SimpleExpression = org.apache.cassandra.db.filter.RowFilter$SimpleExpression of org.apache.cassandra.db.filter.RowFilter