class org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger extends org.apache.cassandra.db.rows.WrappingUnfilteredRowIterator
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger
super_class: org.apache.cassandra.db.rows.WrappingUnfilteredRowIterator
{
private final int nowInSec;
descriptor: I
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private boolean isInit;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private java.util.Iterator<org.apache.cassandra.db.rows.Cell> staticCells;
descriptor: Ljava/util/Iterator;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/Iterator<Lorg/apache/cassandra/db/rows/Cell;>;
private final org.apache.cassandra.db.rows.Row$Builder builder;
descriptor: Lorg/apache/cassandra/db/rows/Row$Builder;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private org.apache.cassandra.db.rows.Row nextToMerge;
descriptor: Lorg/apache/cassandra/db/rows/Row;
flags: (0x0002) ACC_PRIVATE
private org.apache.cassandra.db.rows.Unfiltered nextFromWrapped;
descriptor: Lorg/apache/cassandra/db/rows/Unfiltered;
flags: (0x0002) ACC_PRIVATE
static final boolean $assertionsDisabled;
descriptor: Z
flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/thrift/ThriftResultsMerger;
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.thrift.ThriftResultsMerger$PartitionMerger.$assertionsDisabled:Z
return
LocalVariableTable:
Start End Slot Name Signature
private void <init>(org.apache.cassandra.db.rows.UnfilteredRowIterator, int);
descriptor: (Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;I)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokespecial org.apache.cassandra.db.rows.WrappingUnfilteredRowIterator.<init>:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;)V
1: getstatic org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.$assertionsDisabled:Z
ifne 2
aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.metadata:()Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.isStaticCompactTable:()Z
ifne 2
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
2: StackMap locals: org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger org.apache.cassandra.db.rows.UnfilteredRowIterator int
StackMap stack:
aload 0
iload 2
putfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.nowInSec:I
3: aload 0
invokestatic org.apache.cassandra.db.rows.BTreeRow.sortedBuilder:()Lorg/apache/cassandra/db/rows/Row$Builder;
putfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.builder:Lorg/apache/cassandra/db/rows/Row$Builder;
4: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/thrift/ThriftResultsMerger$PartitionMerger;
0 5 1 results Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
0 5 2 nowInSec I
MethodParameters:
Name Flags
results
nowInSec
private void init();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=1
start local 0 0: getstatic org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.$assertionsDisabled:Z
ifne 1
aload 0
getfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.isInit:Z
ifeq 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
invokespecial org.apache.cassandra.db.rows.WrappingUnfilteredRowIterator.staticRow:()Lorg/apache/cassandra/db/rows/Row;
astore 1
start local 1 2: getstatic org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.$assertionsDisabled:Z
ifne 3
aload 1
invokeinterface org.apache.cassandra.db.rows.Row.hasComplex:()Z
ifeq 3
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
3: StackMap locals: org.apache.cassandra.db.rows.Row
StackMap stack:
aload 0
aload 1
invokeinterface org.apache.cassandra.db.rows.Row.cells:()Ljava/lang/Iterable;
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
putfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.staticCells:Ljava/util/Iterator;
4: aload 0
invokevirtual org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.updateNextToMerge:()V
5: aload 0
iconst_1
putfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.isInit:Z
6: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/thrift/ThriftResultsMerger$PartitionMerger;
2 7 1 staticRow Lorg/apache/cassandra/db/rows/Row;
public org.apache.cassandra.db.rows.Row staticRow();
descriptor: ()Lorg/apache/cassandra/db/rows/Row;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: getstatic org.apache.cassandra.db.rows.Rows.EMPTY_STATIC_ROW:Lorg/apache/cassandra/db/rows/Row;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/thrift/ThriftResultsMerger$PartitionMerger;
public boolean hasNext();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.isInit:Z
ifne 2
1: aload 0
invokevirtual org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.init:()V
2: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.nextFromWrapped:Lorg/apache/cassandra/db/rows/Unfiltered;
ifnonnull 3
aload 0
getfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.nextToMerge:Lorg/apache/cassandra/db/rows/Row;
ifnonnull 3
aload 0
invokespecial org.apache.cassandra.db.rows.WrappingUnfilteredRowIterator.hasNext:()Z
ifne 3
iconst_0
ireturn
StackMap locals:
StackMap stack:
3: iconst_1
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/thrift/ThriftResultsMerger$PartitionMerger;
public org.apache.cassandra.db.rows.Unfiltered next();
descriptor: ()Lorg/apache/cassandra/db/rows/Unfiltered;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.isInit:Z
ifne 2
1: aload 0
invokevirtual org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.init:()V
2: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.nextFromWrapped:Lorg/apache/cassandra/db/rows/Unfiltered;
ifnonnull 4
aload 0
invokespecial org.apache.cassandra.db.rows.WrappingUnfilteredRowIterator.hasNext:()Z
ifeq 4
3: aload 0
aload 0
invokespecial org.apache.cassandra.db.rows.WrappingUnfilteredRowIterator.next:()Lorg/apache/cassandra/db/rows/Unfiltered;
putfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.nextFromWrapped:Lorg/apache/cassandra/db/rows/Unfiltered;
4: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.nextFromWrapped:Lorg/apache/cassandra/db/rows/Unfiltered;
ifnonnull 8
5: aload 0
getfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.nextToMerge:Lorg/apache/cassandra/db/rows/Row;
ifnonnull 7
6: new java.util.NoSuchElementException
dup
invokespecial java.util.NoSuchElementException.<init>:()V
athrow
7: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.consumeNextToMerge:()Lorg/apache/cassandra/db/rows/Row;
areturn
8: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.nextToMerge:Lorg/apache/cassandra/db/rows/Row;
ifnonnull 10
9: aload 0
invokevirtual org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.consumeNextWrapped:()Lorg/apache/cassandra/db/rows/Unfiltered;
areturn
10: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.comparator:Lorg/apache/cassandra/db/ClusteringComparator;
aload 0
getfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.nextToMerge:Lorg/apache/cassandra/db/rows/Row;
aload 0
getfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.nextFromWrapped:Lorg/apache/cassandra/db/rows/Unfiltered;
invokevirtual org.apache.cassandra.db.ClusteringComparator.compare:(Lorg/apache/cassandra/db/Clusterable;Lorg/apache/cassandra/db/Clusterable;)I
istore 1
start local 1 11: iload 1
ifge 13
12: aload 0
invokevirtual org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.consumeNextToMerge:()Lorg/apache/cassandra/db/rows/Row;
areturn
13: StackMap locals: int
StackMap stack:
iload 1
ifle 15
14: aload 0
invokevirtual org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.consumeNextWrapped:()Lorg/apache/cassandra/db/rows/Unfiltered;
areturn
15: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.$assertionsDisabled:Z
ifne 16
aload 0
getfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.nextFromWrapped:Lorg/apache/cassandra/db/rows/Unfiltered;
instanceof org.apache.cassandra.db.rows.Row
ifne 16
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
16: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.consumeNextWrapped:()Lorg/apache/cassandra/db/rows/Unfiltered;
checkcast org.apache.cassandra.db.rows.Row
aload 0
invokevirtual org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.consumeNextToMerge:()Lorg/apache/cassandra/db/rows/Row;
aload 0
getfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.nowInSec:I
invokestatic org.apache.cassandra.db.rows.Rows.merge:(Lorg/apache/cassandra/db/rows/Row;Lorg/apache/cassandra/db/rows/Row;I)Lorg/apache/cassandra/db/rows/Row;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lorg/apache/cassandra/thrift/ThriftResultsMerger$PartitionMerger;
11 17 1 cmp I
private org.apache.cassandra.db.rows.Unfiltered consumeNextWrapped();
descriptor: ()Lorg/apache/cassandra/db/rows/Unfiltered;
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.nextFromWrapped:Lorg/apache/cassandra/db/rows/Unfiltered;
astore 1
start local 1 1: aload 0
aconst_null
putfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.nextFromWrapped:Lorg/apache/cassandra/db/rows/Unfiltered;
2: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/thrift/ThriftResultsMerger$PartitionMerger;
1 3 1 toReturn Lorg/apache/cassandra/db/rows/Unfiltered;
private org.apache.cassandra.db.rows.Row consumeNextToMerge();
descriptor: ()Lorg/apache/cassandra/db/rows/Row;
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.nextToMerge:Lorg/apache/cassandra/db/rows/Row;
astore 1
start local 1 1: aload 0
invokevirtual org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.updateNextToMerge:()V
2: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/thrift/ThriftResultsMerger$PartitionMerger;
1 3 1 toReturn Lorg/apache/cassandra/db/rows/Row;
private void updateNextToMerge();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=10, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.staticCells:Ljava/util/Iterator;
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
1: aload 0
aconst_null
putfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.nextToMerge:Lorg/apache/cassandra/db/rows/Row;
2: return
3: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.staticCells:Ljava/util/Iterator;
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Cell
astore 1
start local 1 4: aload 0
getfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.builder:Lorg/apache/cassandra/db/rows/Row$Builder;
iconst_1
anewarray java.nio.ByteBuffer
dup
iconst_0
aload 1
invokevirtual org.apache.cassandra.db.rows.Cell.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;
aastore
invokestatic org.apache.cassandra.db.Clustering.make:([Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/db/Clustering;
invokeinterface org.apache.cassandra.db.rows.Row$Builder.newRow:(Lorg/apache/cassandra/db/Clustering;)V
5: aload 0
getfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.builder:Lorg/apache/cassandra/db/rows/Row$Builder;
new org.apache.cassandra.db.rows.BufferCell
dup
aload 0
invokevirtual org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.metadata:()Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.compactValueColumn:()Lorg/apache/cassandra/config/ColumnDefinition;
aload 1
invokevirtual org.apache.cassandra.db.rows.Cell.timestamp:()J
aload 1
invokevirtual org.apache.cassandra.db.rows.Cell.ttl:()I
aload 1
invokevirtual org.apache.cassandra.db.rows.Cell.localDeletionTime:()I
aload 1
invokevirtual org.apache.cassandra.db.rows.Cell.value:()Ljava/nio/ByteBuffer;
aload 1
invokevirtual org.apache.cassandra.db.rows.Cell.path:()Lorg/apache/cassandra/db/rows/CellPath;
invokespecial org.apache.cassandra.db.rows.BufferCell.<init>:(Lorg/apache/cassandra/config/ColumnDefinition;JIILjava/nio/ByteBuffer;Lorg/apache/cassandra/db/rows/CellPath;)V
invokeinterface org.apache.cassandra.db.rows.Row$Builder.addCell:(Lorg/apache/cassandra/db/rows/Cell;)V
6: aload 0
aload 0
getfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.builder:Lorg/apache/cassandra/db/rows/Row$Builder;
invokeinterface org.apache.cassandra.db.rows.Row$Builder.build:()Lorg/apache/cassandra/db/rows/Row;
putfield org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger.nextToMerge:Lorg/apache/cassandra/db/rows/Row;
7: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/apache/cassandra/thrift/ThriftResultsMerger$PartitionMerger;
4 8 1 cell Lorg/apache/cassandra/db/rows/Cell;
}
SourceFile: "ThriftResultsMerger.java"
NestHost: org.apache.cassandra.thrift.ThriftResultsMerger
InnerClasses:
public abstract Builder = org.apache.cassandra.db.rows.Row$Builder of org.apache.cassandra.db.rows.Row
private PartitionMerger = org.apache.cassandra.thrift.ThriftResultsMerger$PartitionMerger of org.apache.cassandra.thrift.ThriftResultsMerger