class org.apache.cassandra.service.DataResolver$RepairMergeListener$MergeListener$1 implements org.apache.cassandra.db.rows.RowDiffListener
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: org.apache.cassandra.service.DataResolver$RepairMergeListener$MergeListener$1
super_class: java.lang.Object
{
final org.apache.cassandra.service.DataResolver$RepairMergeListener$MergeListener this$2;
descriptor: Lorg/apache/cassandra/service/DataResolver$RepairMergeListener$MergeListener;
flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC
void <init>(org.apache.cassandra.service.DataResolver$RepairMergeListener$MergeListener);
descriptor: (Lorg/apache/cassandra/service/DataResolver$RepairMergeListener$MergeListener;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 0: aload 0
aload 1
putfield org.apache.cassandra.service.DataResolver$RepairMergeListener$MergeListener$1.this$2:Lorg/apache/cassandra/service/DataResolver$RepairMergeListener$MergeListener;
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/DataResolver$RepairMergeListener$MergeListener$1;
MethodParameters:
Name Flags
this$0 final
public void onPrimaryKeyLivenessInfo(int, org.apache.cassandra.db.Clustering, org.apache.cassandra.db.LivenessInfo, org.apache.cassandra.db.LivenessInfo);
descriptor: (ILorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/db/LivenessInfo;Lorg/apache/cassandra/db/LivenessInfo;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 3
ifnull 2
aload 3
aload 4
invokevirtual org.apache.cassandra.db.LivenessInfo.equals:(Ljava/lang/Object;)Z
ifne 2
1: aload 0
getfield org.apache.cassandra.service.DataResolver$RepairMergeListener$MergeListener$1.this$2:Lorg/apache/cassandra/service/DataResolver$RepairMergeListener$MergeListener;
iload 1
aload 2
invokevirtual org.apache.cassandra.service.DataResolver$RepairMergeListener$MergeListener.currentRow:(ILorg/apache/cassandra/db/Clustering;)Lorg/apache/cassandra/db/rows/Row$Builder;
aload 3
invokeinterface org.apache.cassandra.db.rows.Row$Builder.addPrimaryKeyLivenessInfo:(Lorg/apache/cassandra/db/LivenessInfo;)V
2: StackMap locals:
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/service/DataResolver$RepairMergeListener$MergeListener$1;
0 3 1 i I
0 3 2 clustering Lorg/apache/cassandra/db/Clustering;
0 3 3 merged Lorg/apache/cassandra/db/LivenessInfo;
0 3 4 original Lorg/apache/cassandra/db/LivenessInfo;
MethodParameters:
Name Flags
i
clustering
merged
original
public void onDeletion(int, org.apache.cassandra.db.Clustering, org.apache.cassandra.db.rows.Row$Deletion, org.apache.cassandra.db.rows.Row$Deletion);
descriptor: (ILorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/db/rows/Row$Deletion;Lorg/apache/cassandra/db/rows/Row$Deletion;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 3
ifnull 2
aload 3
aload 4
invokevirtual org.apache.cassandra.db.rows.Row$Deletion.equals:(Ljava/lang/Object;)Z
ifne 2
1: aload 0
getfield org.apache.cassandra.service.DataResolver$RepairMergeListener$MergeListener$1.this$2:Lorg/apache/cassandra/service/DataResolver$RepairMergeListener$MergeListener;
iload 1
aload 2
invokevirtual org.apache.cassandra.service.DataResolver$RepairMergeListener$MergeListener.currentRow:(ILorg/apache/cassandra/db/Clustering;)Lorg/apache/cassandra/db/rows/Row$Builder;
aload 3
invokeinterface org.apache.cassandra.db.rows.Row$Builder.addRowDeletion:(Lorg/apache/cassandra/db/rows/Row$Deletion;)V
2: StackMap locals:
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/service/DataResolver$RepairMergeListener$MergeListener$1;
0 3 1 i I
0 3 2 clustering Lorg/apache/cassandra/db/Clustering;
0 3 3 merged Lorg/apache/cassandra/db/rows/Row$Deletion;
0 3 4 original Lorg/apache/cassandra/db/rows/Row$Deletion;
MethodParameters:
Name Flags
i
clustering
merged
original
public void onComplexDeletion(int, org.apache.cassandra.db.Clustering, org.apache.cassandra.config.ColumnDefinition, org.apache.cassandra.db.DeletionTime, org.apache.cassandra.db.DeletionTime);
descriptor: (ILorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/config/ColumnDefinition;Lorg/apache/cassandra/db/DeletionTime;Lorg/apache/cassandra/db/DeletionTime;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 4
ifnull 2
aload 4
aload 5
invokevirtual org.apache.cassandra.db.DeletionTime.equals:(Ljava/lang/Object;)Z
ifne 2
1: aload 0
getfield org.apache.cassandra.service.DataResolver$RepairMergeListener$MergeListener$1.this$2:Lorg/apache/cassandra/service/DataResolver$RepairMergeListener$MergeListener;
iload 1
aload 2
invokevirtual org.apache.cassandra.service.DataResolver$RepairMergeListener$MergeListener.currentRow:(ILorg/apache/cassandra/db/Clustering;)Lorg/apache/cassandra/db/rows/Row$Builder;
aload 3
aload 4
invokeinterface org.apache.cassandra.db.rows.Row$Builder.addComplexDeletion:(Lorg/apache/cassandra/config/ColumnDefinition;Lorg/apache/cassandra/db/DeletionTime;)V
2: StackMap locals:
StackMap stack:
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 3 0 this Lorg/apache/cassandra/service/DataResolver$RepairMergeListener$MergeListener$1;
0 3 1 i I
0 3 2 clustering Lorg/apache/cassandra/db/Clustering;
0 3 3 column Lorg/apache/cassandra/config/ColumnDefinition;
0 3 4 merged Lorg/apache/cassandra/db/DeletionTime;
0 3 5 original Lorg/apache/cassandra/db/DeletionTime;
MethodParameters:
Name Flags
i
clustering
column
merged
original
public void onCell(int, org.apache.cassandra.db.Clustering, org.apache.cassandra.db.rows.Cell, org.apache.cassandra.db.rows.Cell);
descriptor: (ILorg/apache/cassandra/db/Clustering;Lorg/apache/cassandra/db/rows/Cell;Lorg/apache/cassandra/db/rows/Cell;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 3
ifnull 2
aload 3
aload 4
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifne 2
aload 0
aload 3
invokevirtual org.apache.cassandra.service.DataResolver$RepairMergeListener$MergeListener$1.isQueried:(Lorg/apache/cassandra/db/rows/Cell;)Z
ifeq 2
1: aload 0
getfield org.apache.cassandra.service.DataResolver$RepairMergeListener$MergeListener$1.this$2:Lorg/apache/cassandra/service/DataResolver$RepairMergeListener$MergeListener;
iload 1
aload 2
invokevirtual org.apache.cassandra.service.DataResolver$RepairMergeListener$MergeListener.currentRow:(ILorg/apache/cassandra/db/Clustering;)Lorg/apache/cassandra/db/rows/Row$Builder;
aload 3
invokeinterface org.apache.cassandra.db.rows.Row$Builder.addCell:(Lorg/apache/cassandra/db/rows/Cell;)V
2: StackMap locals:
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/service/DataResolver$RepairMergeListener$MergeListener$1;
0 3 1 i I
0 3 2 clustering Lorg/apache/cassandra/db/Clustering;
0 3 3 merged Lorg/apache/cassandra/db/rows/Cell;
0 3 4 original Lorg/apache/cassandra/db/rows/Cell;
MethodParameters:
Name Flags
i
clustering
merged
original
private boolean isQueried(org.apache.cassandra.db.rows.Cell);
descriptor: (Lorg/apache/cassandra/db/rows/Cell;)Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual org.apache.cassandra.db.rows.Cell.column:()Lorg/apache/cassandra/config/ColumnDefinition;
astore 2
start local 2 1: aload 0
getfield org.apache.cassandra.service.DataResolver$RepairMergeListener$MergeListener$1.this$2:Lorg/apache/cassandra/service/DataResolver$RepairMergeListener$MergeListener;
invokestatic org.apache.cassandra.service.DataResolver$RepairMergeListener$MergeListener.access$0:(Lorg/apache/cassandra/service/DataResolver$RepairMergeListener$MergeListener;)Lorg/apache/cassandra/service/DataResolver$RepairMergeListener;
invokestatic org.apache.cassandra.service.DataResolver$RepairMergeListener.access$0:(Lorg/apache/cassandra/service/DataResolver$RepairMergeListener;)Lorg/apache/cassandra/service/DataResolver;
getfield org.apache.cassandra.service.DataResolver.command:Lorg/apache/cassandra/db/ReadCommand;
invokevirtual org.apache.cassandra.db.ReadCommand.columnFilter:()Lorg/apache/cassandra/db/filter/ColumnFilter;
astore 3
start local 3 2: aload 2
invokevirtual org.apache.cassandra.config.ColumnDefinition.isComplex:()Z
ifeq 3
aload 3
aload 2
aload 1
invokevirtual org.apache.cassandra.db.rows.Cell.path:()Lorg/apache/cassandra/db/rows/CellPath;
invokevirtual org.apache.cassandra.db.filter.ColumnFilter.fetchedCellIsQueried:(Lorg/apache/cassandra/config/ColumnDefinition;Lorg/apache/cassandra/db/rows/CellPath;)Z
goto 4
StackMap locals: org.apache.cassandra.config.ColumnDefinition org.apache.cassandra.db.filter.ColumnFilter
StackMap stack:
3: aload 3
aload 2
invokevirtual org.apache.cassandra.db.filter.ColumnFilter.fetchedColumnIsQueried:(Lorg/apache/cassandra/config/ColumnDefinition;)Z
StackMap locals:
StackMap stack: int
4: ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/service/DataResolver$RepairMergeListener$MergeListener$1;
0 5 1 cell Lorg/apache/cassandra/db/rows/Cell;
1 5 2 column Lorg/apache/cassandra/config/ColumnDefinition;
2 5 3 filter Lorg/apache/cassandra/db/filter/ColumnFilter;
MethodParameters:
Name Flags
cell
}
SourceFile: "DataResolver.java"
EnclosingMethod: org.apache.cassandra.service.DataResolver$RepairMergeListener$MergeListener.<init>:(Lorg/apache/cassandra/service/DataResolver$RepairMergeListener;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/PartitionColumns;Z)V
NestHost: org.apache.cassandra.service.DataResolver
InnerClasses:
public abstract Builder = org.apache.cassandra.db.rows.Row$Builder of org.apache.cassandra.db.rows.Row
public Deletion = org.apache.cassandra.db.rows.Row$Deletion of org.apache.cassandra.db.rows.Row
private RepairMergeListener = org.apache.cassandra.service.DataResolver$RepairMergeListener of org.apache.cassandra.service.DataResolver
private MergeListener = org.apache.cassandra.service.DataResolver$RepairMergeListener$MergeListener of org.apache.cassandra.service.DataResolver$RepairMergeListener
org.apache.cassandra.service.DataResolver$RepairMergeListener$MergeListener$1