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.
  • 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 class org.apache.cassandra.utils.NativeSSTableLoaderClient extends org.apache.cassandra.io.sstable.SSTableLoader$Client
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.cassandra.utils.NativeSSTableLoaderClient
  super_class: org.apache.cassandra.io.sstable.SSTableLoader$Client
{
  protected final java.util.Map<java.lang.String, org.apache.cassandra.config.CFMetaData> tables;
    descriptor: Ljava/util/Map;
    flags: (0x0014) ACC_PROTECTED, ACC_FINAL
    Signature: Ljava/util/Map<Ljava/lang/String;Lorg/apache/cassandra/config/CFMetaData;>;

  private final java.util.Collection<java.net.InetAddress> hosts;
    descriptor: Ljava/util/Collection;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Collection<Ljava/net/InetAddress;>;

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

  private final com.datastax.driver.core.AuthProvider authProvider;
    descriptor: Lcom/datastax/driver/core/AuthProvider;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final com.datastax.driver.core.SSLOptions sslOptions;
    descriptor: Lcom/datastax/driver/core/SSLOptions;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  public void <init>(java.util.Collection<java.net.InetAddress>, int, java.lang.String, java.lang.String, com.datastax.driver.core.SSLOptions);
    descriptor: (Ljava/util/Collection;ILjava/lang/String;Ljava/lang/String;Lcom/datastax/driver/core/SSLOptions;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=6, args_size=6
        start local 0 // org.apache.cassandra.utils.NativeSSTableLoaderClient this
        start local 1 // java.util.Collection hosts
        start local 2 // int port
        start local 3 // java.lang.String username
        start local 4 // java.lang.String password
        start local 5 // com.datastax.driver.core.SSLOptions sslOptions
         0: .line 52
            aload 0 /* this */
            aload 1 /* hosts */
            iload 2 /* port */
            new com.datastax.driver.core.PlainTextAuthProvider
            dup
            aload 3 /* username */
            aload 4 /* password */
            invokespecial com.datastax.driver.core.PlainTextAuthProvider.<init>:(Ljava/lang/String;Ljava/lang/String;)V
            aload 5 /* sslOptions */
            invokespecial org.apache.cassandra.utils.NativeSSTableLoaderClient.<init>:(Ljava/util/Collection;ILcom/datastax/driver/core/AuthProvider;Lcom/datastax/driver/core/SSLOptions;)V
         1: .line 53
            return
        end local 5 // com.datastax.driver.core.SSLOptions sslOptions
        end local 4 // java.lang.String password
        end local 3 // java.lang.String username
        end local 2 // int port
        end local 1 // java.util.Collection hosts
        end local 0 // org.apache.cassandra.utils.NativeSSTableLoaderClient this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    2     0        this  Lorg/apache/cassandra/utils/NativeSSTableLoaderClient;
            0    2     1       hosts  Ljava/util/Collection<Ljava/net/InetAddress;>;
            0    2     2        port  I
            0    2     3    username  Ljava/lang/String;
            0    2     4    password  Ljava/lang/String;
            0    2     5  sslOptions  Lcom/datastax/driver/core/SSLOptions;
    Signature: (Ljava/util/Collection<Ljava/net/InetAddress;>;ILjava/lang/String;Ljava/lang/String;Lcom/datastax/driver/core/SSLOptions;)V
    MethodParameters:
            Name  Flags
      hosts       
      port        
      username    
      password    
      sslOptions  

  public void <init>(java.util.Collection<java.net.InetAddress>, int, com.datastax.driver.core.AuthProvider, com.datastax.driver.core.SSLOptions);
    descriptor: (Ljava/util/Collection;ILcom/datastax/driver/core/AuthProvider;Lcom/datastax/driver/core/SSLOptions;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=5, args_size=5
        start local 0 // org.apache.cassandra.utils.NativeSSTableLoaderClient this
        start local 1 // java.util.Collection hosts
        start local 2 // int port
        start local 3 // com.datastax.driver.core.AuthProvider authProvider
        start local 4 // com.datastax.driver.core.SSLOptions sslOptions
         0: .line 57
            aload 0 /* this */
            invokespecial org.apache.cassandra.io.sstable.SSTableLoader$Client.<init>:()V
         1: .line 58
            aload 0 /* this */
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            putfield org.apache.cassandra.utils.NativeSSTableLoaderClient.tables:Ljava/util/Map;
         2: .line 59
            aload 0 /* this */
            aload 1 /* hosts */
            putfield org.apache.cassandra.utils.NativeSSTableLoaderClient.hosts:Ljava/util/Collection;
         3: .line 60
            aload 0 /* this */
            iload 2 /* port */
            putfield org.apache.cassandra.utils.NativeSSTableLoaderClient.port:I
         4: .line 61
            aload 0 /* this */
            aload 3 /* authProvider */
            putfield org.apache.cassandra.utils.NativeSSTableLoaderClient.authProvider:Lcom/datastax/driver/core/AuthProvider;
         5: .line 62
            aload 0 /* this */
            aload 4 /* sslOptions */
            putfield org.apache.cassandra.utils.NativeSSTableLoaderClient.sslOptions:Lcom/datastax/driver/core/SSLOptions;
         6: .line 63
            return
        end local 4 // com.datastax.driver.core.SSLOptions sslOptions
        end local 3 // com.datastax.driver.core.AuthProvider authProvider
        end local 2 // int port
        end local 1 // java.util.Collection hosts
        end local 0 // org.apache.cassandra.utils.NativeSSTableLoaderClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    7     0          this  Lorg/apache/cassandra/utils/NativeSSTableLoaderClient;
            0    7     1         hosts  Ljava/util/Collection<Ljava/net/InetAddress;>;
            0    7     2          port  I
            0    7     3  authProvider  Lcom/datastax/driver/core/AuthProvider;
            0    7     4    sslOptions  Lcom/datastax/driver/core/SSLOptions;
    Signature: (Ljava/util/Collection<Ljava/net/InetAddress;>;ILcom/datastax/driver/core/AuthProvider;Lcom/datastax/driver/core/SSLOptions;)V
    MethodParameters:
              Name  Flags
      hosts         
      port          
      authProvider  
      sslOptions    

  public void init(java.lang.String);
    descriptor: (Ljava/lang/String;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=17, args_size=2
        start local 0 // org.apache.cassandra.utils.NativeSSTableLoaderClient this
        start local 1 // java.lang.String keyspace
         0: .line 67
            invokestatic com.datastax.driver.core.Cluster.builder:()Lcom/datastax/driver/core/Cluster$Builder;
            aload 0 /* this */
            getfield org.apache.cassandra.utils.NativeSSTableLoaderClient.hosts:Ljava/util/Collection;
            invokevirtual com.datastax.driver.core.Cluster$Builder.addContactPoints:(Ljava/util/Collection;)Lcom/datastax/driver/core/Cluster$Builder;
            aload 0 /* this */
            getfield org.apache.cassandra.utils.NativeSSTableLoaderClient.port:I
            invokevirtual com.datastax.driver.core.Cluster$Builder.withPort:(I)Lcom/datastax/driver/core/Cluster$Builder;
            astore 2 /* builder */
        start local 2 // com.datastax.driver.core.Cluster$Builder builder
         1: .line 68
            aload 0 /* this */
            getfield org.apache.cassandra.utils.NativeSSTableLoaderClient.sslOptions:Lcom/datastax/driver/core/SSLOptions;
            ifnull 3
         2: .line 69
            aload 2 /* builder */
            aload 0 /* this */
            getfield org.apache.cassandra.utils.NativeSSTableLoaderClient.sslOptions:Lcom/datastax/driver/core/SSLOptions;
            invokevirtual com.datastax.driver.core.Cluster$Builder.withSSL:(Lcom/datastax/driver/core/SSLOptions;)Lcom/datastax/driver/core/Cluster$Builder;
            pop
         3: .line 70
      StackMap locals: com.datastax.driver.core.Cluster$Builder
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.utils.NativeSSTableLoaderClient.authProvider:Lcom/datastax/driver/core/AuthProvider;
            ifnull 5
         4: .line 71
            aload 2 /* builder */
            aload 0 /* this */
            getfield org.apache.cassandra.utils.NativeSSTableLoaderClient.authProvider:Lcom/datastax/driver/core/AuthProvider;
            invokevirtual com.datastax.driver.core.Cluster$Builder.withAuthProvider:(Lcom/datastax/driver/core/AuthProvider;)Lcom/datastax/driver/core/Cluster$Builder;
            astore 2 /* builder */
         5: .line 73
      StackMap locals:
      StackMap stack:
            aconst_null
            astore 3
            aconst_null
            astore 4
         6: aload 2 /* builder */
            invokevirtual com.datastax.driver.core.Cluster$Builder.build:()Lcom/datastax/driver/core/Cluster;
            astore 5 /* cluster */
        start local 5 // com.datastax.driver.core.Cluster cluster
         7: aload 5 /* cluster */
            invokevirtual com.datastax.driver.core.Cluster.connect:()Lcom/datastax/driver/core/Session;
            astore 6 /* session */
        start local 6 // com.datastax.driver.core.Session session
         8: .line 76
            aload 5 /* cluster */
            invokevirtual com.datastax.driver.core.Cluster.getMetadata:()Lcom/datastax/driver/core/Metadata;
            astore 7 /* metadata */
        start local 7 // com.datastax.driver.core.Metadata metadata
         9: .line 78
            aload 7 /* metadata */
            invokevirtual com.datastax.driver.core.Metadata.getTokenRanges:()Ljava/util/Set;
            astore 8 /* tokenRanges */
        start local 8 // java.util.Set tokenRanges
        10: .line 80
            aload 7 /* metadata */
            invokevirtual com.datastax.driver.core.Metadata.getPartitioner:()Ljava/lang/String;
            invokestatic org.apache.cassandra.utils.FBUtilities.newPartitioner:(Ljava/lang/String;)Lorg/apache/cassandra/dht/IPartitioner;
            astore 9 /* partitioner */
        start local 9 // org.apache.cassandra.dht.IPartitioner partitioner
        11: .line 81
            aload 9 /* partitioner */
            invokeinterface org.apache.cassandra.dht.IPartitioner.getTokenFactory:()Lorg/apache/cassandra/dht/Token$TokenFactory;
            astore 10 /* tokenFactory */
        start local 10 // org.apache.cassandra.dht.Token$TokenFactory tokenFactory
        12: .line 83
            aload 8 /* tokenRanges */
            invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
            astore 12
            goto 22
      StackMap locals: org.apache.cassandra.utils.NativeSSTableLoaderClient java.lang.String com.datastax.driver.core.Cluster$Builder java.lang.Throwable java.lang.Throwable com.datastax.driver.core.Cluster com.datastax.driver.core.Session com.datastax.driver.core.Metadata java.util.Set org.apache.cassandra.dht.IPartitioner org.apache.cassandra.dht.Token$TokenFactory top java.util.Iterator
      StackMap stack:
        13: aload 12
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast com.datastax.driver.core.TokenRange
            astore 11 /* tokenRange */
        start local 11 // com.datastax.driver.core.TokenRange tokenRange
        14: .line 85
            aload 7 /* metadata */
            aload 1 /* keyspace */
            invokestatic com.datastax.driver.core.Metadata.quote:(Ljava/lang/String;)Ljava/lang/String;
            aload 11 /* tokenRange */
            invokevirtual com.datastax.driver.core.Metadata.getReplicas:(Ljava/lang/String;Lcom/datastax/driver/core/TokenRange;)Ljava/util/Set;
            astore 13 /* endpoints */
        start local 13 // java.util.Set endpoints
        15: .line 86
            new org.apache.cassandra.dht.Range
            dup
            aload 10 /* tokenFactory */
            aload 11 /* tokenRange */
            invokevirtual com.datastax.driver.core.TokenRange.getStart:()Lcom/datastax/driver/core/Token;
            invokevirtual com.datastax.driver.core.Token.getValue:()Ljava/lang/Object;
            invokevirtual java.lang.Object.toString:()Ljava/lang/String;
            invokevirtual org.apache.cassandra.dht.Token$TokenFactory.fromString:(Ljava/lang/String;)Lorg/apache/cassandra/dht/Token;
        16: .line 87
            aload 10 /* tokenFactory */
            aload 11 /* tokenRange */
            invokevirtual com.datastax.driver.core.TokenRange.getEnd:()Lcom/datastax/driver/core/Token;
            invokevirtual com.datastax.driver.core.Token.getValue:()Ljava/lang/Object;
            invokevirtual java.lang.Object.toString:()Ljava/lang/String;
            invokevirtual org.apache.cassandra.dht.Token$TokenFactory.fromString:(Ljava/lang/String;)Lorg/apache/cassandra/dht/Token;
        17: .line 86
            invokespecial org.apache.cassandra.dht.Range.<init>:(Lorg/apache/cassandra/dht/RingPosition;Lorg/apache/cassandra/dht/RingPosition;)V
            astore 14 /* range */
        start local 14 // org.apache.cassandra.dht.Range range
        18: .line 88
            aload 13 /* endpoints */
            invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
            astore 16
            goto 21
      StackMap locals: org.apache.cassandra.utils.NativeSSTableLoaderClient java.lang.String com.datastax.driver.core.Cluster$Builder java.lang.Throwable java.lang.Throwable com.datastax.driver.core.Cluster com.datastax.driver.core.Session com.datastax.driver.core.Metadata java.util.Set org.apache.cassandra.dht.IPartitioner org.apache.cassandra.dht.Token$TokenFactory com.datastax.driver.core.TokenRange java.util.Iterator java.util.Set org.apache.cassandra.dht.Range top java.util.Iterator
      StackMap stack:
        19: aload 16
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast com.datastax.driver.core.Host
            astore 15 /* endpoint */
        start local 15 // com.datastax.driver.core.Host endpoint
        20: .line 89
            aload 0 /* this */
            aload 14 /* range */
            aload 15 /* endpoint */
            invokevirtual com.datastax.driver.core.Host.getBroadcastAddress:()Ljava/net/InetAddress;
            invokevirtual org.apache.cassandra.utils.NativeSSTableLoaderClient.addRangeForEndpoint:(Lorg/apache/cassandra/dht/Range;Ljava/net/InetAddress;)V
        end local 15 // com.datastax.driver.core.Host endpoint
        21: .line 88
      StackMap locals:
      StackMap stack:
            aload 16
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 19
        end local 14 // org.apache.cassandra.dht.Range range
        end local 13 // java.util.Set endpoints
        end local 11 // com.datastax.driver.core.TokenRange tokenRange
        22: .line 83
      StackMap locals: org.apache.cassandra.utils.NativeSSTableLoaderClient java.lang.String com.datastax.driver.core.Cluster$Builder java.lang.Throwable java.lang.Throwable com.datastax.driver.core.Cluster com.datastax.driver.core.Session com.datastax.driver.core.Metadata java.util.Set org.apache.cassandra.dht.IPartitioner org.apache.cassandra.dht.Token$TokenFactory top java.util.Iterator
      StackMap stack:
            aload 12
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 13
        23: .line 92
            aload 1 /* keyspace */
            aload 6 /* session */
            invokestatic org.apache.cassandra.utils.NativeSSTableLoaderClient.fetchTypes:(Ljava/lang/String;Lcom/datastax/driver/core/Session;)Lorg/apache/cassandra/schema/Types;
            astore 11 /* types */
        start local 11 // org.apache.cassandra.schema.Types types
        24: .line 94
            aload 0 /* this */
            getfield org.apache.cassandra.utils.NativeSSTableLoaderClient.tables:Ljava/util/Map;
            aload 1 /* keyspace */
            aload 6 /* session */
            aload 9 /* partitioner */
            aload 11 /* types */
            invokestatic org.apache.cassandra.utils.NativeSSTableLoaderClient.fetchTables:(Ljava/lang/String;Lcom/datastax/driver/core/Session;Lorg/apache/cassandra/dht/IPartitioner;Lorg/apache/cassandra/schema/Types;)Ljava/util/Map;
            invokeinterface java.util.Map.putAll:(Ljava/util/Map;)V
        25: .line 96
            aload 0 /* this */
            getfield org.apache.cassandra.utils.NativeSSTableLoaderClient.tables:Ljava/util/Map;
            aload 1 /* keyspace */
            aload 6 /* session */
            aload 9 /* partitioner */
            aload 11 /* types */
            invokestatic org.apache.cassandra.utils.NativeSSTableLoaderClient.fetchViews:(Ljava/lang/String;Lcom/datastax/driver/core/Session;Lorg/apache/cassandra/dht/IPartitioner;Lorg/apache/cassandra/schema/Types;)Ljava/util/Map;
            invokeinterface java.util.Map.putAll:(Ljava/util/Map;)V
        end local 11 // org.apache.cassandra.schema.Types types
        end local 10 // org.apache.cassandra.dht.Token$TokenFactory tokenFactory
        end local 9 // org.apache.cassandra.dht.IPartitioner partitioner
        end local 8 // java.util.Set tokenRanges
        end local 7 // com.datastax.driver.core.Metadata metadata
        26: .line 97
            aload 6 /* session */
            ifnull 29
            aload 6 /* session */
            invokeinterface com.datastax.driver.core.Session.close:()V
            goto 29
      StackMap locals: org.apache.cassandra.utils.NativeSSTableLoaderClient java.lang.String com.datastax.driver.core.Cluster$Builder java.lang.Throwable java.lang.Throwable com.datastax.driver.core.Cluster com.datastax.driver.core.Session
      StackMap stack: java.lang.Throwable
        27: astore 3
            aload 6 /* session */
            ifnull 28
            aload 6 /* session */
            invokeinterface com.datastax.driver.core.Session.close:()V
        end local 6 // com.datastax.driver.core.Session session
      StackMap locals:
      StackMap stack:
        28: aload 3
            athrow
      StackMap locals:
      StackMap stack:
        29: aload 5 /* cluster */
            ifnull 37
            aload 5 /* cluster */
            invokevirtual com.datastax.driver.core.Cluster.close:()V
            goto 37
      StackMap locals:
      StackMap stack: java.lang.Throwable
        30: astore 4
            aload 3
            ifnonnull 31
            aload 4
            astore 3
            goto 32
      StackMap locals:
      StackMap stack:
        31: aload 3
            aload 4
            if_acmpeq 32
            aload 3
            aload 4
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        32: aload 5 /* cluster */
            ifnull 33
            aload 5 /* cluster */
            invokevirtual com.datastax.driver.core.Cluster.close:()V
        end local 5 // com.datastax.driver.core.Cluster cluster
      StackMap locals:
      StackMap stack:
        33: aload 3
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        34: astore 4
            aload 3
            ifnonnull 35
            aload 4
            astore 3
            goto 36
      StackMap locals:
      StackMap stack:
        35: aload 3
            aload 4
            if_acmpeq 36
            aload 3
            aload 4
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        36: aload 3
            athrow
        37: .line 98
      StackMap locals:
      StackMap stack:
            return
        end local 2 // com.datastax.driver.core.Cluster$Builder builder
        end local 1 // java.lang.String keyspace
        end local 0 // org.apache.cassandra.utils.NativeSSTableLoaderClient this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0   38     0          this  Lorg/apache/cassandra/utils/NativeSSTableLoaderClient;
            0   38     1      keyspace  Ljava/lang/String;
            1   38     2       builder  Lcom/datastax/driver/core/Cluster$Builder;
            7   33     5       cluster  Lcom/datastax/driver/core/Cluster;
            8   28     6       session  Lcom/datastax/driver/core/Session;
            9   26     7      metadata  Lcom/datastax/driver/core/Metadata;
           10   26     8   tokenRanges  Ljava/util/Set<Lcom/datastax/driver/core/TokenRange;>;
           11   26     9   partitioner  Lorg/apache/cassandra/dht/IPartitioner;
           12   26    10  tokenFactory  Lorg/apache/cassandra/dht/Token$TokenFactory;
           14   22    11    tokenRange  Lcom/datastax/driver/core/TokenRange;
           15   22    13     endpoints  Ljava/util/Set<Lcom/datastax/driver/core/Host;>;
           18   22    14         range  Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;
           20   21    15      endpoint  Lcom/datastax/driver/core/Host;
           24   26    11         types  Lorg/apache/cassandra/schema/Types;
      Exception table:
        from    to  target  type
           8    26      27  any
           7    29      30  any
           6    34      34  any
    MethodParameters:
          Name  Flags
      keyspace  

  public org.apache.cassandra.config.CFMetaData getTableMetadata(java.lang.String);
    descriptor: (Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.apache.cassandra.utils.NativeSSTableLoaderClient this
        start local 1 // java.lang.String tableName
         0: .line 102
            aload 0 /* this */
            getfield org.apache.cassandra.utils.NativeSSTableLoaderClient.tables:Ljava/util/Map;
            aload 1 /* tableName */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.apache.cassandra.config.CFMetaData
            areturn
        end local 1 // java.lang.String tableName
        end local 0 // org.apache.cassandra.utils.NativeSSTableLoaderClient this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    1     0       this  Lorg/apache/cassandra/utils/NativeSSTableLoaderClient;
            0    1     1  tableName  Ljava/lang/String;
    MethodParameters:
           Name  Flags
      tableName  

  public void setTableMetadata(org.apache.cassandra.config.CFMetaData);
    descriptor: (Lorg/apache/cassandra/config/CFMetaData;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.apache.cassandra.utils.NativeSSTableLoaderClient this
        start local 1 // org.apache.cassandra.config.CFMetaData cfm
         0: .line 108
            aload 0 /* this */
            getfield org.apache.cassandra.utils.NativeSSTableLoaderClient.tables:Ljava/util/Map;
            aload 1 /* cfm */
            getfield org.apache.cassandra.config.CFMetaData.cfName:Ljava/lang/String;
            aload 1 /* cfm */
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         1: .line 109
            return
        end local 1 // org.apache.cassandra.config.CFMetaData cfm
        end local 0 // org.apache.cassandra.utils.NativeSSTableLoaderClient this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/apache/cassandra/utils/NativeSSTableLoaderClient;
            0    2     1   cfm  Lorg/apache/cassandra/config/CFMetaData;
    MethodParameters:
      Name  Flags
      cfm   

  private static org.apache.cassandra.schema.Types fetchTypes(java.lang.String, com.datastax.driver.core.Session);
    descriptor: (Ljava/lang/String;Lcom/datastax/driver/core/Session;)Lorg/apache/cassandra/schema/Types;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=6, locals=9, args_size=2
        start local 0 // java.lang.String keyspace
        start local 1 // com.datastax.driver.core.Session session
         0: .line 113
            ldc "SELECT * FROM %s.%s WHERE keyspace_name = ?"
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
            ldc "system_schema"
            aastore
            dup
            iconst_1
            ldc "types"
            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
         1: .line 115
            aload 0 /* keyspace */
            invokestatic org.apache.cassandra.schema.Types.rawBuilder:(Ljava/lang/String;)Lorg/apache/cassandra/schema/Types$RawBuilder;
            astore 3 /* types */
        start local 3 // org.apache.cassandra.schema.Types$RawBuilder types
         2: .line 116
            aload 1 /* session */
            aload 2 /* query */
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* keyspace */
            aastore
            invokeinterface com.datastax.driver.core.Session.execute:(Ljava/lang/String;[Ljava/lang/Object;)Lcom/datastax/driver/core/ResultSet;
            invokeinterface com.datastax.driver.core.ResultSet.iterator:()Ljava/util/Iterator;
            astore 5
            goto 8
      StackMap locals: java.lang.String com.datastax.driver.core.Session java.lang.String org.apache.cassandra.schema.Types$RawBuilder top java.util.Iterator
      StackMap stack:
         3: aload 5
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast com.datastax.driver.core.Row
            astore 4 /* row */
        start local 4 // com.datastax.driver.core.Row row
         4: .line 118
            aload 4 /* row */
            ldc "type_name"
            invokeinterface com.datastax.driver.core.Row.getString:(Ljava/lang/String;)Ljava/lang/String;
            astore 6 /* name */
        start local 6 // java.lang.String name
         5: .line 119
            aload 4 /* row */
            ldc "field_names"
            ldc Ljava/lang/String;
            invokeinterface com.datastax.driver.core.Row.getList:(Ljava/lang/String;Ljava/lang/Class;)Ljava/util/List;
            astore 7 /* fieldNames */
        start local 7 // java.util.List fieldNames
         6: .line 120
            aload 4 /* row */
            ldc "field_types"
            ldc Ljava/lang/String;
            invokeinterface com.datastax.driver.core.Row.getList:(Ljava/lang/String;Ljava/lang/Class;)Ljava/util/List;
            astore 8 /* fieldTypes */
        start local 8 // java.util.List fieldTypes
         7: .line 121
            aload 3 /* types */
            aload 6 /* name */
            aload 7 /* fieldNames */
            aload 8 /* fieldTypes */
            invokevirtual org.apache.cassandra.schema.Types$RawBuilder.add:(Ljava/lang/String;Ljava/util/List;Ljava/util/List;)V
        end local 8 // java.util.List fieldTypes
        end local 7 // java.util.List fieldNames
        end local 6 // java.lang.String name
        end local 4 // com.datastax.driver.core.Row row
         8: .line 116
      StackMap locals:
      StackMap stack:
            aload 5
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 3
         9: .line 123
            aload 3 /* types */
            invokevirtual org.apache.cassandra.schema.Types$RawBuilder.build:()Lorg/apache/cassandra/schema/Types;
            areturn
        end local 3 // org.apache.cassandra.schema.Types$RawBuilder types
        end local 2 // java.lang.String query
        end local 1 // com.datastax.driver.core.Session session
        end local 0 // java.lang.String keyspace
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   10     0    keyspace  Ljava/lang/String;
            0   10     1     session  Lcom/datastax/driver/core/Session;
            1   10     2       query  Ljava/lang/String;
            2   10     3       types  Lorg/apache/cassandra/schema/Types$RawBuilder;
            4    8     4         row  Lcom/datastax/driver/core/Row;
            5    8     6        name  Ljava/lang/String;
            6    8     7  fieldNames  Ljava/util/List<Ljava/lang/String;>;
            7    8     8  fieldTypes  Ljava/util/List<Ljava/lang/String;>;
    MethodParameters:
          Name  Flags
      keyspace  
      session   

  private static java.util.Map<java.lang.String, org.apache.cassandra.config.CFMetaData> fetchTables(java.lang.String, com.datastax.driver.core.Session, org.apache.cassandra.dht.IPartitioner, org.apache.cassandra.schema.Types);
    descriptor: (Ljava/lang/String;Lcom/datastax/driver/core/Session;Lorg/apache/cassandra/dht/IPartitioner;Lorg/apache/cassandra/schema/Types;)Ljava/util/Map;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=9, locals=9, args_size=4
        start local 0 // java.lang.String keyspace
        start local 1 // com.datastax.driver.core.Session session
        start local 2 // org.apache.cassandra.dht.IPartitioner partitioner
        start local 3 // org.apache.cassandra.schema.Types types
         0: .line 137
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 4 /* tables */
        start local 4 // java.util.Map tables
         1: .line 138
            ldc "SELECT * FROM %s.%s WHERE keyspace_name = ?"
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
            ldc "system_schema"
            aastore
            dup
            iconst_1
            ldc "tables"
            aastore
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            astore 5 /* query */
        start local 5 // java.lang.String query
         2: .line 140
            aload 1 /* session */
            aload 5 /* query */
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* keyspace */
            aastore
            invokeinterface com.datastax.driver.core.Session.execute:(Ljava/lang/String;[Ljava/lang/Object;)Lcom/datastax/driver/core/ResultSet;
            invokeinterface com.datastax.driver.core.ResultSet.iterator:()Ljava/util/Iterator;
            astore 7
            goto 6
      StackMap locals: java.lang.String com.datastax.driver.core.Session org.apache.cassandra.dht.IPartitioner org.apache.cassandra.schema.Types java.util.Map java.lang.String top java.util.Iterator
      StackMap stack:
         3: aload 7
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast com.datastax.driver.core.Row
            astore 6 /* row */
        start local 6 // com.datastax.driver.core.Row row
         4: .line 142
            aload 6 /* row */
            ldc "table_name"
            invokeinterface com.datastax.driver.core.Row.getString:(Ljava/lang/String;)Ljava/lang/String;
            astore 8 /* name */
        start local 8 // java.lang.String name
         5: .line 143
            aload 4 /* tables */
            aload 8 /* name */
            aload 0 /* keyspace */
            aload 1 /* session */
            aload 2 /* partitioner */
            iconst_0
            aload 6 /* row */
            aload 8 /* name */
            aload 3 /* types */
            invokestatic org.apache.cassandra.utils.NativeSSTableLoaderClient.createTableMetadata:(Ljava/lang/String;Lcom/datastax/driver/core/Session;Lorg/apache/cassandra/dht/IPartitioner;ZLcom/datastax/driver/core/Row;Ljava/lang/String;Lorg/apache/cassandra/schema/Types;)Lorg/apache/cassandra/config/CFMetaData;
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        end local 8 // java.lang.String name
        end local 6 // com.datastax.driver.core.Row row
         6: .line 140
      StackMap locals:
      StackMap stack:
            aload 7
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 3
         7: .line 146
            aload 4 /* tables */
            areturn
        end local 5 // java.lang.String query
        end local 4 // java.util.Map tables
        end local 3 // org.apache.cassandra.schema.Types types
        end local 2 // org.apache.cassandra.dht.IPartitioner partitioner
        end local 1 // com.datastax.driver.core.Session session
        end local 0 // java.lang.String keyspace
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    8     0     keyspace  Ljava/lang/String;
            0    8     1      session  Lcom/datastax/driver/core/Session;
            0    8     2  partitioner  Lorg/apache/cassandra/dht/IPartitioner;
            0    8     3        types  Lorg/apache/cassandra/schema/Types;
            1    8     4       tables  Ljava/util/Map<Ljava/lang/String;Lorg/apache/cassandra/config/CFMetaData;>;
            2    8     5        query  Ljava/lang/String;
            4    6     6          row  Lcom/datastax/driver/core/Row;
            5    6     8         name  Ljava/lang/String;
    Signature: (Ljava/lang/String;Lcom/datastax/driver/core/Session;Lorg/apache/cassandra/dht/IPartitioner;Lorg/apache/cassandra/schema/Types;)Ljava/util/Map<Ljava/lang/String;Lorg/apache/cassandra/config/CFMetaData;>;
    MethodParameters:
             Name  Flags
      keyspace     
      session      
      partitioner  
      types        

  private static java.util.Map<java.lang.String, org.apache.cassandra.config.CFMetaData> fetchViews(java.lang.String, com.datastax.driver.core.Session, org.apache.cassandra.dht.IPartitioner, org.apache.cassandra.schema.Types);
    descriptor: (Ljava/lang/String;Lcom/datastax/driver/core/Session;Lorg/apache/cassandra/dht/IPartitioner;Lorg/apache/cassandra/schema/Types;)Ljava/util/Map;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=9, locals=9, args_size=4
        start local 0 // java.lang.String keyspace
        start local 1 // com.datastax.driver.core.Session session
        start local 2 // org.apache.cassandra.dht.IPartitioner partitioner
        start local 3 // org.apache.cassandra.schema.Types types
         0: .line 154
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 4 /* tables */
        start local 4 // java.util.Map tables
         1: .line 155
            ldc "SELECT * FROM %s.%s WHERE keyspace_name = ?"
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
            ldc "system_schema"
            aastore
            dup
            iconst_1
            ldc "views"
            aastore
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            astore 5 /* query */
        start local 5 // java.lang.String query
         2: .line 157
            aload 1 /* session */
            aload 5 /* query */
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* keyspace */
            aastore
            invokeinterface com.datastax.driver.core.Session.execute:(Ljava/lang/String;[Ljava/lang/Object;)Lcom/datastax/driver/core/ResultSet;
            invokeinterface com.datastax.driver.core.ResultSet.iterator:()Ljava/util/Iterator;
            astore 7
            goto 6
      StackMap locals: java.lang.String com.datastax.driver.core.Session org.apache.cassandra.dht.IPartitioner org.apache.cassandra.schema.Types java.util.Map java.lang.String top java.util.Iterator
      StackMap stack:
         3: aload 7
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast com.datastax.driver.core.Row
            astore 6 /* row */
        start local 6 // com.datastax.driver.core.Row row
         4: .line 159
            aload 6 /* row */
            ldc "view_name"
            invokeinterface com.datastax.driver.core.Row.getString:(Ljava/lang/String;)Ljava/lang/String;
            astore 8 /* name */
        start local 8 // java.lang.String name
         5: .line 160
            aload 4 /* tables */
            aload 8 /* name */
            aload 0 /* keyspace */
            aload 1 /* session */
            aload 2 /* partitioner */
            iconst_1
            aload 6 /* row */
            aload 8 /* name */
            aload 3 /* types */
            invokestatic org.apache.cassandra.utils.NativeSSTableLoaderClient.createTableMetadata:(Ljava/lang/String;Lcom/datastax/driver/core/Session;Lorg/apache/cassandra/dht/IPartitioner;ZLcom/datastax/driver/core/Row;Ljava/lang/String;Lorg/apache/cassandra/schema/Types;)Lorg/apache/cassandra/config/CFMetaData;
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        end local 8 // java.lang.String name
        end local 6 // com.datastax.driver.core.Row row
         6: .line 157
      StackMap locals:
      StackMap stack:
            aload 7
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 3
         7: .line 163
            aload 4 /* tables */
            areturn
        end local 5 // java.lang.String query
        end local 4 // java.util.Map tables
        end local 3 // org.apache.cassandra.schema.Types types
        end local 2 // org.apache.cassandra.dht.IPartitioner partitioner
        end local 1 // com.datastax.driver.core.Session session
        end local 0 // java.lang.String keyspace
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    8     0     keyspace  Ljava/lang/String;
            0    8     1      session  Lcom/datastax/driver/core/Session;
            0    8     2  partitioner  Lorg/apache/cassandra/dht/IPartitioner;
            0    8     3        types  Lorg/apache/cassandra/schema/Types;
            1    8     4       tables  Ljava/util/Map<Ljava/lang/String;Lorg/apache/cassandra/config/CFMetaData;>;
            2    8     5        query  Ljava/lang/String;
            4    6     6          row  Lcom/datastax/driver/core/Row;
            5    6     8         name  Ljava/lang/String;
    Signature: (Ljava/lang/String;Lcom/datastax/driver/core/Session;Lorg/apache/cassandra/dht/IPartitioner;Lorg/apache/cassandra/schema/Types;)Ljava/util/Map<Ljava/lang/String;Lorg/apache/cassandra/config/CFMetaData;>;
    MethodParameters:
             Name  Flags
      keyspace     
      session      
      partitioner  
      types        

  private static org.apache.cassandra.config.CFMetaData createTableMetadata(java.lang.String, com.datastax.driver.core.Session, org.apache.cassandra.dht.IPartitioner, boolean, com.datastax.driver.core.Row, java.lang.String, org.apache.cassandra.schema.Types);
    descriptor: (Ljava/lang/String;Lcom/datastax/driver/core/Session;Lorg/apache/cassandra/dht/IPartitioner;ZLcom/datastax/driver/core/Row;Ljava/lang/String;Lorg/apache/cassandra/schema/Types;)Lorg/apache/cassandra/config/CFMetaData;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=10, locals=21, args_size=7
        start local 0 // java.lang.String keyspace
        start local 1 // com.datastax.driver.core.Session session
        start local 2 // org.apache.cassandra.dht.IPartitioner partitioner
        start local 3 // boolean isView
        start local 4 // com.datastax.driver.core.Row row
        start local 5 // java.lang.String name
        start local 6 // org.apache.cassandra.schema.Types types
         0: .line 174
            aload 4 /* row */
            ldc "id"
            invokeinterface com.datastax.driver.core.Row.getUUID:(Ljava/lang/String;)Ljava/util/UUID;
            astore 7 /* id */
        start local 7 // java.util.UUID id
         1: .line 175
            iload 3 /* isView */
            ifeq 2
            invokestatic java.util.Collections.emptySet:()Ljava/util/Set;
            goto 3
      StackMap locals: java.util.UUID
      StackMap stack:
         2: aload 4 /* row */
            ldc "flags"
            ldc Ljava/lang/String;
            invokeinterface com.datastax.driver.core.Row.getSet:(Ljava/lang/String;Ljava/lang/Class;)Ljava/util/Set;
            invokestatic org.apache.cassandra.config.CFMetaData.flagsFromStrings:(Ljava/util/Set;)Ljava/util/Set;
      StackMap locals:
      StackMap stack: java.util.Set
         3: astore 8 /* flags */
        start local 8 // java.util.Set flags
         4: .line 177
            aload 8 /* flags */
            getstatic org.apache.cassandra.config.CFMetaData$Flag.SUPER:Lorg/apache/cassandra/config/CFMetaData$Flag;
            invokeinterface java.util.Set.contains:(Ljava/lang/Object;)Z
            istore 9 /* isSuper */
        start local 9 // boolean isSuper
         5: .line 178
            aload 8 /* flags */
            getstatic org.apache.cassandra.config.CFMetaData$Flag.COUNTER:Lorg/apache/cassandra/config/CFMetaData$Flag;
            invokeinterface java.util.Set.contains:(Ljava/lang/Object;)Z
            istore 10 /* isCounter */
        start local 10 // boolean isCounter
         6: .line 179
            aload 8 /* flags */
            getstatic org.apache.cassandra.config.CFMetaData$Flag.DENSE:Lorg/apache/cassandra/config/CFMetaData$Flag;
            invokeinterface java.util.Set.contains:(Ljava/lang/Object;)Z
            istore 11 /* isDense */
        start local 11 // boolean isDense
         7: .line 180
            iload 3 /* isView */
            ifne 8
            aload 8 /* flags */
            getstatic org.apache.cassandra.config.CFMetaData$Flag.COMPOUND:Lorg/apache/cassandra/config/CFMetaData$Flag;
            invokeinterface java.util.Set.contains:(Ljava/lang/Object;)Z
            ifne 8
            iconst_0
            goto 9
      StackMap locals: java.lang.String com.datastax.driver.core.Session org.apache.cassandra.dht.IPartitioner int com.datastax.driver.core.Row java.lang.String org.apache.cassandra.schema.Types java.util.UUID java.util.Set int int int
      StackMap stack:
         8: iconst_1
      StackMap locals:
      StackMap stack: int
         9: istore 12 /* isCompound */
        start local 12 // boolean isCompound
        10: .line 182
            ldc "SELECT * FROM %s.%s WHERE keyspace_name = ? AND table_name = ?"
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
        11: .line 183
            ldc "system_schema"
            aastore
            dup
            iconst_1
        12: .line 184
            ldc "columns"
            aastore
        13: .line 182
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            astore 13 /* columnsQuery */
        start local 13 // java.lang.String columnsQuery
        14: .line 186
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            astore 14 /* defs */
        start local 14 // java.util.List defs
        15: .line 187
            aload 1 /* session */
            aload 13 /* columnsQuery */
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* keyspace */
            aastore
            dup
            iconst_1
            aload 5 /* name */
            aastore
            invokeinterface com.datastax.driver.core.Session.execute:(Ljava/lang/String;[Ljava/lang/Object;)Lcom/datastax/driver/core/ResultSet;
            invokeinterface com.datastax.driver.core.ResultSet.iterator:()Ljava/util/Iterator;
            astore 16
            goto 18
      StackMap locals: java.lang.String com.datastax.driver.core.Session org.apache.cassandra.dht.IPartitioner int com.datastax.driver.core.Row java.lang.String org.apache.cassandra.schema.Types java.util.UUID java.util.Set int int int int java.lang.String java.util.List top java.util.Iterator
      StackMap stack:
        16: aload 16
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast com.datastax.driver.core.Row
            astore 15 /* colRow */
        start local 15 // com.datastax.driver.core.Row colRow
        17: .line 188
            aload 14 /* defs */
            aload 15 /* colRow */
            aload 0 /* keyspace */
            aload 5 /* name */
            aload 6 /* types */
            invokestatic org.apache.cassandra.utils.NativeSSTableLoaderClient.createDefinitionFromRow:(Lcom/datastax/driver/core/Row;Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/schema/Types;)Lorg/apache/cassandra/config/ColumnDefinition;
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
        end local 15 // com.datastax.driver.core.Row colRow
        18: .line 187
      StackMap locals:
      StackMap stack:
            aload 16
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 16
        19: .line 190
            aload 0 /* keyspace */
        20: .line 191
            aload 5 /* name */
        21: .line 192
            aload 7 /* id */
        22: .line 193
            iload 11 /* isDense */
        23: .line 194
            iload 12 /* isCompound */
        24: .line 195
            iload 9 /* isSuper */
        25: .line 196
            iload 10 /* isCounter */
        26: .line 197
            iload 3 /* isView */
        27: .line 198
            aload 14 /* defs */
        28: .line 199
            aload 2 /* partitioner */
        29: .line 190
            invokestatic org.apache.cassandra.config.CFMetaData.create:(Ljava/lang/String;Ljava/lang/String;Ljava/util/UUID;ZZZZZLjava/util/List;Lorg/apache/cassandra/dht/IPartitioner;)Lorg/apache/cassandra/config/CFMetaData;
            astore 15 /* metadata */
        start local 15 // org.apache.cassandra.config.CFMetaData metadata
        30: .line 201
            ldc "SELECT * FROM %s.%s WHERE keyspace_name = ? AND table_name = ?"
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
        31: .line 202
            ldc "system_schema"
            aastore
            dup
            iconst_1
        32: .line 203
            ldc "dropped_columns"
            aastore
        33: .line 201
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            astore 16 /* droppedColumnsQuery */
        start local 16 // java.lang.String droppedColumnsQuery
        34: .line 204
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 17 /* droppedColumns */
        start local 17 // java.util.Map droppedColumns
        35: .line 205
            aload 1 /* session */
            aload 16 /* droppedColumnsQuery */
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* keyspace */
            aastore
            dup
            iconst_1
            aload 5 /* name */
            aastore
            invokeinterface com.datastax.driver.core.Session.execute:(Ljava/lang/String;[Ljava/lang/Object;)Lcom/datastax/driver/core/ResultSet;
            invokeinterface com.datastax.driver.core.ResultSet.iterator:()Ljava/util/Iterator;
            astore 19
            goto 39
      StackMap locals: java.lang.String com.datastax.driver.core.Session org.apache.cassandra.dht.IPartitioner int com.datastax.driver.core.Row java.lang.String org.apache.cassandra.schema.Types java.util.UUID java.util.Set int int int int java.lang.String java.util.List org.apache.cassandra.config.CFMetaData java.lang.String java.util.Map top java.util.Iterator
      StackMap stack:
        36: aload 19
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast com.datastax.driver.core.Row
            astore 18 /* colRow */
        start local 18 // com.datastax.driver.core.Row colRow
        37: .line 207
            aload 18 /* colRow */
            aload 0 /* keyspace */
            invokestatic org.apache.cassandra.utils.NativeSSTableLoaderClient.createDroppedColumnFromRow:(Lcom/datastax/driver/core/Row;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData$DroppedColumn;
            astore 20 /* droppedColumn */
        start local 20 // org.apache.cassandra.config.CFMetaData$DroppedColumn droppedColumn
        38: .line 208
            aload 17 /* droppedColumns */
            getstatic org.apache.cassandra.db.marshal.UTF8Type.instance:Lorg/apache/cassandra/db/marshal/UTF8Type;
            aload 20 /* droppedColumn */
            getfield org.apache.cassandra.config.CFMetaData$DroppedColumn.name:Ljava/lang/String;
            invokevirtual org.apache.cassandra.db.marshal.UTF8Type.decompose:(Ljava/lang/Object;)Ljava/nio/ByteBuffer;
            aload 20 /* droppedColumn */
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        end local 20 // org.apache.cassandra.config.CFMetaData$DroppedColumn droppedColumn
        end local 18 // com.datastax.driver.core.Row colRow
        39: .line 205
      StackMap locals:
      StackMap stack:
            aload 19
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 36
        40: .line 210
            aload 15 /* metadata */
            aload 17 /* droppedColumns */
            invokevirtual org.apache.cassandra.config.CFMetaData.droppedColumns:(Ljava/util/Map;)Lorg/apache/cassandra/config/CFMetaData;
            pop
        41: .line 212
            aload 15 /* metadata */
            areturn
        end local 17 // java.util.Map droppedColumns
        end local 16 // java.lang.String droppedColumnsQuery
        end local 15 // org.apache.cassandra.config.CFMetaData metadata
        end local 14 // java.util.List defs
        end local 13 // java.lang.String columnsQuery
        end local 12 // boolean isCompound
        end local 11 // boolean isDense
        end local 10 // boolean isCounter
        end local 9 // boolean isSuper
        end local 8 // java.util.Set flags
        end local 7 // java.util.UUID id
        end local 6 // org.apache.cassandra.schema.Types types
        end local 5 // java.lang.String name
        end local 4 // com.datastax.driver.core.Row row
        end local 3 // boolean isView
        end local 2 // org.apache.cassandra.dht.IPartitioner partitioner
        end local 1 // com.datastax.driver.core.Session session
        end local 0 // java.lang.String keyspace
      LocalVariableTable:
        Start  End  Slot                 Name  Signature
            0   42     0             keyspace  Ljava/lang/String;
            0   42     1              session  Lcom/datastax/driver/core/Session;
            0   42     2          partitioner  Lorg/apache/cassandra/dht/IPartitioner;
            0   42     3               isView  Z
            0   42     4                  row  Lcom/datastax/driver/core/Row;
            0   42     5                 name  Ljava/lang/String;
            0   42     6                types  Lorg/apache/cassandra/schema/Types;
            1   42     7                   id  Ljava/util/UUID;
            4   42     8                flags  Ljava/util/Set<Lorg/apache/cassandra/config/CFMetaData$Flag;>;
            5   42     9              isSuper  Z
            6   42    10            isCounter  Z
            7   42    11              isDense  Z
           10   42    12           isCompound  Z
           14   42    13         columnsQuery  Ljava/lang/String;
           15   42    14                 defs  Ljava/util/List<Lorg/apache/cassandra/config/ColumnDefinition;>;
           17   18    15               colRow  Lcom/datastax/driver/core/Row;
           30   42    15             metadata  Lorg/apache/cassandra/config/CFMetaData;
           34   42    16  droppedColumnsQuery  Ljava/lang/String;
           35   42    17       droppedColumns  Ljava/util/Map<Ljava/nio/ByteBuffer;Lorg/apache/cassandra/config/CFMetaData$DroppedColumn;>;
           37   39    18               colRow  Lcom/datastax/driver/core/Row;
           38   39    20        droppedColumn  Lorg/apache/cassandra/config/CFMetaData$DroppedColumn;
    MethodParameters:
             Name  Flags
      keyspace     
      session      
      partitioner  
      isView       
      row          
      name         
      types        

  private static org.apache.cassandra.config.ColumnDefinition createDefinitionFromRow(com.datastax.driver.core.Row, java.lang.String, java.lang.String, org.apache.cassandra.schema.Types);
    descriptor: (Lcom/datastax/driver/core/Row;Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/schema/Types;)Lorg/apache/cassandra/config/ColumnDefinition;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=8, locals=9, args_size=4
        start local 0 // com.datastax.driver.core.Row row
        start local 1 // java.lang.String keyspace
        start local 2 // java.lang.String table
        start local 3 // org.apache.cassandra.schema.Types types
         0: .line 217
            aload 0 /* row */
            ldc "clustering_order"
            invokeinterface com.datastax.driver.core.Row.getString:(Ljava/lang/String;)Ljava/lang/String;
            invokevirtual java.lang.String.toUpperCase:()Ljava/lang/String;
            invokestatic org.apache.cassandra.config.ColumnDefinition$ClusteringOrder.valueOf:(Ljava/lang/String;)Lorg/apache/cassandra/config/ColumnDefinition$ClusteringOrder;
            astore 4 /* order */
        start local 4 // org.apache.cassandra.config.ColumnDefinition$ClusteringOrder order
         1: .line 218
            aload 1 /* keyspace */
            aload 0 /* row */
            ldc "type"
            invokeinterface com.datastax.driver.core.Row.getString:(Ljava/lang/String;)Ljava/lang/String;
            aload 3 /* types */
            invokestatic org.apache.cassandra.schema.CQLTypeParser.parse:(Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/schema/Types;)Lorg/apache/cassandra/db/marshal/AbstractType;
            astore 5 /* type */
        start local 5 // org.apache.cassandra.db.marshal.AbstractType type
         2: .line 219
            aload 4 /* order */
            getstatic org.apache.cassandra.config.ColumnDefinition$ClusteringOrder.DESC:Lorg/apache/cassandra/config/ColumnDefinition$ClusteringOrder;
            if_acmpne 4
         3: .line 220
            aload 5 /* type */
            invokestatic org.apache.cassandra.db.marshal.ReversedType.getInstance:(Lorg/apache/cassandra/db/marshal/AbstractType;)Lorg/apache/cassandra/db/marshal/ReversedType;
            astore 5 /* type */
         4: .line 222
      StackMap locals: org.apache.cassandra.config.ColumnDefinition$ClusteringOrder org.apache.cassandra.db.marshal.AbstractType
      StackMap stack:
            new org.apache.cassandra.cql3.ColumnIdentifier
            dup
            aload 0 /* row */
            ldc "column_name_bytes"
            invokeinterface com.datastax.driver.core.Row.getBytes:(Ljava/lang/String;)Ljava/nio/ByteBuffer;
            aload 0 /* row */
            ldc "column_name"
            invokeinterface com.datastax.driver.core.Row.getString:(Ljava/lang/String;)Ljava/lang/String;
            invokespecial org.apache.cassandra.cql3.ColumnIdentifier.<init>:(Ljava/nio/ByteBuffer;Ljava/lang/String;)V
            astore 6 /* name */
        start local 6 // org.apache.cassandra.cql3.ColumnIdentifier name
         5: .line 224
            aload 0 /* row */
            ldc "position"
            invokeinterface com.datastax.driver.core.Row.getInt:(Ljava/lang/String;)I
            istore 7 /* position */
        start local 7 // int position
         6: .line 225
            aload 0 /* row */
            ldc "kind"
            invokeinterface com.datastax.driver.core.Row.getString:(Ljava/lang/String;)Ljava/lang/String;
            invokevirtual java.lang.String.toUpperCase:()Ljava/lang/String;
            invokestatic org.apache.cassandra.config.ColumnDefinition$Kind.valueOf:(Ljava/lang/String;)Lorg/apache/cassandra/config/ColumnDefinition$Kind;
            astore 8 /* kind */
        start local 8 // org.apache.cassandra.config.ColumnDefinition$Kind kind
         7: .line 226
            new org.apache.cassandra.config.ColumnDefinition
            dup
            aload 1 /* keyspace */
            aload 2 /* table */
            aload 6 /* name */
            aload 5 /* type */
            iload 7 /* position */
            aload 8 /* kind */
            invokespecial org.apache.cassandra.config.ColumnDefinition.<init>:(Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/cql3/ColumnIdentifier;Lorg/apache/cassandra/db/marshal/AbstractType;ILorg/apache/cassandra/config/ColumnDefinition$Kind;)V
            areturn
        end local 8 // org.apache.cassandra.config.ColumnDefinition$Kind kind
        end local 7 // int position
        end local 6 // org.apache.cassandra.cql3.ColumnIdentifier name
        end local 5 // org.apache.cassandra.db.marshal.AbstractType type
        end local 4 // org.apache.cassandra.config.ColumnDefinition$ClusteringOrder order
        end local 3 // org.apache.cassandra.schema.Types types
        end local 2 // java.lang.String table
        end local 1 // java.lang.String keyspace
        end local 0 // com.datastax.driver.core.Row row
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    8     0       row  Lcom/datastax/driver/core/Row;
            0    8     1  keyspace  Ljava/lang/String;
            0    8     2     table  Ljava/lang/String;
            0    8     3     types  Lorg/apache/cassandra/schema/Types;
            1    8     4     order  Lorg/apache/cassandra/config/ColumnDefinition$ClusteringOrder;
            2    8     5      type  Lorg/apache/cassandra/db/marshal/AbstractType<*>;
            5    8     6      name  Lorg/apache/cassandra/cql3/ColumnIdentifier;
            6    8     7  position  I
            7    8     8      kind  Lorg/apache/cassandra/config/ColumnDefinition$Kind;
    MethodParameters:
          Name  Flags
      row       
      keyspace  
      table     
      types     

  private static org.apache.cassandra.config.CFMetaData$DroppedColumn createDroppedColumnFromRow(com.datastax.driver.core.Row, java.lang.String);
    descriptor: (Lcom/datastax/driver/core/Row;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData$DroppedColumn;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=7, locals=7, args_size=2
        start local 0 // com.datastax.driver.core.Row row
        start local 1 // java.lang.String keyspace
         0: .line 231
            aload 0 /* row */
            ldc "column_name"
            invokeinterface com.datastax.driver.core.Row.getString:(Ljava/lang/String;)Ljava/lang/String;
            astore 2 /* name */
        start local 2 // java.lang.String name
         1: .line 233
            aload 0 /* row */
            ldc "kind"
            invokeinterface com.datastax.driver.core.Row.isNull:(Ljava/lang/String;)Z
            ifeq 2
            aconst_null
            goto 3
      StackMap locals: java.lang.String
      StackMap stack:
         2: aload 0 /* row */
            ldc "kind"
            invokeinterface com.datastax.driver.core.Row.getString:(Ljava/lang/String;)Ljava/lang/String;
            invokevirtual java.lang.String.toUpperCase:()Ljava/lang/String;
            invokestatic org.apache.cassandra.config.ColumnDefinition$Kind.valueOf:(Ljava/lang/String;)Lorg/apache/cassandra/config/ColumnDefinition$Kind;
         3: .line 232
      StackMap locals:
      StackMap stack: org.apache.cassandra.config.ColumnDefinition$Kind
            astore 3 /* kind */
        start local 3 // org.apache.cassandra.config.ColumnDefinition$Kind kind
         4: .line 234
            aload 1 /* keyspace */
            aload 0 /* row */
            ldc "type"
            invokeinterface com.datastax.driver.core.Row.getString:(Ljava/lang/String;)Ljava/lang/String;
            invokestatic org.apache.cassandra.schema.Types.none:()Lorg/apache/cassandra/schema/Types;
            invokestatic org.apache.cassandra.schema.CQLTypeParser.parse:(Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/schema/Types;)Lorg/apache/cassandra/db/marshal/AbstractType;
            astore 4 /* type */
        start local 4 // org.apache.cassandra.db.marshal.AbstractType type
         5: .line 235
            getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
            aload 0 /* row */
            ldc "dropped_time"
            invokeinterface com.datastax.driver.core.Row.getTimestamp:(Ljava/lang/String;)Ljava/util/Date;
            invokevirtual java.util.Date.getTime:()J
            invokevirtual java.util.concurrent.TimeUnit.toMicros:(J)J
            lstore 5 /* droppedTime */
        start local 5 // long droppedTime
         6: .line 236
            new org.apache.cassandra.config.CFMetaData$DroppedColumn
            dup
            aload 2 /* name */
            aload 3 /* kind */
            aload 4 /* type */
            lload 5 /* droppedTime */
            invokespecial org.apache.cassandra.config.CFMetaData$DroppedColumn.<init>:(Ljava/lang/String;Lorg/apache/cassandra/config/ColumnDefinition$Kind;Lorg/apache/cassandra/db/marshal/AbstractType;J)V
            areturn
        end local 5 // long droppedTime
        end local 4 // org.apache.cassandra.db.marshal.AbstractType type
        end local 3 // org.apache.cassandra.config.ColumnDefinition$Kind kind
        end local 2 // java.lang.String name
        end local 1 // java.lang.String keyspace
        end local 0 // com.datastax.driver.core.Row row
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    7     0          row  Lcom/datastax/driver/core/Row;
            0    7     1     keyspace  Ljava/lang/String;
            1    7     2         name  Ljava/lang/String;
            4    7     3         kind  Lorg/apache/cassandra/config/ColumnDefinition$Kind;
            5    7     4         type  Lorg/apache/cassandra/db/marshal/AbstractType<*>;
            6    7     5  droppedTime  J
    MethodParameters:
          Name  Flags
      row       
      keyspace  
}
SourceFile: "NativeSSTableLoaderClient.java"
InnerClasses:
  public Builder = com.datastax.driver.core.Cluster$Builder of com.datastax.driver.core.Cluster
  public DroppedColumn = org.apache.cassandra.config.CFMetaData$DroppedColumn of org.apache.cassandra.config.CFMetaData
  public final Flag = org.apache.cassandra.config.CFMetaData$Flag of org.apache.cassandra.config.CFMetaData
  public final ClusteringOrder = org.apache.cassandra.config.ColumnDefinition$ClusteringOrder of org.apache.cassandra.config.ColumnDefinition
  public final Kind = org.apache.cassandra.config.ColumnDefinition$Kind of org.apache.cassandra.config.ColumnDefinition
  public abstract TokenFactory = org.apache.cassandra.dht.Token$TokenFactory of org.apache.cassandra.dht.Token
  public abstract Client = org.apache.cassandra.io.sstable.SSTableLoader$Client of org.apache.cassandra.io.sstable.SSTableLoader
  public final RawBuilder = org.apache.cassandra.schema.Types$RawBuilder of org.apache.cassandra.schema.Types