class org.apache.cassandra.tools.BulkLoader$ExternalClient extends org.apache.cassandra.utils.NativeSSTableLoaderClient
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: org.apache.cassandra.tools.BulkLoader$ExternalClient
super_class: org.apache.cassandra.utils.NativeSSTableLoaderClient
{
private final int storagePort;
descriptor: I
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final int sslStoragePort;
descriptor: I
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.apache.cassandra.config.EncryptionOptions$ServerEncryptionOptions serverEncOptions;
descriptor: Lorg/apache/cassandra/config/EncryptionOptions$ServerEncryptionOptions;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
public void <init>(java.util.Set<java.net.InetAddress>, int, com.datastax.driver.core.AuthProvider, int, int, org.apache.cassandra.config.EncryptionOptions$ServerEncryptionOptions, com.datastax.driver.core.SSLOptions);
descriptor: (Ljava/util/Set;ILcom/datastax/driver/core/AuthProvider;IILorg/apache/cassandra/config/EncryptionOptions$ServerEncryptionOptions;Lcom/datastax/driver/core/SSLOptions;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=8, args_size=8
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 0: aload 0
aload 1
iload 2
aload 3
aload 7
invokespecial org.apache.cassandra.utils.NativeSSTableLoaderClient.<init>:(Ljava/util/Collection;ILcom/datastax/driver/core/AuthProvider;Lcom/datastax/driver/core/SSLOptions;)V
1: aload 0
iload 4
putfield org.apache.cassandra.tools.BulkLoader$ExternalClient.storagePort:I
2: aload 0
iload 5
putfield org.apache.cassandra.tools.BulkLoader$ExternalClient.sslStoragePort:I
3: aload 0
aload 6
putfield org.apache.cassandra.tools.BulkLoader$ExternalClient.serverEncOptions:Lorg/apache/cassandra/config/EncryptionOptions$ServerEncryptionOptions;
4: return
end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/tools/BulkLoader$ExternalClient;
0 5 1 hosts Ljava/util/Set<Ljava/net/InetAddress;>;
0 5 2 port I
0 5 3 authProvider Lcom/datastax/driver/core/AuthProvider;
0 5 4 storagePort I
0 5 5 sslStoragePort I
0 5 6 serverEncryptionOptions Lorg/apache/cassandra/config/EncryptionOptions$ServerEncryptionOptions;
0 5 7 sslOptions Lcom/datastax/driver/core/SSLOptions;
Signature: (Ljava/util/Set<Ljava/net/InetAddress;>;ILcom/datastax/driver/core/AuthProvider;IILorg/apache/cassandra/config/EncryptionOptions$ServerEncryptionOptions;Lcom/datastax/driver/core/SSLOptions;)V
MethodParameters:
Name Flags
hosts
port
authProvider
storagePort
sslStoragePort
serverEncryptionOptions
sslOptions
public org.apache.cassandra.streaming.StreamConnectionFactory getConnectionFactory();
descriptor: ()Lorg/apache/cassandra/streaming/StreamConnectionFactory;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=1, args_size=1
start local 0 0: new org.apache.cassandra.tools.BulkLoadConnectionFactory
dup
aload 0
getfield org.apache.cassandra.tools.BulkLoader$ExternalClient.storagePort:I
aload 0
getfield org.apache.cassandra.tools.BulkLoader$ExternalClient.sslStoragePort:I
aload 0
getfield org.apache.cassandra.tools.BulkLoader$ExternalClient.serverEncOptions:Lorg/apache/cassandra/config/EncryptionOptions$ServerEncryptionOptions;
iconst_0
invokespecial org.apache.cassandra.tools.BulkLoadConnectionFactory.<init>:(IILorg/apache/cassandra/config/EncryptionOptions$ServerEncryptionOptions;Z)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/BulkLoader$ExternalClient;
}
SourceFile: "BulkLoader.java"
NestHost: org.apache.cassandra.tools.BulkLoader
InnerClasses:
public ServerEncryptionOptions = org.apache.cassandra.config.EncryptionOptions$ServerEncryptionOptions of org.apache.cassandra.config.EncryptionOptions
ExternalClient = org.apache.cassandra.tools.BulkLoader$ExternalClient of org.apache.cassandra.tools.BulkLoader