class org.apache.cassandra.service.CacheService$CounterCacheSerializer$1 implements java.util.concurrent.Callable<org.apache.cassandra.utils.Pair<org.apache.cassandra.cache.CounterCacheKey, org.apache.cassandra.db.ClockAndCount>>
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: org.apache.cassandra.service.CacheService$CounterCacheSerializer$1
super_class: java.lang.Object
{
final org.apache.cassandra.service.CacheService$CounterCacheSerializer this$1;
descriptor: Lorg/apache/cassandra/service/CacheService$CounterCacheSerializer;
flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC
private final org.apache.cassandra.db.ColumnFamilyStore val$cfs;
descriptor: Lorg/apache/cassandra/db/ColumnFamilyStore;
flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC
private final java.nio.ByteBuffer val$partitionKey;
descriptor: Ljava/nio/ByteBuffer;
flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC
private final java.nio.ByteBuffer val$cellName;
descriptor: Ljava/nio/ByteBuffer;
flags: (0x1012) ACC_PRIVATE, ACC_FINAL, ACC_SYNTHETIC
void <init>(org.apache.cassandra.service.CacheService$CounterCacheSerializer, org.apache.cassandra.db.ColumnFamilyStore, java.nio.ByteBuffer, java.nio.ByteBuffer);
descriptor: (Lorg/apache/cassandra/service/CacheService$CounterCacheSerializer;Lorg/apache/cassandra/db/ColumnFamilyStore;Ljava/nio/ByteBuffer;Ljava/nio/ByteBuffer;)V
flags: (0x0000)
Code:
stack=2, locals=5, args_size=5
start local 0 0: aload 0
aload 1
putfield org.apache.cassandra.service.CacheService$CounterCacheSerializer$1.this$1:Lorg/apache/cassandra/service/CacheService$CounterCacheSerializer;
aload 0
aload 2
putfield org.apache.cassandra.service.CacheService$CounterCacheSerializer$1.val$cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
aload 0
aload 3
putfield org.apache.cassandra.service.CacheService$CounterCacheSerializer$1.val$partitionKey:Ljava/nio/ByteBuffer;
aload 0
aload 4
putfield org.apache.cassandra.service.CacheService$CounterCacheSerializer$1.val$cellName:Ljava/nio/ByteBuffer;
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/service/CacheService$CounterCacheSerializer$1;
MethodParameters:
Name Flags
this$0 final
val$cfs final
val$partitionKey final
val$cellName final
public org.apache.cassandra.utils.Pair<org.apache.cassandra.cache.CounterCacheKey, org.apache.cassandra.db.ClockAndCount> call();
descriptor: ()Lorg/apache/cassandra/utils/Pair;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=15, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.service.CacheService$CounterCacheSerializer$1.val$cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
aload 0
getfield org.apache.cassandra.service.CacheService$CounterCacheSerializer$1.val$partitionKey:Ljava/nio/ByteBuffer;
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.decorateKey:(Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/db/DecoratedKey;
astore 1
start local 1 1: aload 0
getfield org.apache.cassandra.service.CacheService$CounterCacheSerializer$1.val$cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
aload 0
getfield org.apache.cassandra.service.CacheService$CounterCacheSerializer$1.val$cellName:Ljava/nio/ByteBuffer;
invokestatic org.apache.cassandra.db.LegacyLayout.decodeCellName:(Lorg/apache/cassandra/config/CFMetaData;Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/db/LegacyLayout$LegacyCellName;
astore 2
start local 2 2: aload 2
getfield org.apache.cassandra.db.LegacyLayout$LegacyCellName.column:Lorg/apache/cassandra/config/ColumnDefinition;
astore 3
start local 3 3: aload 2
getfield org.apache.cassandra.db.LegacyLayout$LegacyCellName.collectionElement:Ljava/nio/ByteBuffer;
ifnonnull 4
aconst_null
goto 5
StackMap locals: org.apache.cassandra.db.DecoratedKey org.apache.cassandra.db.LegacyLayout$LegacyCellName org.apache.cassandra.config.ColumnDefinition
StackMap stack:
4: aload 2
getfield org.apache.cassandra.db.LegacyLayout$LegacyCellName.collectionElement:Ljava/nio/ByteBuffer;
invokestatic org.apache.cassandra.db.rows.CellPath.create:(Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/db/rows/CellPath;
StackMap locals:
StackMap stack: org.apache.cassandra.db.rows.CellPath
5: astore 4
start local 4 6: invokestatic org.apache.cassandra.utils.FBUtilities.nowInSeconds:()I
istore 5
start local 5 7: invokestatic org.apache.cassandra.db.filter.ColumnFilter.selectionBuilder:()Lorg/apache/cassandra/db/filter/ColumnFilter$Builder;
astore 6
start local 6 8: aload 4
ifnonnull 10
9: aload 6
aload 3
invokevirtual org.apache.cassandra.db.filter.ColumnFilter$Builder.add:(Lorg/apache/cassandra/config/ColumnDefinition;)Lorg/apache/cassandra/db/filter/ColumnFilter$Builder;
pop
goto 11
10: StackMap locals: org.apache.cassandra.db.rows.CellPath int org.apache.cassandra.db.filter.ColumnFilter$Builder
StackMap stack:
aload 6
aload 3
aload 4
invokevirtual org.apache.cassandra.db.filter.ColumnFilter$Builder.select:(Lorg/apache/cassandra/config/ColumnDefinition;Lorg/apache/cassandra/db/rows/CellPath;)Lorg/apache/cassandra/db/filter/ColumnFilter$Builder;
pop
11: StackMap locals:
StackMap stack:
new org.apache.cassandra.db.filter.ClusteringIndexNamesFilter
dup
aload 2
getfield org.apache.cassandra.db.LegacyLayout$LegacyCellName.clustering:Lorg/apache/cassandra/db/Clustering;
aload 0
getfield org.apache.cassandra.service.CacheService$CounterCacheSerializer$1.val$cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
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;
iconst_0
invokespecial org.apache.cassandra.db.filter.ClusteringIndexNamesFilter.<init>:(Ljava/util/NavigableSet;Z)V
astore 7
start local 7 12: aload 0
getfield org.apache.cassandra.service.CacheService$CounterCacheSerializer$1.val$cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
iload 5
aload 1
aload 6
invokevirtual org.apache.cassandra.db.filter.ColumnFilter$Builder.build:()Lorg/apache/cassandra/db/filter/ColumnFilter;
aload 7
invokestatic org.apache.cassandra.db.SinglePartitionReadCommand.create:(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;
astore 8
start local 8 13: aconst_null
astore 9
aconst_null
astore 10
14: aload 8
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.executionController:()Lorg/apache/cassandra/db/ReadExecutionController;
astore 11
start local 11 15: aload 8
aload 0
getfield org.apache.cassandra.service.CacheService$CounterCacheSerializer$1.val$cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
aload 11
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.queryMemtableAndDisk:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
iload 5
invokestatic org.apache.cassandra.db.rows.UnfilteredRowIterators.filter:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;I)Lorg/apache/cassandra/db/rows/RowIterator;
astore 12
start local 12 16: aload 3
invokevirtual org.apache.cassandra.config.ColumnDefinition.isStatic:()Z
ifeq 19
17: aload 12
invokeinterface org.apache.cassandra.db.rows.RowIterator.staticRow:()Lorg/apache/cassandra/db/rows/Row;
aload 3
invokeinterface org.apache.cassandra.db.rows.Row.getCell:(Lorg/apache/cassandra/config/ColumnDefinition;)Lorg/apache/cassandra/db/rows/Cell;
astore 13
start local 13 18: goto 24
end local 13 19: StackMap locals: org.apache.cassandra.service.CacheService$CounterCacheSerializer$1 org.apache.cassandra.db.DecoratedKey org.apache.cassandra.db.LegacyLayout$LegacyCellName org.apache.cassandra.config.ColumnDefinition org.apache.cassandra.db.rows.CellPath int org.apache.cassandra.db.filter.ColumnFilter$Builder org.apache.cassandra.db.filter.ClusteringIndexFilter org.apache.cassandra.db.SinglePartitionReadCommand java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.ReadExecutionController org.apache.cassandra.db.rows.RowIterator
StackMap stack:
aload 12
invokeinterface org.apache.cassandra.db.rows.RowIterator.hasNext:()Z
ifne 23
20: aload 12
ifnull 21
aload 12
invokeinterface org.apache.cassandra.db.rows.RowIterator.close:()V
StackMap locals:
StackMap stack:
21: aload 11
ifnull 22
aload 11
invokevirtual org.apache.cassandra.db.ReadExecutionController.close:()V
22: StackMap locals:
StackMap stack:
aconst_null
areturn
23: StackMap locals:
StackMap stack:
aload 12
invokeinterface org.apache.cassandra.db.rows.RowIterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Row
aload 3
invokeinterface org.apache.cassandra.db.rows.Row.getCell:(Lorg/apache/cassandra/config/ColumnDefinition;)Lorg/apache/cassandra/db/rows/Cell;
astore 13
start local 13 24: StackMap locals: org.apache.cassandra.db.rows.Cell
StackMap stack:
aload 13
ifnonnull 28
25: aload 12
ifnull 26
aload 12
invokeinterface org.apache.cassandra.db.rows.RowIterator.close:()V
StackMap locals:
StackMap stack:
26: aload 11
ifnull 27
aload 11
invokevirtual org.apache.cassandra.db.ReadExecutionController.close:()V
27: StackMap locals:
StackMap stack:
aconst_null
areturn
28: StackMap locals:
StackMap stack:
invokestatic org.apache.cassandra.db.context.CounterContext.instance:()Lorg/apache/cassandra/db/context/CounterContext;
aload 13
invokevirtual org.apache.cassandra.db.rows.Cell.value:()Ljava/nio/ByteBuffer;
invokevirtual org.apache.cassandra.db.context.CounterContext.getLocalClockAndCount:(Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/db/ClockAndCount;
astore 14
start local 14 29: aload 0
getfield org.apache.cassandra.service.CacheService$CounterCacheSerializer$1.val$cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.ksAndCFName:Lorg/apache/cassandra/utils/Pair;
aload 0
getfield org.apache.cassandra.service.CacheService$CounterCacheSerializer$1.val$partitionKey:Ljava/nio/ByteBuffer;
aload 2
getfield org.apache.cassandra.db.LegacyLayout$LegacyCellName.clustering:Lorg/apache/cassandra/db/Clustering;
aload 3
aload 4
invokestatic org.apache.cassandra.cache.CounterCacheKey.create:(Lorg/apache/cassandra/utils/Pair;Ljava/nio/ByteBuffer;Lorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/config/ColumnDefinition;Lorg/apache/cassandra/db/rows/CellPath;)Lorg/apache/cassandra/cache/CounterCacheKey;
aload 14
invokestatic org.apache.cassandra.utils.Pair.create:(Ljava/lang/Object;Ljava/lang/Object;)Lorg/apache/cassandra/utils/Pair;
30: aload 12
ifnull 31
aload 12
invokeinterface org.apache.cassandra.db.rows.RowIterator.close:()V
StackMap locals: org.apache.cassandra.service.CacheService$CounterCacheSerializer$1 org.apache.cassandra.db.DecoratedKey org.apache.cassandra.db.LegacyLayout$LegacyCellName org.apache.cassandra.config.ColumnDefinition org.apache.cassandra.db.rows.CellPath int org.apache.cassandra.db.filter.ColumnFilter$Builder org.apache.cassandra.db.filter.ClusteringIndexFilter org.apache.cassandra.db.SinglePartitionReadCommand java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.ReadExecutionController org.apache.cassandra.db.rows.RowIterator org.apache.cassandra.db.rows.Cell org.apache.cassandra.db.ClockAndCount
StackMap stack: org.apache.cassandra.utils.Pair
31: aload 11
ifnull 32
aload 11
invokevirtual org.apache.cassandra.db.ReadExecutionController.close:()V
32: StackMap locals:
StackMap stack: org.apache.cassandra.utils.Pair
areturn
end local 14 end local 13 StackMap locals: org.apache.cassandra.service.CacheService$CounterCacheSerializer$1 org.apache.cassandra.db.DecoratedKey org.apache.cassandra.db.LegacyLayout$LegacyCellName org.apache.cassandra.config.ColumnDefinition org.apache.cassandra.db.rows.CellPath int org.apache.cassandra.db.filter.ColumnFilter$Builder org.apache.cassandra.db.filter.ClusteringIndexFilter org.apache.cassandra.db.SinglePartitionReadCommand java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.ReadExecutionController org.apache.cassandra.db.rows.RowIterator
StackMap stack: java.lang.Throwable
33: astore 9
34: aload 12
ifnull 35
aload 12
invokeinterface org.apache.cassandra.db.rows.RowIterator.close:()V
end local 12 StackMap locals:
StackMap stack:
35: aload 9
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
36: astore 10
aload 9
ifnonnull 37
aload 10
astore 9
goto 38
StackMap locals:
StackMap stack:
37: aload 9
aload 10
if_acmpeq 38
aload 9
aload 10
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
38: aload 11
ifnull 39
aload 11
invokevirtual org.apache.cassandra.db.ReadExecutionController.close:()V
end local 11 StackMap locals:
StackMap stack:
39: aload 9
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
40: astore 10
aload 9
ifnonnull 41
aload 10
astore 9
goto 42
StackMap locals:
StackMap stack:
41: aload 9
aload 10
if_acmpeq 42
aload 9
aload 10
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
42: aload 9
athrow
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 43 0 this Lorg/apache/cassandra/service/CacheService$CounterCacheSerializer$1;
1 43 1 key Lorg/apache/cassandra/db/DecoratedKey;
2 43 2 name Lorg/apache/cassandra/db/LegacyLayout$LegacyCellName;
3 43 3 column Lorg/apache/cassandra/config/ColumnDefinition;
6 43 4 path Lorg/apache/cassandra/db/rows/CellPath;
7 43 5 nowInSec I
8 43 6 builder Lorg/apache/cassandra/db/filter/ColumnFilter$Builder;
12 43 7 filter Lorg/apache/cassandra/db/filter/ClusteringIndexFilter;
13 43 8 cmd Lorg/apache/cassandra/db/SinglePartitionReadCommand;
15 39 11 controller Lorg/apache/cassandra/db/ReadExecutionController;
16 35 12 iter Lorg/apache/cassandra/db/rows/RowIterator;
18 19 13 cell Lorg/apache/cassandra/db/rows/Cell;
24 33 13 cell Lorg/apache/cassandra/db/rows/Cell;
29 33 14 clockAndCount Lorg/apache/cassandra/db/ClockAndCount;
Exception table:
from to target type
16 20 33 any
23 25 33 any
28 30 33 any
15 21 36 any
23 26 36 any
28 31 36 any
33 36 36 any
14 22 40 any
23 27 40 any
28 32 40 any
33 40 40 any
Exceptions:
throws java.lang.Exception
Signature: ()Lorg/apache/cassandra/utils/Pair<Lorg/apache/cassandra/cache/CounterCacheKey;Lorg/apache/cassandra/db/ClockAndCount;>;
public java.lang.Object call();
descriptor: ()Ljava/lang/Object;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual org.apache.cassandra.service.CacheService$CounterCacheSerializer$1.call:()Lorg/apache/cassandra/utils/Pair;
areturn
LocalVariableTable:
Start End Slot Name Signature
Exceptions:
throws java.lang.Exception
}
Signature: Ljava/lang/Object;Ljava/util/concurrent/Callable<Lorg/apache/cassandra/utils/Pair<Lorg/apache/cassandra/cache/CounterCacheKey;Lorg/apache/cassandra/db/ClockAndCount;>;>;
SourceFile: "CacheService.java"
EnclosingMethod: org.apache.cassandra.service.CacheService$CounterCacheSerializer.deserialize:(Lorg/apache/cassandra/io/util/DataInputPlus;Lorg/apache/cassandra/db/ColumnFamilyStore;)Ljava/util/concurrent/Future;
NestHost: org.apache.cassandra.service.CacheService
InnerClasses:
public LegacyCellName = org.apache.cassandra.db.LegacyLayout$LegacyCellName of org.apache.cassandra.db.LegacyLayout
public Builder = org.apache.cassandra.db.filter.ColumnFilter$Builder of org.apache.cassandra.db.filter.ColumnFilter
public CounterCacheSerializer = org.apache.cassandra.service.CacheService$CounterCacheSerializer of org.apache.cassandra.service.CacheService
org.apache.cassandra.service.CacheService$CounterCacheSerializer$1