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 0: aload 0
invokespecial java.lang.Object.<init>:()V
return
end local 0 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 0: invokestatic org.apache.cassandra.tools.LoaderOptions.builder:()Lorg/apache/cassandra/tools/LoaderOptions$Builder;
aload 0
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
start local 1 1: aload 1
invokestatic org.apache.cassandra.tools.BulkLoader.load:(Lorg/apache/cassandra/tools/LoaderOptions;)V
2: return
end local 1 end local 0 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 0: invokestatic org.apache.cassandra.config.DatabaseDescriptor.toolInitialization:()V
1: new org.apache.cassandra.utils.OutputHandler$SystemOutput
dup
aload 0
getfield org.apache.cassandra.tools.LoaderOptions.verbose:Z
aload 0
getfield org.apache.cassandra.tools.LoaderOptions.debug:Z
invokespecial org.apache.cassandra.utils.OutputHandler$SystemOutput.<init>:(ZZ)V
astore 1
start local 1 2: new org.apache.cassandra.io.sstable.SSTableLoader
dup
3: aload 0
getfield org.apache.cassandra.tools.LoaderOptions.directory:Ljava/io/File;
invokevirtual java.io.File.getAbsoluteFile:()Ljava/io/File;
4: new org.apache.cassandra.tools.BulkLoader$ExternalClient
dup
5: aload 0
getfield org.apache.cassandra.tools.LoaderOptions.hosts:Ljava/util/Set;
6: aload 0
getfield org.apache.cassandra.tools.LoaderOptions.nativePort:I
7: aload 0
getfield org.apache.cassandra.tools.LoaderOptions.authProvider:Lcom/datastax/driver/core/AuthProvider;
8: aload 0
getfield org.apache.cassandra.tools.LoaderOptions.storagePort:I
9: aload 0
getfield org.apache.cassandra.tools.LoaderOptions.sslStoragePort:I
10: aload 0
getfield org.apache.cassandra.tools.LoaderOptions.serverEncOptions:Lorg/apache/cassandra/config/EncryptionOptions$ServerEncryptionOptions;
11: aload 0
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: 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: aload 1
14: aload 0
getfield org.apache.cassandra.tools.LoaderOptions.connectionsPerHost:I
15: 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
start local 2 16: aload 0
getfield org.apache.cassandra.tools.LoaderOptions.throttle:I
invokestatic org.apache.cassandra.config.DatabaseDescriptor.setStreamThroughputOutboundMegabitsPerSec:(I)V
17: aload 0
getfield org.apache.cassandra.tools.LoaderOptions.interDcThrottle:I
invokestatic org.apache.cassandra.config.DatabaseDescriptor.setInterDCStreamThroughputOutboundMegabitsPerSec:(I)V
18: aconst_null
astore 3
start local 3 19: new org.apache.cassandra.tools.BulkLoader$ProgressIndicator
dup
invokespecial org.apache.cassandra.tools.BulkLoader$ProgressIndicator.<init>:()V
astore 4
start local 4 20: aload 0
getfield org.apache.cassandra.tools.LoaderOptions.noProgress:Z
ifeq 23
21: aload 2
aload 0
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
22: goto 32
23: 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
aload 0
getfield org.apache.cassandra.tools.LoaderOptions.ignores:Ljava/util/Set;
iconst_1
anewarray org.apache.cassandra.streaming.StreamEventHandler
dup
iconst_0
aload 4
aastore
invokevirtual org.apache.cassandra.io.sstable.SSTableLoader.stream:(Ljava/util/Set;[Lorg/apache/cassandra/streaming/StreamEventHandler;)Lorg/apache/cassandra/streaming/StreamResultFuture;
astore 3
24: goto 32
25: StackMap locals:
StackMap stack: java.lang.Exception
astore 5
start local 5 26: aload 5
invokestatic org.apache.cassandra.utils.JVMStabilityInspector.inspectThrowable:(Ljava/lang/Throwable;)V
27: getstatic java.lang.System.err:Ljava/io/PrintStream;
aload 5
invokevirtual java.lang.Exception.getMessage:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
28: aload 5
invokevirtual java.lang.Exception.getCause:()Ljava/lang/Throwable;
ifnull 30
29: getstatic java.lang.System.err:Ljava/io/PrintStream;
aload 5
invokevirtual java.lang.Exception.getCause:()Ljava/lang/Throwable;
invokevirtual java.io.PrintStream.println:(Ljava/lang/Object;)V
30: StackMap locals: java.lang.Exception
StackMap stack:
aload 5
getstatic java.lang.System.err:Ljava/io/PrintStream;
invokevirtual java.lang.Exception.printStackTrace:(Ljava/io/PrintStream;)V
31: new org.apache.cassandra.tools.BulkLoadException
dup
aload 5
invokespecial org.apache.cassandra.tools.BulkLoadException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 5 32: StackMap locals:
StackMap stack:
aload 3
invokevirtual org.apache.cassandra.streaming.StreamResultFuture.get:()Ljava/lang/Object;
pop
33: aload 0
getfield org.apache.cassandra.tools.LoaderOptions.noProgress:Z
ifne 35
34: aload 4
aload 0
getfield org.apache.cassandra.tools.LoaderOptions.connectionsPerHost:I
invokevirtual org.apache.cassandra.tools.BulkLoader$ProgressIndicator.printSummary:(I)V
35: StackMap locals:
StackMap stack:
ldc 1000
invokestatic java.lang.Thread.sleep:(J)V
36: goto 42
37: StackMap locals:
StackMap stack: java.lang.Exception
astore 5
start local 5 38: 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: getstatic java.lang.System.err:Ljava/io/PrintStream;
aload 2
invokevirtual org.apache.cassandra.io.sstable.SSTableLoader.getFailedHosts:()Ljava/util/Set;
invokevirtual java.io.PrintStream.println:(Ljava/lang/Object;)V
40: aload 5
getstatic java.lang.System.err:Ljava/io/PrintStream;
invokevirtual java.lang.Exception.printStackTrace:(Ljava/io/PrintStream;)V
41: new org.apache.cassandra.tools.BulkLoadException
dup
aload 5
invokespecial org.apache.cassandra.tools.BulkLoadException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 5 42: StackMap locals:
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 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 0: aload 0
getfield org.apache.cassandra.config.EncryptionOptions$ClientEncryptionOptions.enabled:Z
ifne 2
1: aconst_null
areturn
2: StackMap locals:
StackMap stack:
aload 0
iconst_1
invokestatic org.apache.cassandra.security.SSLFactory.createSSLContext:(Lorg/apache/cassandra/config/EncryptionOptions;Z)Ljavax/net/ssl/SSLContext;
astore 1
start local 1 3: goto 6
end local 1 4: StackMap locals:
StackMap stack: java.io.IOException
astore 2
start local 2 5: new java.lang.RuntimeException
dup
ldc "Could not create SSL Context."
aload 2
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
athrow
end local 2 start local 1 6: StackMap locals: javax.net.ssl.SSLContext
StackMap stack:
invokestatic com.datastax.driver.core.JdkSSLOptions.builder:()Lcom/datastax/driver/core/JdkSSLOptions$Builder;
7: aload 1
invokevirtual com.datastax.driver.core.JdkSSLOptions$Builder.withSSLContext:(Ljavax/net/ssl/SSLContext;)Lcom/datastax/driver/core/JdkSSLOptions$Builder;
8: aload 0
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: invokevirtual com.datastax.driver.core.JdkSSLOptions$Builder.build:()Lcom/datastax/driver/core/JdkSSLOptions;
10: areturn
end local 1 end local 0 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