public class org.apache.cassandra.tools.BulkLoader
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.cassandra.tools.BulkLoader
  super_class: java.lang.Object
{
  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.tools.BulkLoader this
         0: .line 43
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // org.apache.cassandra.tools.BulkLoader this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/tools/BulkLoader;

  public static void main(java.lang.String[]);
    descriptor: ([Ljava/lang/String;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // java.lang.String[] args
         0: .line 47
            invokestatic org.apache.cassandra.tools.LoaderOptions.builder:()Lorg/apache/cassandra/tools/LoaderOptions$Builder;
            aload 0 /* args */
            invokevirtual org.apache.cassandra.tools.LoaderOptions$Builder.parseArgs:([Ljava/lang/String;)Lorg/apache/cassandra/tools/LoaderOptions$Builder;
            invokevirtual org.apache.cassandra.tools.LoaderOptions$Builder.build:()Lorg/apache/cassandra/tools/LoaderOptions;
            astore 1 /* options */
        start local 1 // org.apache.cassandra.tools.LoaderOptions options
         1: .line 48
            aload 1 /* options */
            invokestatic org.apache.cassandra.tools.BulkLoader.load:(Lorg/apache/cassandra/tools/LoaderOptions;)V
         2: .line 49
            return
        end local 1 // org.apache.cassandra.tools.LoaderOptions options
        end local 0 // java.lang.String[] args
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     args  [Ljava/lang/String;
            1    3     1  options  Lorg/apache/cassandra/tools/LoaderOptions;
    Exceptions:
      throws org.apache.cassandra.tools.BulkLoadException
    MethodParameters:
      Name  Flags
      args  

  public static void load(org.apache.cassandra.tools.LoaderOptions);
    descriptor: (Lorg/apache/cassandra/tools/LoaderOptions;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=12, locals=6, args_size=1
        start local 0 // org.apache.cassandra.tools.LoaderOptions options
         0: .line 53
            invokestatic org.apache.cassandra.config.DatabaseDescriptor.toolInitialization:()V
         1: .line 54
            new org.apache.cassandra.utils.OutputHandler$SystemOutput
            dup
            aload 0 /* options */
            getfield org.apache.cassandra.tools.LoaderOptions.verbose:Z
            aload 0 /* options */
            getfield org.apache.cassandra.tools.LoaderOptions.debug:Z
            invokespecial org.apache.cassandra.utils.OutputHandler$SystemOutput.<init>:(ZZ)V
            astore 1 /* handler */
        start local 1 // org.apache.cassandra.utils.OutputHandler handler
         2: .line 55
            new org.apache.cassandra.io.sstable.SSTableLoader
            dup
         3: .line 56
            aload 0 /* options */
            getfield org.apache.cassandra.tools.LoaderOptions.directory:Ljava/io/File;
            invokevirtual java.io.File.getAbsoluteFile:()Ljava/io/File;
         4: .line 57
            new org.apache.cassandra.tools.BulkLoader$ExternalClient
            dup
         5: .line 58
            aload 0 /* options */
            getfield org.apache.cassandra.tools.LoaderOptions.hosts:Ljava/util/Set;
         6: .line 59
            aload 0 /* options */
            getfield org.apache.cassandra.tools.LoaderOptions.nativePort:I
         7: .line 60
            aload 0 /* options */
            getfield org.apache.cassandra.tools.LoaderOptions.authProvider:Lcom/datastax/driver/core/AuthProvider;
         8: .line 61
            aload 0 /* options */
            getfield org.apache.cassandra.tools.LoaderOptions.storagePort:I
         9: .line 62
            aload 0 /* options */
            getfield org.apache.cassandra.tools.LoaderOptions.sslStoragePort:I
        10: .line 63
            aload 0 /* options */
            getfield org.apache.cassandra.tools.LoaderOptions.serverEncOptions:Lorg/apache/cassandra/config/EncryptionOptions$ServerEncryptionOptions;
        11: .line 64
            aload 0 /* options */
            getfield org.apache.cassandra.tools.LoaderOptions.clientEncOptions:Lorg/apache/cassandra/config/EncryptionOptions$ClientEncryptionOptions;
            invokestatic org.apache.cassandra.tools.BulkLoader.buildSSLOptions:(Lorg/apache/cassandra/config/EncryptionOptions$ClientEncryptionOptions;)Lcom/datastax/driver/core/SSLOptions;
        12: .line 57
            invokespecial org.apache.cassandra.tools.BulkLoader$ExternalClient.<init>:(Ljava/util/Set;ILcom/datastax/driver/core/AuthProvider;IILorg/apache/cassandra/config/EncryptionOptions$ServerEncryptionOptions;Lcom/datastax/driver/core/SSLOptions;)V
        13: .line 65
            aload 1 /* handler */
        14: .line 66
            aload 0 /* options */
            getfield org.apache.cassandra.tools.LoaderOptions.connectionsPerHost:I
        15: .line 55
            invokespecial org.apache.cassandra.io.sstable.SSTableLoader.<init>:(Ljava/io/File;Lorg/apache/cassandra/io/sstable/SSTableLoader$Client;Lorg/apache/cassandra/utils/OutputHandler;I)V
            astore 2 /* loader */
        start local 2 // org.apache.cassandra.io.sstable.SSTableLoader loader
        16: .line 67
            aload 0 /* options */
            getfield org.apache.cassandra.tools.LoaderOptions.throttle:I
            invokestatic org.apache.cassandra.config.DatabaseDescriptor.setStreamThroughputOutboundMegabitsPerSec:(I)V
        17: .line 68
            aload 0 /* options */
            getfield org.apache.cassandra.tools.LoaderOptions.interDcThrottle:I
            invokestatic org.apache.cassandra.config.DatabaseDescriptor.setInterDCStreamThroughputOutboundMegabitsPerSec:(I)V
        18: .line 69
            aconst_null
            astore 3 /* future */
        start local 3 // org.apache.cassandra.streaming.StreamResultFuture future
        19: .line 71
            new org.apache.cassandra.tools.BulkLoader$ProgressIndicator
            dup
            invokespecial org.apache.cassandra.tools.BulkLoader$ProgressIndicator.<init>:()V
            astore 4 /* indicator */
        start local 4 // org.apache.cassandra.tools.BulkLoader$ProgressIndicator indicator
        20: .line 74
            aload 0 /* options */
            getfield org.apache.cassandra.tools.LoaderOptions.noProgress:Z
            ifeq 23
        21: .line 76
            aload 2 /* loader */
            aload 0 /* options */
            getfield org.apache.cassandra.tools.LoaderOptions.ignores:Ljava/util/Set;
            iconst_0
            anewarray org.apache.cassandra.streaming.StreamEventHandler
            invokevirtual org.apache.cassandra.io.sstable.SSTableLoader.stream:(Ljava/util/Set;[Lorg/apache/cassandra/streaming/StreamEventHandler;)Lorg/apache/cassandra/streaming/StreamResultFuture;
            astore 3 /* future */
        22: .line 77
            goto 32
        23: .line 80
      StackMap locals: org.apache.cassandra.tools.LoaderOptions org.apache.cassandra.utils.OutputHandler org.apache.cassandra.io.sstable.SSTableLoader org.apache.cassandra.streaming.StreamResultFuture org.apache.cassandra.tools.BulkLoader$ProgressIndicator
      StackMap stack:
            aload 2 /* loader */
            aload 0 /* options */
            getfield org.apache.cassandra.tools.LoaderOptions.ignores:Ljava/util/Set;
            iconst_1
            anewarray org.apache.cassandra.streaming.StreamEventHandler
            dup
            iconst_0
            aload 4 /* indicator */
            aastore
            invokevirtual org.apache.cassandra.io.sstable.SSTableLoader.stream:(Ljava/util/Set;[Lorg/apache/cassandra/streaming/StreamEventHandler;)Lorg/apache/cassandra/streaming/StreamResultFuture;
            astore 3 /* future */
        24: .line 83
            goto 32
        25: .line 84
      StackMap locals:
      StackMap stack: java.lang.Exception
            astore 5 /* e */
        start local 5 // java.lang.Exception e
        26: .line 86
            aload 5 /* e */
            invokestatic org.apache.cassandra.utils.JVMStabilityInspector.inspectThrowable:(Ljava/lang/Throwable;)V
        27: .line 87
            getstatic java.lang.System.err:Ljava/io/PrintStream;
            aload 5 /* e */
            invokevirtual java.lang.Exception.getMessage:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        28: .line 88
            aload 5 /* e */
            invokevirtual java.lang.Exception.getCause:()Ljava/lang/Throwable;
            ifnull 30
        29: .line 90
            getstatic java.lang.System.err:Ljava/io/PrintStream;
            aload 5 /* e */
            invokevirtual java.lang.Exception.getCause:()Ljava/lang/Throwable;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/Object;)V
        30: .line 92
      StackMap locals: java.lang.Exception
      StackMap stack:
            aload 5 /* e */
            getstatic java.lang.System.err:Ljava/io/PrintStream;
            invokevirtual java.lang.Exception.printStackTrace:(Ljava/io/PrintStream;)V
        31: .line 93
            new org.apache.cassandra.tools.BulkLoadException
            dup
            aload 5 /* e */
            invokespecial org.apache.cassandra.tools.BulkLoadException.<init>:(Ljava/lang/Throwable;)V
            athrow
        end local 5 // java.lang.Exception e
        32: .line 98
      StackMap locals:
      StackMap stack:
            aload 3 /* future */
            invokevirtual org.apache.cassandra.streaming.StreamResultFuture.get:()Ljava/lang/Object;
            pop
        33: .line 100
            aload 0 /* options */
            getfield org.apache.cassandra.tools.LoaderOptions.noProgress:Z
            ifne 35
        34: .line 102
            aload 4 /* indicator */
            aload 0 /* options */
            getfield org.apache.cassandra.tools.LoaderOptions.connectionsPerHost:I
            invokevirtual org.apache.cassandra.tools.BulkLoader$ProgressIndicator.printSummary:(I)V
        35: .line 106
      StackMap locals:
      StackMap stack:
            ldc 1000
            invokestatic java.lang.Thread.sleep:(J)V
        36: .line 108
            goto 42
        37: .line 109
      StackMap locals:
      StackMap stack: java.lang.Exception
            astore 5 /* e */
        start local 5 // java.lang.Exception e
        38: .line 111
            getstatic java.lang.System.err:Ljava/io/PrintStream;
            ldc "Streaming to the following hosts failed:"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        39: .line 112
            getstatic java.lang.System.err:Ljava/io/PrintStream;
            aload 2 /* loader */
            invokevirtual org.apache.cassandra.io.sstable.SSTableLoader.getFailedHosts:()Ljava/util/Set;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/Object;)V
        40: .line 113
            aload 5 /* e */
            getstatic java.lang.System.err:Ljava/io/PrintStream;
            invokevirtual java.lang.Exception.printStackTrace:(Ljava/io/PrintStream;)V
        41: .line 114
            new org.apache.cassandra.tools.BulkLoadException
            dup
            aload 5 /* e */
            invokespecial org.apache.cassandra.tools.BulkLoadException.<init>:(Ljava/lang/Throwable;)V
            athrow
        end local 5 // java.lang.Exception e
        42: .line 116
      StackMap locals:
      StackMap stack:
            return
        end local 4 // org.apache.cassandra.tools.BulkLoader$ProgressIndicator indicator
        end local 3 // org.apache.cassandra.streaming.StreamResultFuture future
        end local 2 // org.apache.cassandra.io.sstable.SSTableLoader loader
        end local 1 // org.apache.cassandra.utils.OutputHandler handler
        end local 0 // org.apache.cassandra.tools.LoaderOptions options
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0   43     0    options  Lorg/apache/cassandra/tools/LoaderOptions;
            2   43     1    handler  Lorg/apache/cassandra/utils/OutputHandler;
           16   43     2     loader  Lorg/apache/cassandra/io/sstable/SSTableLoader;
           19   43     3     future  Lorg/apache/cassandra/streaming/StreamResultFuture;
           20   43     4  indicator  Lorg/apache/cassandra/tools/BulkLoader$ProgressIndicator;
           26   32     5          e  Ljava/lang/Exception;
           38   42     5          e  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
          20    24      25  Class java.lang.Exception
          32    36      37  Class java.lang.Exception
    Exceptions:
      throws org.apache.cassandra.tools.BulkLoadException
    MethodParameters:
         Name  Flags
      options  

  private static com.datastax.driver.core.SSLOptions buildSSLOptions(org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions);
    descriptor: (Lorg/apache/cassandra/config/EncryptionOptions$ClientEncryptionOptions;)Lcom/datastax/driver/core/SSLOptions;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=4, locals=3, args_size=1
        start local 0 // org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions clientEncryptionOptions
         0: .line 249
            aload 0 /* clientEncryptionOptions */
            getfield org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions.enabled:Z
            ifne 2
         1: .line 251
            aconst_null
            areturn
         2: .line 257
      StackMap locals:
      StackMap stack:
            aload 0 /* clientEncryptionOptions */
            iconst_1
            invokestatic org.apache.cassandra.security.SSLFactory.createSSLContext:(Lorg/apache/cassandra/config/EncryptionOptions;Z)Ljavax/net/ssl/SSLContext;
            astore 1 /* sslContext */
        start local 1 // javax.net.ssl.SSLContext sslContext
         3: .line 258
            goto 6
        end local 1 // javax.net.ssl.SSLContext sslContext
         4: .line 259
      StackMap locals:
      StackMap stack: java.io.IOException
            astore 2 /* e */
        start local 2 // java.io.IOException e
         5: .line 261
            new java.lang.RuntimeException
            dup
            ldc "Could not create SSL Context."
            aload 2 /* e */
            invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
            athrow
        end local 2 // java.io.IOException e
        start local 1 // javax.net.ssl.SSLContext sslContext
         6: .line 264
      StackMap locals: javax.net.ssl.SSLContext
      StackMap stack:
            invokestatic com.datastax.driver.core.JdkSSLOptions.builder:()Lcom/datastax/driver/core/JdkSSLOptions$Builder;
         7: .line 265
            aload 1 /* sslContext */
            invokevirtual com.datastax.driver.core.JdkSSLOptions$Builder.withSSLContext:(Ljavax/net/ssl/SSLContext;)Lcom/datastax/driver/core/JdkSSLOptions$Builder;
         8: .line 266
            aload 0 /* clientEncryptionOptions */
            getfield org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions.cipher_suites:[Ljava/lang/String;
            invokevirtual com.datastax.driver.core.JdkSSLOptions$Builder.withCipherSuites:([Ljava/lang/String;)Lcom/datastax/driver/core/JdkSSLOptions$Builder;
         9: .line 267
            invokevirtual com.datastax.driver.core.JdkSSLOptions$Builder.build:()Lcom/datastax/driver/core/JdkSSLOptions;
        10: .line 264
            areturn
        end local 1 // javax.net.ssl.SSLContext sslContext
        end local 0 // org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions clientEncryptionOptions
      LocalVariableTable:
        Start  End  Slot                     Name  Signature
            0   11     0  clientEncryptionOptions  Lorg/apache/cassandra/config/EncryptionOptions$ClientEncryptionOptions;
            3    4     1               sslContext  Ljavax/net/ssl/SSLContext;
            6   11     1               sslContext  Ljavax/net/ssl/SSLContext;
            5    6     2                        e  Ljava/io/IOException;
      Exception table:
        from    to  target  type
           2     3       4  Class java.io.IOException
    MethodParameters:
                         Name  Flags
      clientEncryptionOptions  
}
SourceFile: "BulkLoader.java"
NestMembers:
  org.apache.cassandra.tools.BulkLoader$CmdLineOptions  org.apache.cassandra.tools.BulkLoader$ExternalClient  org.apache.cassandra.tools.BulkLoader$ProgressIndicator
InnerClasses:
  public Builder = com.datastax.driver.core.JdkSSLOptions$Builder of com.datastax.driver.core.JdkSSLOptions
  public ClientEncryptionOptions = org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions of org.apache.cassandra.config.EncryptionOptions
  public ServerEncryptionOptions = org.apache.cassandra.config.EncryptionOptions$ServerEncryptionOptions of org.apache.cassandra.config.EncryptionOptions
  public abstract Client = org.apache.cassandra.io.sstable.SSTableLoader$Client of org.apache.cassandra.io.sstable.SSTableLoader
  public CmdLineOptions = org.apache.cassandra.tools.BulkLoader$CmdLineOptions of org.apache.cassandra.tools.BulkLoader
  ExternalClient = org.apache.cassandra.tools.BulkLoader$ExternalClient of org.apache.cassandra.tools.BulkLoader
  ProgressIndicator = org.apache.cassandra.tools.BulkLoader$ProgressIndicator of org.apache.cassandra.tools.BulkLoader
  Builder = org.apache.cassandra.tools.LoaderOptions$Builder of org.apache.cassandra.tools.LoaderOptions
  public SystemOutput = org.apache.cassandra.utils.OutputHandler$SystemOutput of org.apache.cassandra.utils.OutputHandler