org.apache.cassandra/cassandra-all/3.11.5 : org/apache/cassandra/hints/LegacyHintsMigrator.class

LegacyHintsMigrator
https://cassandra.apache.org: The Apache Cassandra Project develops a highly scalable second-generation distributed database, bringing together Dynamo's fully distributed design and Bigtable's ColumnFamily-based data model.
The Apache Software License, Version 2.0
Andres de la Peña
Avinash Lakshman
Aleksey Yeschenko
Aaron Morton
Ariel Weisberg
Blake Eggleston
Benedict Elliott Smith
Benjamin Lerer
Branimir Lambov
Brandon Williams
Carl Yeksigian
David Brosiusd
Dikang Gu
Eric Evans
Gary Dusbabek
Chris Goffinet
Alex Petrov
Laine Jaakko Olavi
T Jake Luciani
Jason Brown
Jonathan Ellis
Jake Farrell
Jeff Jirsa
Joel Knighton
Josh McKenzie
Johan Oskarsson
Jun Rao
Jay Zhuang
Sankalp Kohli
Marcus Eriksson
Michael Semb Wever
Mikhail Stepura
Michael Shuler
Paulo Motta
Prashant Malik
Robert Stupp
Peter Schuller
Sam Tunnicliffe
Sylvain Lebresne
Stefania Alborghetti
Tyler Hobbs
Vijay Parthasarathy
Pavel Yaskevich
Yuki Morishita
Nate McCall
public final class org.apache.cassandra.hints.LegacyHintsMigrator
  minor version: 0
  major version: 59
  flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
  this_class: org.apache.cassandra.hints.LegacyHintsMigrator
  super_class: java.lang.Object
{
  private static final org.slf4j.Logger logger;
    descriptor: Lorg/slf4j/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private final java.io.File hintsDirectory;
    descriptor: Ljava/io/File;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final long maxHintsFileSize;
    descriptor: J
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.apache.cassandra.db.ColumnFamilyStore legacyHintsTable;
    descriptor: Lorg/apache/cassandra/db/ColumnFamilyStore;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final int pageSize;
    descriptor: I
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 50
            ldc Lorg/apache/cassandra/hints/LegacyHintsMigrator;
            invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
            putstatic org.apache.cassandra.hints.LegacyHintsMigrator.logger:Lorg/slf4j/Logger;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(java.io.File, long);
    descriptor: (Ljava/io/File;J)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // org.apache.cassandra.hints.LegacyHintsMigrator this
        start local 1 // java.io.File hintsDirectory
        start local 2 // long maxHintsFileSize
         0: .line 58
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 60
            aload 0 /* this */
            aload 1 /* hintsDirectory */
            putfield org.apache.cassandra.hints.LegacyHintsMigrator.hintsDirectory:Ljava/io/File;
         2: .line 61
            aload 0 /* this */
            lload 2 /* maxHintsFileSize */
            putfield org.apache.cassandra.hints.LegacyHintsMigrator.maxHintsFileSize:J
         3: .line 63
            aload 0 /* this */
            ldc "system"
            invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
            ldc "hints"
            invokevirtual org.apache.cassandra.db.Keyspace.getColumnFamilyStore:(Ljava/lang/String;)Lorg/apache/cassandra/db/ColumnFamilyStore;
            putfield org.apache.cassandra.hints.LegacyHintsMigrator.legacyHintsTable:Lorg/apache/cassandra/db/ColumnFamilyStore;
         4: .line 64
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.hints.LegacyHintsMigrator.legacyHintsTable:Lorg/apache/cassandra/db/ColumnFamilyStore;
            invokestatic org.apache.cassandra.hints.LegacyHintsMigrator.calculatePageSize:(Lorg/apache/cassandra/db/ColumnFamilyStore;)I
            putfield org.apache.cassandra.hints.LegacyHintsMigrator.pageSize:I
         5: .line 65
            return
        end local 2 // long maxHintsFileSize
        end local 1 // java.io.File hintsDirectory
        end local 0 // org.apache.cassandra.hints.LegacyHintsMigrator this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    6     0              this  Lorg/apache/cassandra/hints/LegacyHintsMigrator;
            0    6     1    hintsDirectory  Ljava/io/File;
            0    6     2  maxHintsFileSize  J
    MethodParameters:
                  Name  Flags
      hintsDirectory    
      maxHintsFileSize  

  private static int calculatePageSize(org.apache.cassandra.db.ColumnFamilyStore);
    descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;)I
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=4, locals=6, args_size=1
        start local 0 // org.apache.cassandra.db.ColumnFamilyStore legacyHintsTable
         0: .line 70
            sipush 128
            istore 1 /* size */
        start local 1 // int size
         1: .line 72
            aload 0 /* legacyHintsTable */
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getMeanColumns:()I
            istore 2 /* meanCellCount */
        start local 2 // int meanCellCount
         2: .line 73
            aload 0 /* legacyHintsTable */
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getMeanPartitionSize:()D
            dstore 3 /* meanPartitionSize */
        start local 3 // double meanPartitionSize
         3: .line 75
            iload 2 /* meanCellCount */
            ifeq 6
            dload 3 /* meanPartitionSize */
            dconst_0
            dcmpl
            ifeq 6
         4: .line 77
            dload 3 /* meanPartitionSize */
            d2i
            iload 2 /* meanCellCount */
            idiv
            istore 5 /* avgHintSize */
        start local 5 // int avgHintSize
         5: .line 78
            iconst_2
            iload 1 /* size */
            ldc 524288
            iload 5 /* avgHintSize */
            idiv
            invokestatic java.lang.Math.min:(II)I
            invokestatic java.lang.Math.max:(II)I
            istore 1 /* size */
        end local 5 // int avgHintSize
         6: .line 81
      StackMap locals: int int double
      StackMap stack:
            iload 1 /* size */
            ireturn
        end local 3 // double meanPartitionSize
        end local 2 // int meanCellCount
        end local 1 // int size
        end local 0 // org.apache.cassandra.db.ColumnFamilyStore legacyHintsTable
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    7     0   legacyHintsTable  Lorg/apache/cassandra/db/ColumnFamilyStore;
            1    7     1               size  I
            2    7     2      meanCellCount  I
            3    7     3  meanPartitionSize  D
            5    6     5        avgHintSize  I
    MethodParameters:
                  Name  Flags
      legacyHintsTable  

  public void migrate();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // org.apache.cassandra.hints.LegacyHintsMigrator this
         0: .line 87
            aload 0 /* this */
            getfield org.apache.cassandra.hints.LegacyHintsMigrator.legacyHintsTable:Lorg/apache/cassandra/db/ColumnFamilyStore;
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.isEmpty:()Z
            ifeq 2
         1: .line 88
            return
         2: .line 89
      StackMap locals:
      StackMap stack:
            getstatic org.apache.cassandra.hints.LegacyHintsMigrator.logger:Lorg/slf4j/Logger;
            ldc "Migrating legacy hints to new storage"
            invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;)V
         3: .line 92
            getstatic org.apache.cassandra.hints.LegacyHintsMigrator.logger:Lorg/slf4j/Logger;
            ldc "Forcing a major compaction of {}.{} table"
            ldc "system"
            ldc "hints"
            invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
         4: .line 93
            aload 0 /* this */
            invokevirtual org.apache.cassandra.hints.LegacyHintsMigrator.compactLegacyHints:()V
         5: .line 96
            getstatic org.apache.cassandra.hints.LegacyHintsMigrator.logger:Lorg/slf4j/Logger;
            ldc "Writing legacy hints to the new storage"
            invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;)V
         6: .line 97
            aload 0 /* this */
            invokevirtual org.apache.cassandra.hints.LegacyHintsMigrator.migrateLegacyHints:()V
         7: .line 100
            getstatic org.apache.cassandra.hints.LegacyHintsMigrator.logger:Lorg/slf4j/Logger;
            ldc "Truncating {}.{} table"
            ldc "system"
            ldc "hints"
            invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
         8: .line 101
            aload 0 /* this */
            getfield org.apache.cassandra.hints.LegacyHintsMigrator.legacyHintsTable:Lorg/apache/cassandra/db/ColumnFamilyStore;
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.truncateBlocking:()V
         9: .line 102
            return
        end local 0 // org.apache.cassandra.hints.LegacyHintsMigrator this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   10     0  this  Lorg/apache/cassandra/hints/LegacyHintsMigrator;

  private void compactLegacyHints();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // org.apache.cassandra.hints.LegacyHintsMigrator this
         0: .line 106
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            astore 1 /* descriptors */
        start local 1 // java.util.Collection descriptors
         1: .line 107
            aload 0 /* this */
            getfield org.apache.cassandra.hints.LegacyHintsMigrator.legacyHintsTable:Lorg/apache/cassandra/db/ColumnFamilyStore;
            invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getTracker:()Lorg/apache/cassandra/db/lifecycle/Tracker;
            invokevirtual org.apache.cassandra.db.lifecycle.Tracker.getUncompacting:()Ljava/lang/Iterable;
            aload 1 /* descriptors */
            invokedynamic accept(Ljava/util/Collection;)Ljava/util/function/Consumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  org/apache/cassandra/hints/LegacyHintsMigrator.lambda$0(Ljava/util/Collection;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V (6)
                  (Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
            invokeinterface java.lang.Iterable.forEach:(Ljava/util/function/Consumer;)V
         2: .line 108
            aload 1 /* descriptors */
            invokeinterface java.util.Collection.isEmpty:()Z
            ifne 4
         3: .line 109
            aload 0 /* this */
            aload 1 /* descriptors */
            invokevirtual org.apache.cassandra.hints.LegacyHintsMigrator.forceCompaction:(Ljava/util/Collection;)V
         4: .line 110
      StackMap locals: java.util.Collection
      StackMap stack:
            return
        end local 1 // java.util.Collection descriptors
        end local 0 // org.apache.cassandra.hints.LegacyHintsMigrator this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    5     0         this  Lorg/apache/cassandra/hints/LegacyHintsMigrator;
            1    5     1  descriptors  Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/Descriptor;>;

  private void forceCompaction(java.util.Collection<org.apache.cassandra.io.sstable.Descriptor>);
    descriptor: (Ljava/util/Collection;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // org.apache.cassandra.hints.LegacyHintsMigrator this
        start local 1 // java.util.Collection descriptors
         0: .line 116
            getstatic org.apache.cassandra.db.compaction.CompactionManager.instance:Lorg/apache/cassandra/db/compaction/CompactionManager;
            aload 0 /* this */
            getfield org.apache.cassandra.hints.LegacyHintsMigrator.legacyHintsTable:Lorg/apache/cassandra/db/ColumnFamilyStore;
            aload 1 /* descriptors */
            invokestatic org.apache.cassandra.utils.FBUtilities.nowInSeconds:()I
            invokevirtual org.apache.cassandra.db.compaction.CompactionManager.submitUserDefined:(Lorg/apache/cassandra/db/ColumnFamilyStore;Ljava/util/Collection;I)Ljava/util/concurrent/Future;
            invokeinterface java.util.concurrent.Future.get:()Ljava/lang/Object;
            pop
         1: .line 117
            goto 4
         2: .line 118
      StackMap locals:
      StackMap stack: java.lang.Exception
            astore 2 /* e */
        start local 2 // java.lang.Exception e
         3: .line 120
            new java.lang.RuntimeException
            dup
            aload 2 /* e */
            invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
            athrow
        end local 2 // java.lang.Exception e
         4: .line 122
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.util.Collection descriptors
        end local 0 // org.apache.cassandra.hints.LegacyHintsMigrator this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    5     0         this  Lorg/apache/cassandra/hints/LegacyHintsMigrator;
            0    5     1  descriptors  Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/Descriptor;>;
            3    4     2            e  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           0     1       2  Class java.lang.InterruptedException
           0     1       2  Class java.util.concurrent.ExecutionException
    Signature: (Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/Descriptor;>;)V
    MethodParameters:
             Name  Flags
      descriptors  

  private void migrateLegacyHints();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=3, args_size=1
        start local 0 // org.apache.cassandra.hints.LegacyHintsMigrator this
         0: .line 126
            ldc 262144
            invokestatic java.nio.ByteBuffer.allocateDirect:(I)Ljava/nio/ByteBuffer;
            astore 1 /* buffer */
        start local 1 // java.nio.ByteBuffer buffer
         1: .line 127
            ldc "SELECT DISTINCT target_id FROM %s.%s"
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
            ldc "system"
            aastore
            dup
            iconst_1
            ldc "hints"
            aastore
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            astore 2 /* query */
        start local 2 // java.lang.String query
         2: .line 129
            aload 2 /* query */
            iconst_0
            anewarray java.lang.Object
            invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
            aload 0 /* this */
            aload 1 /* buffer */
            invokedynamic accept(Lorg/apache/cassandra/hints/LegacyHintsMigrator;Ljava/nio/ByteBuffer;)Ljava/util/function/Consumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  org/apache/cassandra/hints/LegacyHintsMigrator.lambda$1(Ljava/nio/ByteBuffer;Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)V (7)
                  (Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)V
            invokevirtual org.apache.cassandra.cql3.UntypedResultSet.forEach:(Ljava/util/function/Consumer;)V
         3: .line 130
            aload 1 /* buffer */
            invokestatic org.apache.cassandra.io.util.FileUtils.clean:(Ljava/nio/ByteBuffer;)V
         4: .line 131
            return
        end local 2 // java.lang.String query
        end local 1 // java.nio.ByteBuffer buffer
        end local 0 // org.apache.cassandra.hints.LegacyHintsMigrator this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    5     0    this  Lorg/apache/cassandra/hints/LegacyHintsMigrator;
            1    5     1  buffer  Ljava/nio/ByteBuffer;
            2    5     2   query  Ljava/lang/String;

  private void migrateLegacyHints(java.util.UUID, java.nio.ByteBuffer);
    descriptor: (Ljava/util/UUID;Ljava/nio/ByteBuffer;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=6, locals=5, args_size=3
        start local 0 // org.apache.cassandra.hints.LegacyHintsMigrator this
        start local 1 // java.util.UUID hostId
        start local 2 // java.nio.ByteBuffer buffer
         0: .line 135
            ldc "SELECT target_id, hint_id, message_version, mutation, ttl(mutation) AS ttl, writeTime(mutation) AS write_time FROM %s.%s WHERE target_id = ?"
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
         1: .line 138
            ldc "system"
            aastore
            dup
            iconst_1
         2: .line 139
            ldc "hints"
            aastore
         3: .line 135
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            astore 3 /* query */
        start local 3 // java.lang.String query
         4: .line 142
            aload 3 /* query */
            aload 0 /* this */
            getfield org.apache.cassandra.hints.LegacyHintsMigrator.pageSize:I
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 1 /* hostId */
            aastore
            invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternalWithPaging:(Ljava/lang/String;I[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
            astore 4 /* rows */
        start local 4 // org.apache.cassandra.cql3.UntypedResultSet rows
         5: .line 143
            aload 0 /* this */
            aload 1 /* hostId */
            aload 4 /* rows */
            aload 2 /* buffer */
            invokevirtual org.apache.cassandra.hints.LegacyHintsMigrator.migrateLegacyHints:(Ljava/util/UUID;Lorg/apache/cassandra/cql3/UntypedResultSet;Ljava/nio/ByteBuffer;)V
         6: .line 147
            aload 1 /* hostId */
            invokestatic org.apache.cassandra.hints.LegacyHintsMigrator.deleteLegacyHintsPartition:(Ljava/util/UUID;)V
         7: .line 148
            return
        end local 4 // org.apache.cassandra.cql3.UntypedResultSet rows
        end local 3 // java.lang.String query
        end local 2 // java.nio.ByteBuffer buffer
        end local 1 // java.util.UUID hostId
        end local 0 // org.apache.cassandra.hints.LegacyHintsMigrator this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    8     0    this  Lorg/apache/cassandra/hints/LegacyHintsMigrator;
            0    8     1  hostId  Ljava/util/UUID;
            0    8     2  buffer  Ljava/nio/ByteBuffer;
            4    8     3   query  Ljava/lang/String;
            5    8     4    rows  Lorg/apache/cassandra/cql3/UntypedResultSet;
    MethodParameters:
        Name  Flags
      hostId  
      buffer  

  private void migrateLegacyHints(java.util.UUID, org.apache.cassandra.cql3.UntypedResultSet, java.nio.ByteBuffer);
    descriptor: (Ljava/util/UUID;Lorg/apache/cassandra/cql3/UntypedResultSet;Ljava/nio/ByteBuffer;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=4, args_size=4
        start local 0 // org.apache.cassandra.hints.LegacyHintsMigrator this
        start local 1 // java.util.UUID hostId
        start local 2 // org.apache.cassandra.cql3.UntypedResultSet rows
        start local 3 // java.nio.ByteBuffer buffer
         0: .line 152
            aload 0 /* this */
            aload 1 /* hostId */
            aload 2 /* rows */
            invokevirtual org.apache.cassandra.cql3.UntypedResultSet.iterator:()Ljava/util/Iterator;
            aload 3 /* buffer */
            invokevirtual org.apache.cassandra.hints.LegacyHintsMigrator.migrateLegacyHints:(Ljava/util/UUID;Ljava/util/Iterator;Ljava/nio/ByteBuffer;)V
         1: .line 153
            return
        end local 3 // java.nio.ByteBuffer buffer
        end local 2 // org.apache.cassandra.cql3.UntypedResultSet rows
        end local 1 // java.util.UUID hostId
        end local 0 // org.apache.cassandra.hints.LegacyHintsMigrator this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lorg/apache/cassandra/hints/LegacyHintsMigrator;
            0    2     1  hostId  Ljava/util/UUID;
            0    2     2    rows  Lorg/apache/cassandra/cql3/UntypedResultSet;
            0    2     3  buffer  Ljava/nio/ByteBuffer;
    MethodParameters:
        Name  Flags
      hostId  
      rows    
      buffer  

  private void migrateLegacyHints(java.util.UUID, java.util.Iterator<org.apache.cassandra.cql3.UntypedResultSet$Row>, java.nio.ByteBuffer);
    descriptor: (Ljava/util/UUID;Ljava/util/Iterator;Ljava/nio/ByteBuffer;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=4, args_size=4
        start local 0 // org.apache.cassandra.hints.LegacyHintsMigrator this
        start local 1 // java.util.UUID hostId
        start local 2 // java.util.Iterator iterator
        start local 3 // java.nio.ByteBuffer buffer
         0: .line 159
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* hostId */
            aload 2 /* iterator */
            aload 3 /* buffer */
            invokevirtual org.apache.cassandra.hints.LegacyHintsMigrator.migrateLegacyHintsInternal:(Ljava/util/UUID;Ljava/util/Iterator;Ljava/nio/ByteBuffer;)V
         1: .line 163
            aload 2 /* iterator */
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 0
         2: .line 164
            return
        end local 3 // java.nio.ByteBuffer buffer
        end local 2 // java.util.Iterator iterator
        end local 1 // java.util.UUID hostId
        end local 0 // org.apache.cassandra.hints.LegacyHintsMigrator this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    3     0      this  Lorg/apache/cassandra/hints/LegacyHintsMigrator;
            0    3     1    hostId  Ljava/util/UUID;
            0    3     2  iterator  Ljava/util/Iterator<Lorg/apache/cassandra/cql3/UntypedResultSet$Row;>;
            0    3     3    buffer  Ljava/nio/ByteBuffer;
    Signature: (Ljava/util/UUID;Ljava/util/Iterator<Lorg/apache/cassandra/cql3/UntypedResultSet$Row;>;Ljava/nio/ByteBuffer;)V
    MethodParameters:
          Name  Flags
      hostId    
      iterator  
      buffer    

  private void migrateLegacyHintsInternal(java.util.UUID, java.util.Iterator<org.apache.cassandra.cql3.UntypedResultSet$Row>, java.nio.ByteBuffer);
    descriptor: (Ljava/util/UUID;Ljava/util/Iterator;Ljava/nio/ByteBuffer;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=12, args_size=4
        start local 0 // org.apache.cassandra.hints.LegacyHintsMigrator this
        start local 1 // java.util.UUID hostId
        start local 2 // java.util.Iterator iterator
        start local 3 // java.nio.ByteBuffer buffer
         0: .line 168
            new org.apache.cassandra.hints.HintsDescriptor
            dup
            aload 1 /* hostId */
            invokestatic java.lang.System.currentTimeMillis:()J
            invokespecial org.apache.cassandra.hints.HintsDescriptor.<init>:(Ljava/util/UUID;J)V
            astore 4 /* descriptor */
        start local 4 // org.apache.cassandra.hints.HintsDescriptor descriptor
         1: .line 170
            aconst_null
            astore 5
            aconst_null
            astore 6
         2: aload 0 /* this */
            getfield org.apache.cassandra.hints.LegacyHintsMigrator.hintsDirectory:Ljava/io/File;
            aload 4 /* descriptor */
            invokestatic org.apache.cassandra.hints.HintsWriter.create:(Ljava/io/File;Lorg/apache/cassandra/hints/HintsDescriptor;)Lorg/apache/cassandra/hints/HintsWriter;
            astore 7 /* writer */
        start local 7 // org.apache.cassandra.hints.HintsWriter writer
         3: .line 172
            aconst_null
            astore 8
            aconst_null
            astore 9
         4: aload 7 /* writer */
            aload 3 /* buffer */
            invokevirtual org.apache.cassandra.hints.HintsWriter.newSession:(Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/hints/HintsWriter$Session;
            astore 10 /* session */
        start local 10 // org.apache.cassandra.hints.HintsWriter$Session session
         5: .line 174
            goto 11
         6: .line 176
      StackMap locals: org.apache.cassandra.hints.LegacyHintsMigrator java.util.UUID java.util.Iterator java.nio.ByteBuffer org.apache.cassandra.hints.HintsDescriptor java.lang.Throwable java.lang.Throwable org.apache.cassandra.hints.HintsWriter java.lang.Throwable java.lang.Throwable org.apache.cassandra.hints.HintsWriter$Session
      StackMap stack:
            aload 2 /* iterator */
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.cql3.UntypedResultSet$Row
            invokestatic org.apache.cassandra.hints.LegacyHintsMigrator.convertLegacyHint:(Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)Lorg/apache/cassandra/hints/Hint;
            astore 11 /* hint */
        start local 11 // org.apache.cassandra.hints.Hint hint
         7: .line 177
            aload 11 /* hint */
            ifnull 9
         8: .line 178
            aload 10 /* session */
            aload 11 /* hint */
            invokevirtual org.apache.cassandra.hints.HintsWriter$Session.append:(Lorg/apache/cassandra/hints/Hint;)V
         9: .line 180
      StackMap locals: org.apache.cassandra.hints.Hint
      StackMap stack:
            aload 10 /* session */
            invokevirtual org.apache.cassandra.hints.HintsWriter$Session.position:()J
            aload 0 /* this */
            getfield org.apache.cassandra.hints.LegacyHintsMigrator.maxHintsFileSize:J
            lcmp
            iflt 11
        10: .line 181
            goto 12
        end local 11 // org.apache.cassandra.hints.Hint hint
        11: .line 174
      StackMap locals:
      StackMap stack:
            aload 2 /* iterator */
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 6
        12: .line 183
      StackMap locals:
      StackMap stack:
            aload 10 /* session */
            ifnull 18
            aload 10 /* session */
            invokevirtual org.apache.cassandra.hints.HintsWriter$Session.close:()V
            goto 18
      StackMap locals:
      StackMap stack: java.lang.Throwable
        13: astore 8
            aload 10 /* session */
            ifnull 14
            aload 10 /* session */
            invokevirtual org.apache.cassandra.hints.HintsWriter$Session.close:()V
        end local 10 // org.apache.cassandra.hints.HintsWriter$Session session
      StackMap locals:
      StackMap stack:
        14: aload 8
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        15: astore 9
            aload 8
            ifnonnull 16
            aload 9
            astore 8
            goto 17
      StackMap locals:
      StackMap stack:
        16: aload 8
            aload 9
            if_acmpeq 17
            aload 8
            aload 9
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        17: aload 8
            athrow
        18: .line 184
      StackMap locals:
      StackMap stack:
            aload 7 /* writer */
            ifnull 26
            aload 7 /* writer */
            invokevirtual org.apache.cassandra.hints.HintsWriter.close:()V
            goto 26
      StackMap locals:
      StackMap stack: java.lang.Throwable
        19: astore 5
            aload 7 /* writer */
            ifnull 20
            aload 7 /* writer */
            invokevirtual org.apache.cassandra.hints.HintsWriter.close:()V
        end local 7 // org.apache.cassandra.hints.HintsWriter writer
      StackMap locals:
      StackMap stack:
        20: aload 5
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        21: astore 6
            aload 5
            ifnonnull 22
            aload 6
            astore 5
            goto 23
      StackMap locals:
      StackMap stack:
        22: aload 5
            aload 6
            if_acmpeq 23
            aload 5
            aload 6
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        23: aload 5
            athrow
        24: .line 185
      StackMap locals: org.apache.cassandra.hints.LegacyHintsMigrator java.util.UUID java.util.Iterator java.nio.ByteBuffer org.apache.cassandra.hints.HintsDescriptor
      StackMap stack: java.io.IOException
            astore 5 /* e */
        start local 5 // java.io.IOException e
        25: .line 187
            new org.apache.cassandra.io.FSWriteError
            dup
            aload 5 /* e */
            aload 4 /* descriptor */
            invokevirtual org.apache.cassandra.hints.HintsDescriptor.fileName:()Ljava/lang/String;
            invokespecial org.apache.cassandra.io.FSWriteError.<init>:(Ljava/lang/Throwable;Ljava/lang/String;)V
            athrow
        end local 5 // java.io.IOException e
        26: .line 189
      StackMap locals:
      StackMap stack:
            return
        end local 4 // org.apache.cassandra.hints.HintsDescriptor descriptor
        end local 3 // java.nio.ByteBuffer buffer
        end local 2 // java.util.Iterator iterator
        end local 1 // java.util.UUID hostId
        end local 0 // org.apache.cassandra.hints.LegacyHintsMigrator this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   27     0        this  Lorg/apache/cassandra/hints/LegacyHintsMigrator;
            0   27     1      hostId  Ljava/util/UUID;
            0   27     2    iterator  Ljava/util/Iterator<Lorg/apache/cassandra/cql3/UntypedResultSet$Row;>;
            0   27     3      buffer  Ljava/nio/ByteBuffer;
            1   27     4  descriptor  Lorg/apache/cassandra/hints/HintsDescriptor;
            3   20     7      writer  Lorg/apache/cassandra/hints/HintsWriter;
            5   14    10     session  Lorg/apache/cassandra/hints/HintsWriter$Session;
            7   11    11        hint  Lorg/apache/cassandra/hints/Hint;
           25   26     5           e  Ljava/io/IOException;
      Exception table:
        from    to  target  type
           5    12      13  any
           4    15      15  any
           3    18      19  any
           2    21      21  any
           1    24      24  Class java.io.IOException
    Signature: (Ljava/util/UUID;Ljava/util/Iterator<Lorg/apache/cassandra/cql3/UntypedResultSet$Row;>;Ljava/nio/ByteBuffer;)V
    MethodParameters:
          Name  Flags
      hostId    
      iterator  
      buffer    

  private static org.apache.cassandra.hints.Hint convertLegacyHint(org.apache.cassandra.cql3.UntypedResultSet$Row);
    descriptor: (Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)Lorg/apache/cassandra/hints/Hint;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=4, locals=7, args_size=1
        start local 0 // org.apache.cassandra.cql3.UntypedResultSet$Row row
         0: .line 193
            aload 0 /* row */
            invokestatic org.apache.cassandra.hints.LegacyHintsMigrator.deserializeLegacyMutation:(Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)Lorg/apache/cassandra/db/Mutation;
            astore 1 /* mutation */
        start local 1 // org.apache.cassandra.db.Mutation mutation
         1: .line 194
            aload 1 /* mutation */
            ifnonnull 3
         2: .line 195
            aconst_null
            areturn
         3: .line 197
      StackMap locals: org.apache.cassandra.db.Mutation
      StackMap stack:
            aload 0 /* row */
            ldc "write_time"
            invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getLong:(Ljava/lang/String;)J
            lstore 2 /* creationTime */
        start local 2 // long creationTime
         4: .line 198
            invokestatic org.apache.cassandra.utils.FBUtilities.nowInSeconds:()I
            aload 0 /* row */
            ldc "ttl"
            invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getInt:(Ljava/lang/String;)I
            iadd
            istore 4 /* expirationTime */
        start local 4 // int expirationTime
         5: .line 199
            iload 4 /* expirationTime */
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            lload 2 /* creationTime */
            invokevirtual java.util.concurrent.TimeUnit.toSeconds:(J)J
            l2i
            isub
            istore 5 /* originalGCGS */
        start local 5 // int originalGCGS
         6: .line 201
            iload 5 /* originalGCGS */
            aload 1 /* mutation */
            invokevirtual org.apache.cassandra.db.Mutation.smallestGCGS:()I
            invokestatic java.lang.Math.min:(II)I
            istore 6 /* gcgs */
        start local 6 // int gcgs
         7: .line 203
            aload 1 /* mutation */
            lload 2 /* creationTime */
            iload 6 /* gcgs */
            invokestatic org.apache.cassandra.hints.Hint.create:(Lorg/apache/cassandra/db/Mutation;JI)Lorg/apache/cassandra/hints/Hint;
            areturn
        end local 6 // int gcgs
        end local 5 // int originalGCGS
        end local 4 // int expirationTime
        end local 2 // long creationTime
        end local 1 // org.apache.cassandra.db.Mutation mutation
        end local 0 // org.apache.cassandra.cql3.UntypedResultSet$Row row
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    8     0             row  Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
            1    8     1        mutation  Lorg/apache/cassandra/db/Mutation;
            4    8     2    creationTime  J
            5    8     4  expirationTime  I
            6    8     5    originalGCGS  I
            7    8     6            gcgs  I
    MethodParameters:
      Name  Flags
      row   

  private static org.apache.cassandra.db.Mutation deserializeLegacyMutation(org.apache.cassandra.cql3.UntypedResultSet$Row);
    descriptor: (Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)Lorg/apache/cassandra/db/Mutation;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=7, locals=5, args_size=1
        start local 0 // org.apache.cassandra.cql3.UntypedResultSet$Row row
         0: .line 208
            aconst_null
            astore 1
            aconst_null
            astore 2
         1: new org.apache.cassandra.io.util.DataInputBuffer
            dup
            aload 0 /* row */
            ldc "mutation"
            invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getBlob:(Ljava/lang/String;)Ljava/nio/ByteBuffer;
            iconst_1
            invokespecial org.apache.cassandra.io.util.DataInputBuffer.<init>:(Ljava/nio/ByteBuffer;Z)V
            astore 3 /* dib */
        start local 3 // org.apache.cassandra.io.util.DataInputBuffer dib
         2: .line 210
            getstatic org.apache.cassandra.db.Mutation.serializer:Lorg/apache/cassandra/db/Mutation$MutationSerializer;
            aload 3 /* dib */
         3: .line 211
            aload 0 /* row */
            ldc "message_version"
            invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getInt:(Ljava/lang/String;)I
         4: .line 210
            invokevirtual org.apache.cassandra.db.Mutation$MutationSerializer.deserialize:(Lorg/apache/cassandra/io/util/DataInputPlus;I)Lorg/apache/cassandra/db/Mutation;
            astore 4 /* mutation */
        start local 4 // org.apache.cassandra.db.Mutation mutation
         5: .line 212
            aload 4 /* mutation */
            invokevirtual org.apache.cassandra.db.Mutation.getPartitionUpdates:()Ljava/util/Collection;
            invokedynamic accept()Ljava/util/function/Consumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  org/apache/cassandra/db/partitions/PartitionUpdate.validate()V (5)
                  (Lorg/apache/cassandra/db/partitions/PartitionUpdate;)V
            invokeinterface java.util.Collection.forEach:(Ljava/util/function/Consumer;)V
         6: .line 213
            aload 4 /* mutation */
         7: .line 214
            aload 3 /* dib */
            ifnull 8
            aload 3 /* dib */
            invokevirtual org.apache.cassandra.io.util.DataInputBuffer.close:()V
         8: .line 213
      StackMap locals: org.apache.cassandra.cql3.UntypedResultSet$Row java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.DataInputBuffer org.apache.cassandra.db.Mutation
      StackMap stack: org.apache.cassandra.db.Mutation
            areturn
        end local 4 // org.apache.cassandra.db.Mutation mutation
      StackMap locals: org.apache.cassandra.cql3.UntypedResultSet$Row java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.DataInputBuffer
      StackMap stack: java.lang.Throwable
         9: astore 1
        10: .line 214
            aload 3 /* dib */
            ifnull 11
            aload 3 /* dib */
            invokevirtual org.apache.cassandra.io.util.DataInputBuffer.close:()V
        end local 3 // org.apache.cassandra.io.util.DataInputBuffer dib
      StackMap locals:
      StackMap stack:
        11: aload 1
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        12: astore 2
            aload 1
            ifnonnull 13
            aload 2
            astore 1
            goto 14
      StackMap locals:
      StackMap stack:
        13: aload 1
            aload 2
            if_acmpeq 14
            aload 1
            aload 2
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        14: aload 1
            athrow
        15: .line 215
      StackMap locals: org.apache.cassandra.cql3.UntypedResultSet$Row
      StackMap stack: java.io.IOException
            astore 1 /* e */
        start local 1 // java.io.IOException e
        16: .line 217
            getstatic org.apache.cassandra.hints.LegacyHintsMigrator.logger:Lorg/slf4j/Logger;
            ldc "Failed to migrate a hint for {} from legacy {}.{} table"
            iconst_4
            anewarray java.lang.Object
            dup
            iconst_0
        17: .line 218
            aload 0 /* row */
            ldc "target_id"
            invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getUUID:(Ljava/lang/String;)Ljava/util/UUID;
            aastore
            dup
            iconst_1
        18: .line 219
            ldc "system"
            aastore
            dup
            iconst_2
        19: .line 220
            ldc "hints"
            aastore
            dup
            iconst_3
        20: .line 221
            aload 1 /* e */
            aastore
        21: .line 217
            invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;[Ljava/lang/Object;)V
        22: .line 222
            aconst_null
            areturn
        end local 1 // java.io.IOException e
        23: .line 224
      StackMap locals:
      StackMap stack: org.apache.cassandra.serializers.MarshalException
            astore 1 /* e */
        start local 1 // org.apache.cassandra.serializers.MarshalException e
        24: .line 226
            getstatic org.apache.cassandra.hints.LegacyHintsMigrator.logger:Lorg/slf4j/Logger;
            ldc "Failed to validate a hint for {} from legacy {}.{} table - skipping"
            iconst_4
            anewarray java.lang.Object
            dup
            iconst_0
        25: .line 227
            aload 0 /* row */
            ldc "target_id"
            invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getUUID:(Ljava/lang/String;)Ljava/util/UUID;
            aastore
            dup
            iconst_1
        26: .line 228
            ldc "system"
            aastore
            dup
            iconst_2
        27: .line 229
            ldc "hints"
            aastore
            dup
            iconst_3
        28: .line 230
            aload 1 /* e */
            aastore
        29: .line 226
            invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;[Ljava/lang/Object;)V
        30: .line 231
            aconst_null
            areturn
        end local 1 // org.apache.cassandra.serializers.MarshalException e
        end local 0 // org.apache.cassandra.cql3.UntypedResultSet$Row row
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   31     0       row  Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
            2   11     3       dib  Lorg/apache/cassandra/io/util/DataInputBuffer;
            5    9     4  mutation  Lorg/apache/cassandra/db/Mutation;
           16   23     1         e  Ljava/io/IOException;
           24   31     1         e  Lorg/apache/cassandra/serializers/MarshalException;
      Exception table:
        from    to  target  type
           2     7       9  any
           1     8      12  any
           9    12      12  any
           0     8      15  Class java.io.IOException
           9    15      15  Class java.io.IOException
           0     8      23  Class org.apache.cassandra.serializers.MarshalException
           9    15      23  Class org.apache.cassandra.serializers.MarshalException
    MethodParameters:
      Name  Flags
      row   

  private static void deleteLegacyHintsPartition(java.util.UUID);
    descriptor: (Ljava/util/UUID;)V
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=7, locals=2, args_size=1
        start local 0 // java.util.UUID hostId
         0: .line 238
            new org.apache.cassandra.db.Mutation
            dup
            getstatic org.apache.cassandra.db.SystemKeyspace.LegacyHints:Lorg/apache/cassandra/config/CFMetaData;
         1: .line 239
            getstatic org.apache.cassandra.db.marshal.UUIDType.instance:Lorg/apache/cassandra/db/marshal/UUIDType;
            aload 0 /* hostId */
            invokevirtual org.apache.cassandra.db.marshal.UUIDType.decompose:(Ljava/lang/Object;)Ljava/nio/ByteBuffer;
         2: .line 240
            invokestatic java.lang.System.currentTimeMillis:()J
         3: .line 241
            invokestatic org.apache.cassandra.utils.FBUtilities.nowInSeconds:()I
         4: .line 238
            invokestatic org.apache.cassandra.db.partitions.PartitionUpdate.fullPartitionDelete:(Lorg/apache/cassandra/config/CFMetaData;Ljava/nio/ByteBuffer;JI)Lorg/apache/cassandra/db/partitions/PartitionUpdate;
            invokespecial org.apache.cassandra.db.Mutation.<init>:(Lorg/apache/cassandra/db/partitions/PartitionUpdate;)V
            astore 1 /* mutation */
        start local 1 // org.apache.cassandra.db.Mutation mutation
         5: .line 242
            aload 1 /* mutation */
            invokevirtual org.apache.cassandra.db.Mutation.applyUnsafe:()V
         6: .line 243
            return
        end local 1 // org.apache.cassandra.db.Mutation mutation
        end local 0 // java.util.UUID hostId
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    7     0    hostId  Ljava/util/UUID;
            5    7     1  mutation  Lorg/apache/cassandra/db/Mutation;
    MethodParameters:
        Name  Flags
      hostId  

  private static void lambda$0(java.util.Collection, org.apache.cassandra.io.sstable.format.SSTableReader);
    descriptor: (Ljava/util/Collection;Lorg/apache/cassandra/io/sstable/format/SSTableReader;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 1 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
         0: .line 107
            aload 0
            aload 1 /* sstable */
            getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
            invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
            return
        end local 1 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     1  sstable  Lorg/apache/cassandra/io/sstable/format/SSTableReader;

  private void lambda$1(java.nio.ByteBuffer, org.apache.cassandra.cql3.UntypedResultSet$Row);
    descriptor: (Ljava/nio/ByteBuffer;Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // org.apache.cassandra.hints.LegacyHintsMigrator this
        start local 2 // org.apache.cassandra.cql3.UntypedResultSet$Row row
         0: .line 129
            aload 0 /* this */
            aload 2 /* row */
            ldc "target_id"
            invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getUUID:(Ljava/lang/String;)Ljava/util/UUID;
            aload 1
            invokevirtual org.apache.cassandra.hints.LegacyHintsMigrator.migrateLegacyHints:(Ljava/util/UUID;Ljava/nio/ByteBuffer;)V
            return
        end local 2 // org.apache.cassandra.cql3.UntypedResultSet$Row row
        end local 0 // org.apache.cassandra.hints.LegacyHintsMigrator this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/hints/LegacyHintsMigrator;
            0    1     2   row  Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
}
SourceFile: "LegacyHintsMigrator.java"
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  public Row = org.apache.cassandra.cql3.UntypedResultSet$Row of org.apache.cassandra.cql3.UntypedResultSet
  public MutationSerializer = org.apache.cassandra.db.Mutation$MutationSerializer of org.apache.cassandra.db.Mutation
  final Session = org.apache.cassandra.hints.HintsWriter$Session of org.apache.cassandra.hints.HintsWriter
/

org.apache.cassandra/ cassandra-all/ 3.11.5/ org/apache/cassandra/hints/LegacyHintsMigrator.class
