public class org.apache.cassandra.db.compaction.Verifier implements java.io.Closeable
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.db.compaction.Verifier
super_class: java.lang.Object
{
private final org.apache.cassandra.db.ColumnFamilyStore cfs;
descriptor: Lorg/apache/cassandra/db/ColumnFamilyStore;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.cassandra.io.sstable.format.SSTableReader sstable;
descriptor: Lorg/apache/cassandra/io/sstable/format/SSTableReader;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.cassandra.db.compaction.CompactionController controller;
descriptor: Lorg/apache/cassandra/db/compaction/CompactionController;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.cassandra.io.util.RandomAccessReader dataFile;
descriptor: Lorg/apache/cassandra/io/util/RandomAccessReader;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.cassandra.io.util.RandomAccessReader indexFile;
descriptor: Lorg/apache/cassandra/io/util/RandomAccessReader;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.cassandra.db.compaction.Verifier$VerifyInfo verifyInfo;
descriptor: Lorg/apache/cassandra/db/compaction/Verifier$VerifyInfo;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.cassandra.db.RowIndexEntry$IndexSerializer rowIndexEntrySerializer;
descriptor: Lorg/apache/cassandra/db/RowIndexEntry$IndexSerializer;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private int goodRows;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private final org.apache.cassandra.utils.OutputHandler outputHandler;
descriptor: Lorg/apache/cassandra/utils/OutputHandler;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private org.apache.cassandra.io.util.DataIntegrityMetadata$FileDigestValidator validator;
descriptor: Lorg/apache/cassandra/io/util/DataIntegrityMetadata$FileDigestValidator;
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/db/compaction/Verifier;
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.compaction.Verifier.$assertionsDisabled:Z
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(org.apache.cassandra.db.ColumnFamilyStore, org.apache.cassandra.io.sstable.format.SSTableReader, boolean);
descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/io/sstable/format/SSTableReader;Z)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
new org.apache.cassandra.utils.OutputHandler$LogOutput
dup
invokespecial org.apache.cassandra.utils.OutputHandler$LogOutput.<init>:()V
iload 3
invokespecial org.apache.cassandra.db.compaction.Verifier.<init>:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/io/sstable/format/SSTableReader;Lorg/apache/cassandra/utils/OutputHandler;Z)V
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/compaction/Verifier;
0 2 1 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
0 2 2 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
0 2 3 isOffline Z
MethodParameters:
Name Flags
cfs
sstable
isOffline
public void <init>(org.apache.cassandra.db.ColumnFamilyStore, org.apache.cassandra.io.sstable.format.SSTableReader, org.apache.cassandra.utils.OutputHandler, boolean);
descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/io/sstable/format/SSTableReader;Lorg/apache/cassandra/utils/OutputHandler;Z)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield org.apache.cassandra.db.compaction.Verifier.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
2: aload 0
aload 2
putfield org.apache.cassandra.db.compaction.Verifier.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
3: aload 0
aload 3
putfield org.apache.cassandra.db.compaction.Verifier.outputHandler:Lorg/apache/cassandra/utils/OutputHandler;
4: aload 0
aload 2
getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
getfield org.apache.cassandra.io.sstable.Descriptor.version:Lorg/apache/cassandra/io/sstable/format/Version;
invokevirtual org.apache.cassandra.io.sstable.format.Version.getSSTableFormat:()Lorg/apache/cassandra/io/sstable/format/SSTableFormat;
aload 2
getfield org.apache.cassandra.io.sstable.format.SSTableReader.metadata:Lorg/apache/cassandra/config/CFMetaData;
aload 2
getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
getfield org.apache.cassandra.io.sstable.Descriptor.version:Lorg/apache/cassandra/io/sstable/format/Version;
aload 2
getfield org.apache.cassandra.io.sstable.format.SSTableReader.header:Lorg/apache/cassandra/db/SerializationHeader;
invokeinterface org.apache.cassandra.io.sstable.format.SSTableFormat.getIndexSerializer:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/io/sstable/format/Version;Lorg/apache/cassandra/db/SerializationHeader;)Lorg/apache/cassandra/db/RowIndexEntry$IndexSerializer;
putfield org.apache.cassandra.db.compaction.Verifier.rowIndexEntrySerializer:Lorg/apache/cassandra/db/RowIndexEntry$IndexSerializer;
5: aload 0
new org.apache.cassandra.db.compaction.Verifier$VerifyController
dup
aload 1
invokespecial org.apache.cassandra.db.compaction.Verifier$VerifyController.<init>:(Lorg/apache/cassandra/db/ColumnFamilyStore;)V
putfield org.apache.cassandra.db.compaction.Verifier.controller:Lorg/apache/cassandra/db/compaction/CompactionController;
6: aload 0
iload 4
ifeq 8
7: aload 2
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.openDataReader:()Lorg/apache/cassandra/io/util/RandomAccessReader;
goto 9
8: StackMap locals: org.apache.cassandra.db.compaction.Verifier org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.io.sstable.format.SSTableReader org.apache.cassandra.utils.OutputHandler int
StackMap stack: org.apache.cassandra.db.compaction.Verifier
aload 2
getstatic org.apache.cassandra.db.compaction.CompactionManager.instance:Lorg/apache/cassandra/db/compaction/CompactionManager;
invokevirtual org.apache.cassandra.db.compaction.CompactionManager.getRateLimiter:()Lcom/google/common/util/concurrent/RateLimiter;
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.openDataReader:(Lcom/google/common/util/concurrent/RateLimiter;)Lorg/apache/cassandra/io/util/RandomAccessReader;
9: StackMap locals: org.apache.cassandra.db.compaction.Verifier org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.io.sstable.format.SSTableReader org.apache.cassandra.utils.OutputHandler int
StackMap stack: org.apache.cassandra.db.compaction.Verifier org.apache.cassandra.io.util.RandomAccessReader
putfield org.apache.cassandra.db.compaction.Verifier.dataFile:Lorg/apache/cassandra/io/util/RandomAccessReader;
10: aload 0
new java.io.File
dup
aload 2
getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
getstatic org.apache.cassandra.io.sstable.Component.PRIMARY_INDEX:Lorg/apache/cassandra/io/sstable/Component;
invokevirtual org.apache.cassandra.io.sstable.Descriptor.filenameFor:(Lorg/apache/cassandra/io/sstable/Component;)Ljava/lang/String;
invokespecial java.io.File.<init>:(Ljava/lang/String;)V
invokestatic org.apache.cassandra.io.util.RandomAccessReader.open:(Ljava/io/File;)Lorg/apache/cassandra/io/util/RandomAccessReader;
putfield org.apache.cassandra.db.compaction.Verifier.indexFile:Lorg/apache/cassandra/io/util/RandomAccessReader;
11: aload 0
new org.apache.cassandra.db.compaction.Verifier$VerifyInfo
dup
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.dataFile:Lorg/apache/cassandra/io/util/RandomAccessReader;
aload 2
invokespecial org.apache.cassandra.db.compaction.Verifier$VerifyInfo.<init>:(Lorg/apache/cassandra/io/util/RandomAccessReader;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
putfield org.apache.cassandra.db.compaction.Verifier.verifyInfo:Lorg/apache/cassandra/db/compaction/Verifier$VerifyInfo;
12: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lorg/apache/cassandra/db/compaction/Verifier;
0 13 1 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
0 13 2 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
0 13 3 outputHandler Lorg/apache/cassandra/utils/OutputHandler;
0 13 4 isOffline Z
MethodParameters:
Name Flags
cfs
sstable
outputHandler
isOffline
public void verify(boolean);
descriptor: (Z)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=21, args_size=2
start local 0 start local 1 0: lconst_0
lstore 2
start local 2 1: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.outputHandler:Lorg/apache/cassandra/utils/OutputHandler;
ldc "Verifying %s (%s)"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
aastore
dup
iconst_1
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.dataFile:Lorg/apache/cassandra/io/util/RandomAccessReader;
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.length:()J
invokestatic org.apache.cassandra.utils.FBUtilities.prettyPrintMemory:(J)Ljava/lang/String;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokeinterface org.apache.cassandra.utils.OutputHandler.output:(Ljava/lang/String;)V
2: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.outputHandler:Lorg/apache/cassandra/utils/OutputHandler;
ldc "Deserializing sstable metadata for %s "
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokeinterface org.apache.cassandra.utils.OutputHandler.output:(Ljava/lang/String;)V
3: getstatic org.apache.cassandra.io.sstable.metadata.MetadataType.VALIDATION:Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
getstatic org.apache.cassandra.io.sstable.metadata.MetadataType.STATS:Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
getstatic org.apache.cassandra.io.sstable.metadata.MetadataType.HEADER:Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
invokestatic java.util.EnumSet.of:(Ljava/lang/Enum;Ljava/lang/Enum;Ljava/lang/Enum;)Ljava/util/EnumSet;
astore 4
start local 4 4: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
invokevirtual org.apache.cassandra.io.sstable.Descriptor.getMetadataSerializer:()Lorg/apache/cassandra/io/sstable/metadata/IMetadataSerializer;
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
aload 4
invokeinterface org.apache.cassandra.io.sstable.metadata.IMetadataSerializer.deserialize:(Lorg/apache/cassandra/io/sstable/Descriptor;Ljava/util/EnumSet;)Ljava/util/Map;
astore 5
start local 5 5: aload 5
getstatic org.apache.cassandra.io.sstable.metadata.MetadataType.VALIDATION:Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
ifeq 11
6: aload 5
getstatic org.apache.cassandra.io.sstable.metadata.MetadataType.VALIDATION:Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.metadata.ValidationMetadata
getfield org.apache.cassandra.io.sstable.metadata.ValidationMetadata.partitioner:Ljava/lang/String;
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getPartitioner:()Lorg/apache/cassandra/dht/IPartitioner;
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokevirtual java.lang.Class.getCanonicalName:()Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 11
7: new java.io.IOException
dup
ldc "Partitioner does not match validation metadata"
invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
athrow
end local 5 end local 4 8: StackMap locals: org.apache.cassandra.db.compaction.Verifier int long
StackMap stack: java.lang.Throwable
astore 4
start local 4 9: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.outputHandler:Lorg/apache/cassandra/utils/OutputHandler;
aload 4
invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
invokeinterface org.apache.cassandra.utils.OutputHandler.debug:(Ljava/lang/String;)V
10: aload 0
iconst_0
invokevirtual org.apache.cassandra.db.compaction.Verifier.markAndThrow:(Z)V
end local 4 11: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.outputHandler:Lorg/apache/cassandra/utils/OutputHandler;
ldc "Checking computed hash of %s "
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokeinterface org.apache.cassandra.utils.OutputHandler.output:(Ljava/lang/String;)V
12: aload 0
aconst_null
putfield org.apache.cassandra.db.compaction.Verifier.validator:Lorg/apache/cassandra/io/util/DataIntegrityMetadata$FileDigestValidator;
13: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
getfield org.apache.cassandra.io.sstable.Descriptor.digestComponent:Lorg/apache/cassandra/io/sstable/Component;
ifnull 18
14: new java.io.File
dup
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
getfield org.apache.cassandra.io.sstable.Descriptor.digestComponent:Lorg/apache/cassandra/io/sstable/Component;
invokevirtual org.apache.cassandra.io.sstable.Descriptor.filenameFor:(Lorg/apache/cassandra/io/sstable/Component;)Ljava/lang/String;
invokespecial java.io.File.<init>:(Ljava/lang/String;)V
invokevirtual java.io.File.exists:()Z
ifeq 18
15: aload 0
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
invokestatic org.apache.cassandra.io.util.DataIntegrityMetadata.fileDigestValidator:(Lorg/apache/cassandra/io/sstable/Descriptor;)Lorg/apache/cassandra/io/util/DataIntegrityMetadata$FileDigestValidator;
putfield org.apache.cassandra.db.compaction.Verifier.validator:Lorg/apache/cassandra/io/util/DataIntegrityMetadata$FileDigestValidator;
16: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.validator:Lorg/apache/cassandra/io/util/DataIntegrityMetadata$FileDigestValidator;
invokevirtual org.apache.cassandra.io.util.DataIntegrityMetadata$FileDigestValidator.validate:()V
17: goto 28
18: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.outputHandler:Lorg/apache/cassandra/utils/OutputHandler;
ldc "Data digest missing, assuming extended verification of disk values"
invokeinterface org.apache.cassandra.utils.OutputHandler.output:(Ljava/lang/String;)V
19: iconst_1
istore 1
20: goto 28
21: StackMap locals:
StackMap stack: java.io.IOException
astore 4
start local 4 22: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.outputHandler:Lorg/apache/cassandra/utils/OutputHandler;
aload 4
invokevirtual java.io.IOException.getMessage:()Ljava/lang/String;
invokeinterface org.apache.cassandra.utils.OutputHandler.debug:(Ljava/lang/String;)V
23: aload 0
invokevirtual org.apache.cassandra.db.compaction.Verifier.markAndThrow:()V
end local 4 24: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.validator:Lorg/apache/cassandra/io/util/DataIntegrityMetadata$FileDigestValidator;
invokestatic org.apache.cassandra.io.util.FileUtils.closeQuietly:(Ljava/io/Closeable;)V
goto 29
25: StackMap locals:
StackMap stack: java.lang.Throwable
astore 5
26: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.validator:Lorg/apache/cassandra/io/util/DataIntegrityMetadata$FileDigestValidator;
invokestatic org.apache.cassandra.io.util.FileUtils.closeQuietly:(Ljava/io/Closeable;)V
27: aload 5
athrow
28: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.validator:Lorg/apache/cassandra/io/util/DataIntegrityMetadata$FileDigestValidator;
invokestatic org.apache.cassandra.io.util.FileUtils.closeQuietly:(Ljava/io/Closeable;)V
29: StackMap locals:
StackMap stack:
iload 1
ifne 31
30: return
31: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.outputHandler:Lorg/apache/cassandra/utils/OutputHandler;
ldc "Extended Verify requested, proceeding to inspect values"
invokeinterface org.apache.cassandra.utils.OutputHandler.output:(Ljava/lang/String;)V
32: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.indexFile:Lorg/apache/cassandra/io/util/RandomAccessReader;
invokestatic org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength:(Ljava/io/DataInput;)Ljava/nio/ByteBuffer;
astore 4
start local 4 33: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.rowIndexEntrySerializer:Lorg/apache/cassandra/db/RowIndexEntry$IndexSerializer;
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.indexFile:Lorg/apache/cassandra/io/util/RandomAccessReader;
invokeinterface org.apache.cassandra.db.RowIndexEntry$IndexSerializer.deserializePositionAndSkip:(Lorg/apache/cassandra/io/util/DataInputPlus;)J
lstore 5
start local 5 34: lload 5
lconst_0
lcmp
ifeq 36
35: aload 0
invokevirtual org.apache.cassandra.db.compaction.Verifier.markAndThrow:()V
end local 5 36: StackMap locals: java.nio.ByteBuffer
StackMap stack:
aconst_null
astore 5
start local 5 37: goto 90
38: StackMap locals: org.apache.cassandra.db.DecoratedKey
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.verifyInfo:Lorg/apache/cassandra/db/compaction/Verifier$VerifyInfo;
invokevirtual org.apache.cassandra.db.compaction.Verifier$VerifyInfo.isStopRequested:()Z
ifeq 40
39: new org.apache.cassandra.db.compaction.CompactionInterruptedException
dup
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.verifyInfo:Lorg/apache/cassandra/db/compaction/Verifier$VerifyInfo;
invokevirtual org.apache.cassandra.db.compaction.Verifier$VerifyInfo.getCompactionInfo:()Lorg/apache/cassandra/db/compaction/CompactionInfo;
invokespecial org.apache.cassandra.db.compaction.CompactionInterruptedException.<init>:(Lorg/apache/cassandra/db/compaction/CompactionInfo;)V
athrow
40: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.dataFile:Lorg/apache/cassandra/io/util/RandomAccessReader;
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.getFilePointer:()J
lstore 2
41: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.outputHandler:Lorg/apache/cassandra/utils/OutputHandler;
new java.lang.StringBuilder
dup
ldc "Reading row at "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
lload 2
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface org.apache.cassandra.utils.OutputHandler.debug:(Ljava/lang/String;)V
42: aconst_null
astore 6
start local 6 43: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.dataFile:Lorg/apache/cassandra/io/util/RandomAccessReader;
invokestatic org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength:(Ljava/io/DataInput;)Ljava/nio/ByteBuffer;
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.decorateKey:(Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/db/DecoratedKey;
astore 6
44: goto 47
45: StackMap locals: org.apache.cassandra.db.compaction.Verifier int long java.nio.ByteBuffer org.apache.cassandra.db.DecoratedKey org.apache.cassandra.db.DecoratedKey
StackMap stack: java.lang.Throwable
astore 7
start local 7 46: aload 0
aload 7
invokevirtual org.apache.cassandra.db.compaction.Verifier.throwIfFatal:(Ljava/lang/Throwable;)V
end local 7 47: StackMap locals:
StackMap stack:
aload 4
astore 7
start local 7 48: lconst_0
lstore 8
start local 8 49: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.indexFile:Lorg/apache/cassandra/io/util/RandomAccessReader;
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.isEOF:()Z
ifeq 50
aconst_null
goto 51
StackMap locals: java.nio.ByteBuffer long
StackMap stack:
50: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.indexFile:Lorg/apache/cassandra/io/util/RandomAccessReader;
invokestatic org.apache.cassandra.utils.ByteBufferUtil.readWithShortLength:(Ljava/io/DataInput;)Ljava/nio/ByteBuffer;
StackMap locals:
StackMap stack: java.nio.ByteBuffer
51: astore 4
52: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.indexFile:Lorg/apache/cassandra/io/util/RandomAccessReader;
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.isEOF:()Z
ifeq 54
53: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.dataFile:Lorg/apache/cassandra/io/util/RandomAccessReader;
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.length:()J
goto 55
54: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.rowIndexEntrySerializer:Lorg/apache/cassandra/db/RowIndexEntry$IndexSerializer;
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.indexFile:Lorg/apache/cassandra/io/util/RandomAccessReader;
invokeinterface org.apache.cassandra.db.RowIndexEntry$IndexSerializer.deserializePositionAndSkip:(Lorg/apache/cassandra/io/util/DataInputPlus;)J
55: StackMap locals:
StackMap stack: long
lstore 8
56: goto 59
57: StackMap locals:
StackMap stack: java.lang.Throwable
pop
58: aload 0
invokevirtual org.apache.cassandra.db.compaction.Verifier.markAndThrow:()V
59: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.dataFile:Lorg/apache/cassandra/io/util/RandomAccessReader;
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.getFilePointer:()J
lstore 10
start local 10 60: aload 7
ifnonnull 62
61: ldc -1
goto 63
62: StackMap locals: long
StackMap stack:
lload 2
ldc 2
ladd
aload 7
invokevirtual java.nio.ByteBuffer.remaining:()I
i2l
ladd
63: StackMap locals:
StackMap stack: long
lstore 12
start local 12 64: lload 8
lload 12
lsub
lstore 14
start local 14 65: aload 6
ifnonnull 66
ldc "(unreadable key)"
goto 67
StackMap locals: long long
StackMap stack:
66: aload 6
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
invokestatic org.apache.cassandra.utils.ByteBufferUtil.bytesToHex:(Ljava/nio/ByteBuffer;)Ljava/lang/String;
StackMap locals:
StackMap stack: java.lang.String
67: astore 16
start local 16 68: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.outputHandler:Lorg/apache/cassandra/utils/OutputHandler;
ldc "row %s is %s"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 16
aastore
dup
iconst_1
lload 14
invokestatic org.apache.cassandra.utils.FBUtilities.prettyPrintMemory:(J)Ljava/lang/String;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokeinterface org.apache.cassandra.utils.OutputHandler.debug:(Ljava/lang/String;)V
69: getstatic org.apache.cassandra.db.compaction.Verifier.$assertionsDisabled:Z
ifne 70
aload 7
ifnonnull 70
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.indexFile:Lorg/apache/cassandra/io/util/RandomAccessReader;
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.isEOF:()Z
ifne 70
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
70: StackMap locals: java.lang.String
StackMap stack:
aload 6
ifnull 71
lload 14
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.dataFile:Lorg/apache/cassandra/io/util/RandomAccessReader;
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.length:()J
lcmp
ifle 72
71: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.db.compaction.Verifier.markAndThrow:()V
72: StackMap locals:
StackMap stack:
aconst_null
astore 17
aconst_null
astore 18
73: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.dataFile:Lorg/apache/cassandra/io/util/RandomAccessReader;
aload 6
invokestatic org.apache.cassandra.io.sstable.SSTableIdentityIterator.create:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;Lorg/apache/cassandra/io/util/RandomAccessReader;Lorg/apache/cassandra/db/DecoratedKey;)Lorg/apache/cassandra/io/sstable/SSTableIdentityIterator;
astore 19
start local 19 74: aload 19
ifnull 80
aload 19
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
goto 80
StackMap locals: org.apache.cassandra.db.compaction.Verifier int long java.nio.ByteBuffer org.apache.cassandra.db.DecoratedKey org.apache.cassandra.db.DecoratedKey java.nio.ByteBuffer long long long long java.lang.String java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.rows.UnfilteredRowIterator
StackMap stack: java.lang.Throwable
75: astore 17
aload 19
ifnull 76
aload 19
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
end local 19 StackMap locals:
StackMap stack:
76: aload 17
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
77: astore 18
aload 17
ifnonnull 78
aload 18
astore 17
goto 79
StackMap locals:
StackMap stack:
78: aload 17
aload 18
if_acmpeq 79
aload 17
aload 18
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
79: aload 17
athrow
80: StackMap locals:
StackMap stack:
aload 5
ifnull 81
aload 5
aload 6
invokevirtual org.apache.cassandra.db.DecoratedKey.compareTo:(Lorg/apache/cassandra/db/PartitionPosition;)I
ifgt 82
StackMap locals:
StackMap stack:
81: aload 6
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
aload 7
invokevirtual java.nio.ByteBuffer.equals:(Ljava/lang/Object;)Z
ifeq 82
lload 10
lload 12
lcmp
ifeq 83
82: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.apache.cassandra.db.compaction.Verifier.markAndThrow:()V
83: StackMap locals:
StackMap stack:
aload 0
dup
getfield org.apache.cassandra.db.compaction.Verifier.goodRows:I
iconst_1
iadd
putfield org.apache.cassandra.db.compaction.Verifier.goodRows:I
84: aload 6
astore 5
85: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.outputHandler:Lorg/apache/cassandra/utils/OutputHandler;
ldc "Row %s at %s valid, moving to next row at %s "
iconst_3
anewarray java.lang.Object
dup
iconst_0
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.goodRows:I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
lload 2
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
dup
iconst_2
lload 8
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokeinterface org.apache.cassandra.utils.OutputHandler.debug:(Ljava/lang/String;)V
86: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.dataFile:Lorg/apache/cassandra/io/util/RandomAccessReader;
lload 8
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.seek:(J)V
87: goto 90
88: StackMap locals:
StackMap stack: java.lang.Throwable
pop
89: aload 0
invokevirtual org.apache.cassandra.db.compaction.Verifier.markAndThrow:()V
end local 16 end local 14 end local 12 end local 10 end local 8 end local 7 end local 6 90: StackMap locals: org.apache.cassandra.db.compaction.Verifier int long java.nio.ByteBuffer org.apache.cassandra.db.DecoratedKey
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.dataFile:Lorg/apache/cassandra/io/util/RandomAccessReader;
invokevirtual org.apache.cassandra.io.util.RandomAccessReader.isEOF:()Z
ifeq 38
end local 5 end local 4 91: goto 97
92: StackMap locals: org.apache.cassandra.db.compaction.Verifier int long
StackMap stack: java.lang.Throwable
astore 4
start local 4 93: aload 4
invokestatic com.google.common.base.Throwables.propagate:(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;
athrow
end local 4 94: StackMap locals:
StackMap stack: java.lang.Throwable
astore 20
95: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.controller:Lorg/apache/cassandra/db/compaction/CompactionController;
invokevirtual org.apache.cassandra.db.compaction.CompactionController.close:()V
96: aload 20
athrow
97: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.controller:Lorg/apache/cassandra/db/compaction/CompactionController;
invokevirtual org.apache.cassandra.db.compaction.CompactionController.close:()V
98: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.outputHandler:Lorg/apache/cassandra/utils/OutputHandler;
new java.lang.StringBuilder
dup
ldc "Verify of "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
ldc " succeeded. All "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.goodRows:I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc " rows read successfully"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface org.apache.cassandra.utils.OutputHandler.output:(Ljava/lang/String;)V
99: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 100 0 this Lorg/apache/cassandra/db/compaction/Verifier;
0 100 1 extended Z
1 100 2 rowStart J
4 8 4 types Ljava/util/EnumSet<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;>;
5 8 5 sstableMetadata Ljava/util/Map<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;>;
9 11 4 t Ljava/lang/Throwable;
22 24 4 e Ljava/io/IOException;
33 91 4 nextIndexKey Ljava/nio/ByteBuffer;
34 36 5 firstRowPositionFromIndex J
37 91 5 prevKey Lorg/apache/cassandra/db/DecoratedKey;
43 90 6 key Lorg/apache/cassandra/db/DecoratedKey;
46 47 7 th Ljava/lang/Throwable;
48 90 7 currentIndexKey Ljava/nio/ByteBuffer;
49 90 8 nextRowPositionFromIndex J
60 90 10 dataStart J
64 90 12 dataStartFromIndex J
65 90 14 dataSize J
68 90 16 keyName Ljava/lang/String;
74 76 19 iterator Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
93 94 4 t Ljava/lang/Throwable;
Exception table:
from to target type
3 8 8 Class java.lang.Throwable
12 20 21 Class java.io.IOException
12 24 25 any
43 44 45 Class java.lang.Throwable
49 56 57 Class java.lang.Throwable
73 77 77 any
70 87 88 Class java.lang.Throwable
32 91 92 Class java.lang.Throwable
32 94 94 any
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
extended
public void close();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.dataFile:Lorg/apache/cassandra/io/util/RandomAccessReader;
invokestatic org.apache.cassandra.io.util.FileUtils.closeQuietly:(Ljava/io/Closeable;)V
1: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.indexFile:Lorg/apache/cassandra/io/util/RandomAccessReader;
invokestatic org.apache.cassandra.io.util.FileUtils.closeQuietly:(Ljava/io/Closeable;)V
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/db/compaction/Verifier;
private void throwIfFatal(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 1
instanceof java.lang.Error
ifeq 2
aload 1
instanceof java.lang.AssertionError
ifne 2
aload 1
instanceof java.io.IOError
ifne 2
1: aload 1
checkcast java.lang.Error
athrow
2: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/db/compaction/Verifier;
0 3 1 th Ljava/lang/Throwable;
MethodParameters:
Name Flags
th
private void markAndThrow();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_1
invokevirtual org.apache.cassandra.db.compaction.Verifier.markAndThrow:(Z)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/compaction/Verifier;
Exceptions:
throws java.io.IOException
private void markAndThrow(boolean);
descriptor: (Z)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=9, locals=2, args_size=2
start local 0 start local 1 0: iload 1
ifeq 7
1: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
invokevirtual org.apache.cassandra.io.sstable.Descriptor.getMetadataSerializer:()Lorg/apache/cassandra/io/sstable/metadata/IMetadataSerializer;
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
lconst_0
invokeinterface org.apache.cassandra.io.sstable.metadata.IMetadataSerializer.mutateRepairedAt:(Lorg/apache/cassandra/io/sstable/Descriptor;J)V
2: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.reloadSSTableMetadata:()V
3: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.cfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getTracker:()Lorg/apache/cassandra/db/lifecycle/Tracker;
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
invokestatic java.util.Collections.singleton:(Ljava/lang/Object;)Ljava/util/Set;
invokevirtual org.apache.cassandra.db.lifecycle.Tracker.notifySSTableRepairedStatusChanged:(Ljava/util/Collection;)V
4: goto 7
5: StackMap locals:
StackMap stack: java.io.IOException
pop
6: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.outputHandler:Lorg/apache/cassandra/utils/OutputHandler;
new java.lang.StringBuilder
dup
ldc "Error mutating repairedAt for SSTable "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getFilename:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ", as part of markAndThrow"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokeinterface org.apache.cassandra.utils.OutputHandler.output:(Ljava/lang/String;)V
7: StackMap locals:
StackMap stack:
new org.apache.cassandra.io.sstable.CorruptSSTableException
dup
8: new java.lang.Exception
dup
ldc "Invalid SSTable %s, please force %srepair"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getFilename:()Ljava/lang/String;
aastore
dup
iconst_1
iload 1
ifeq 9
ldc ""
goto 10
StackMap locals: org.apache.cassandra.db.compaction.Verifier int
StackMap stack: new 7 new 7 new 8 new 8 java.lang.String java.lang.Object[] java.lang.Object[] int
9: ldc "a full "
StackMap locals: org.apache.cassandra.db.compaction.Verifier int
StackMap stack: new 7 new 7 new 8 new 8 java.lang.String java.lang.Object[] java.lang.Object[] int java.lang.String
10: aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.Exception.<init>:(Ljava/lang/String;)V
aload 0
getfield org.apache.cassandra.db.compaction.Verifier.sstable:Lorg/apache/cassandra/io/sstable/format/SSTableReader;
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getFilename:()Ljava/lang/String;
invokespecial org.apache.cassandra.io.sstable.CorruptSSTableException.<init>:(Ljava/lang/Throwable;Ljava/lang/String;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/apache/cassandra/db/compaction/Verifier;
0 11 1 mutateRepaired Z
Exception table:
from to target type
1 4 5 Class java.io.IOException
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
mutateRepaired
public org.apache.cassandra.db.compaction.CompactionInfo$Holder getVerifyInfo();
descriptor: ()Lorg/apache/cassandra/db/compaction/CompactionInfo$Holder;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.compaction.Verifier.verifyInfo:Lorg/apache/cassandra/db/compaction/Verifier$VerifyInfo;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/compaction/Verifier;
}
SourceFile: "Verifier.java"
NestMembers:
org.apache.cassandra.db.compaction.Verifier$VerifyController org.apache.cassandra.db.compaction.Verifier$VerifyInfo
InnerClasses:
public abstract IndexSerializer = org.apache.cassandra.db.RowIndexEntry$IndexSerializer of org.apache.cassandra.db.RowIndexEntry
public abstract Holder = org.apache.cassandra.db.compaction.CompactionInfo$Holder of org.apache.cassandra.db.compaction.CompactionInfo
private VerifyController = org.apache.cassandra.db.compaction.Verifier$VerifyController of org.apache.cassandra.db.compaction.Verifier
private VerifyInfo = org.apache.cassandra.db.compaction.Verifier$VerifyInfo of org.apache.cassandra.db.compaction.Verifier
public FileDigestValidator = org.apache.cassandra.io.util.DataIntegrityMetadata$FileDigestValidator of org.apache.cassandra.io.util.DataIntegrityMetadata
public LogOutput = org.apache.cassandra.utils.OutputHandler$LogOutput of org.apache.cassandra.utils.OutputHandler