public class examples.CassandraClientExamples
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: examples.CassandraClientExamples
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 Lexamples/CassandraClientExamples;
public void specifyingNodes(io.vertx.core.Vertx);
descriptor: (Lio/vertx/core/Vertx;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: new io.vertx.cassandra.CassandraClientOptions
dup
invokespecial io.vertx.cassandra.CassandraClientOptions.<init>:()V
1: ldc "node1.address"
sipush 9142
invokevirtual io.vertx.cassandra.CassandraClientOptions.addContactPoint:(Ljava/lang/String;I)Lio/vertx/cassandra/CassandraClientOptions;
2: ldc "node2.address"
sipush 9142
invokevirtual io.vertx.cassandra.CassandraClientOptions.addContactPoint:(Ljava/lang/String;I)Lio/vertx/cassandra/CassandraClientOptions;
3: ldc "node3.address"
sipush 9142
invokevirtual io.vertx.cassandra.CassandraClientOptions.addContactPoint:(Ljava/lang/String;I)Lio/vertx/cassandra/CassandraClientOptions;
4: astore 2
start local 2 5: aload 1
aload 2
invokestatic io.vertx.cassandra.CassandraClient.create:(Lio/vertx/core/Vertx;Lio/vertx/cassandra/CassandraClientOptions;)Lio/vertx/cassandra/CassandraClient;
pop
6: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lexamples/CassandraClientExamples;
0 7 1 vertx Lio/vertx/core/Vertx;
5 7 2 options Lio/vertx/cassandra/CassandraClientOptions;
MethodParameters:
Name Flags
vertx
public void portAndKeyspace(io.vertx.core.Vertx);
descriptor: (Lio/vertx/core/Vertx;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: new io.vertx.cassandra.CassandraClientOptions
dup
invokespecial io.vertx.cassandra.CassandraClientOptions.<init>:()V
1: ldc "localhost"
sipush 9142
invokevirtual io.vertx.cassandra.CassandraClientOptions.addContactPoint:(Ljava/lang/String;I)Lio/vertx/cassandra/CassandraClientOptions;
2: ldc "my_keyspace"
invokevirtual io.vertx.cassandra.CassandraClientOptions.setKeyspace:(Ljava/lang/String;)Lio/vertx/cassandra/CassandraClientOptions;
3: astore 2
start local 2 4: aload 1
aload 2
invokestatic io.vertx.cassandra.CassandraClient.create:(Lio/vertx/core/Vertx;Lio/vertx/cassandra/CassandraClientOptions;)Lio/vertx/cassandra/CassandraClient;
pop
5: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lexamples/CassandraClientExamples;
0 6 1 vertx Lio/vertx/core/Vertx;
4 6 2 options Lio/vertx/cassandra/CassandraClientOptions;
MethodParameters:
Name Flags
vertx
public void sharedClient(io.vertx.core.Vertx);
descriptor: (Lio/vertx/core/Vertx;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: new io.vertx.cassandra.CassandraClientOptions
dup
invokespecial io.vertx.cassandra.CassandraClientOptions.<init>:()V
1: ldc "node1.address"
sipush 9142
invokevirtual io.vertx.cassandra.CassandraClientOptions.addContactPoint:(Ljava/lang/String;I)Lio/vertx/cassandra/CassandraClientOptions;
2: ldc "node2.address"
sipush 9142
invokevirtual io.vertx.cassandra.CassandraClientOptions.addContactPoint:(Ljava/lang/String;I)Lio/vertx/cassandra/CassandraClientOptions;
3: ldc "node3.address"
sipush 9142
invokevirtual io.vertx.cassandra.CassandraClientOptions.addContactPoint:(Ljava/lang/String;I)Lio/vertx/cassandra/CassandraClientOptions;
4: ldc "my_keyspace"
invokevirtual io.vertx.cassandra.CassandraClientOptions.setKeyspace:(Ljava/lang/String;)Lio/vertx/cassandra/CassandraClientOptions;
5: astore 2
start local 2 6: aload 1
ldc "sharedClientName"
aload 2
invokestatic io.vertx.cassandra.CassandraClient.createShared:(Lio/vertx/core/Vertx;Ljava/lang/String;Lio/vertx/cassandra/CassandraClientOptions;)Lio/vertx/cassandra/CassandraClient;
pop
7: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lexamples/CassandraClientExamples;
0 8 1 vertx Lio/vertx/core/Vertx;
6 8 2 options Lio/vertx/cassandra/CassandraClientOptions;
MethodParameters:
Name Flags
vertx
public void lowLevelQuerying(io.vertx.cassandra.CassandraClient);
descriptor: (Lio/vertx/cassandra/CassandraClient;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "SELECT * FROM my_keyspace.my_table where my_key = 'my_value'"
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/CassandraClientExamples.lambda$0(Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.cassandra.CassandraClient.execute:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lexamples/CassandraClientExamples;
0 2 1 cassandraClient Lio/vertx/cassandra/CassandraClient;
MethodParameters:
Name Flags
cassandraClient
public void executeAndCollect(io.vertx.cassandra.CassandraClient, java.util.stream.Collector<com.datastax.oss.driver.api.core.cql.Row, ?, java.lang.String>);
descriptor: (Lio/vertx/cassandra/CassandraClient;Ljava/util/stream/Collector;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
ldc "SELECT * FROM users"
aload 2
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/CassandraClientExamples.lambda$2(Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.cassandra.CassandraClient.execute:(Ljava/lang/String;Ljava/util/stream/Collector;Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
pop
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lexamples/CassandraClientExamples;
0 2 1 cassandraClient Lio/vertx/cassandra/CassandraClient;
0 2 2 listCollector Ljava/util/stream/Collector<Lcom/datastax/oss/driver/api/core/cql/Row;*Ljava/lang/String;>;
Signature: (Lio/vertx/cassandra/CassandraClient;Ljava/util/stream/Collector<Lcom/datastax/oss/driver/api/core/cql/Row;*Ljava/lang/String;>;)V
MethodParameters:
Name Flags
cassandraClient
listCollector
public void streamingViaHttp(io.vertx.core.Vertx, io.vertx.cassandra.CassandraClient, io.vertx.core.http.HttpServerResponse);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/cassandra/CassandraClient;Lio/vertx/core/http/HttpServerResponse;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 2
ldc "SELECT my_string_col FROM my_keyspace.my_table where my_key = 'my_value'"
aload 3
invokedynamic handle(Lio/vertx/core/http/HttpServerResponse;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/CassandraClientExamples.lambda$3(Lio/vertx/core/http/HttpServerResponse;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.cassandra.CassandraClient.queryStream:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
pop
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lexamples/CassandraClientExamples;
0 2 1 vertx Lio/vertx/core/Vertx;
0 2 2 cassandraClient Lio/vertx/cassandra/CassandraClient;
0 2 3 response Lio/vertx/core/http/HttpServerResponse;
MethodParameters:
Name Flags
vertx
cassandraClient
response
public void fetchAll(io.vertx.cassandra.CassandraClient);
descriptor: (Lio/vertx/cassandra/CassandraClient;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "SELECT * FROM my_keyspace.my_table where my_key = 'my_value'"
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/CassandraClientExamples.lambda$7(Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.cassandra.CassandraClient.executeWithFullFetch:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lexamples/CassandraClientExamples;
0 2 1 cassandraClient Lio/vertx/cassandra/CassandraClient;
MethodParameters:
Name Flags
cassandraClient
public void prepareQuery(io.vertx.cassandra.CassandraClient);
descriptor: (Lio/vertx/cassandra/CassandraClient;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "SELECT * FROM my_keyspace.my_table where my_key = ? "
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/CassandraClientExamples.lambda$8(Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.cassandra.CassandraClient.prepare:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lexamples/CassandraClientExamples;
0 2 1 cassandraClient Lio/vertx/cassandra/CassandraClient;
MethodParameters:
Name Flags
cassandraClient
public void usingPreparedStatementFuture(io.vertx.cassandra.CassandraClient, com.datastax.oss.driver.api.core.cql.PreparedStatement);
descriptor: (Lio/vertx/cassandra/CassandraClient;Lcom/datastax/oss/driver/api/core/cql/PreparedStatement;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
aload 2
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "my_value"
aastore
invokeinterface com.datastax.oss.driver.api.core.cql.PreparedStatement.bind:([Ljava/lang/Object;)Lcom/datastax/oss/driver/api/core/cql/BoundStatement;
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/CassandraClientExamples.lambda$9(Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.cassandra.CassandraClient.execute:(Lcom/datastax/oss/driver/api/core/cql/Statement;Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
pop
1: aload 1
aload 2
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "my_value"
aastore
invokeinterface com.datastax.oss.driver.api.core.cql.PreparedStatement.bind:([Ljava/lang/Object;)Lcom/datastax/oss/driver/api/core/cql/BoundStatement;
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/CassandraClientExamples.lambda$10(Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.cassandra.CassandraClient.executeWithFullFetch:(Lcom/datastax/oss/driver/api/core/cql/Statement;Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
pop
2: aload 1
aload 2
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "my_value"
aastore
invokeinterface com.datastax.oss.driver.api.core.cql.PreparedStatement.bind:([Ljava/lang/Object;)Lcom/datastax/oss/driver/api/core/cql/BoundStatement;
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/CassandraClientExamples.lambda$11(Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.cassandra.CassandraClient.queryStream:(Lcom/datastax/oss/driver/api/core/cql/Statement;Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
pop
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lexamples/CassandraClientExamples;
0 4 1 cassandraClient Lio/vertx/cassandra/CassandraClient;
0 4 2 preparedStatement Lcom/datastax/oss/driver/api/core/cql/PreparedStatement;
MethodParameters:
Name Flags
cassandraClient
preparedStatement
public void batching(io.vertx.cassandra.CassandraClient);
descriptor: (Lio/vertx/cassandra/CassandraClient;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: getstatic com.datastax.oss.driver.api.core.cql.BatchType.LOGGED:Lcom/datastax/oss/driver/api/core/cql/BatchType;
invokestatic com.datastax.oss.driver.api.core.cql.BatchStatement.newInstance:(Lcom/datastax/oss/driver/api/core/cql/BatchType;)Lcom/datastax/oss/driver/api/core/cql/BatchStatement;
1: ldc "INSERT INTO NAMES (name) VALUES ('Pavel')"
invokestatic com.datastax.oss.driver.api.core.cql.SimpleStatement.newInstance:(Ljava/lang/String;)Lcom/datastax/oss/driver/api/core/cql/SimpleStatement;
invokeinterface com.datastax.oss.driver.api.core.cql.BatchStatement.add:(Lcom/datastax/oss/driver/api/core/cql/BatchableStatement;)Lcom/datastax/oss/driver/api/core/cql/BatchStatement;
2: ldc "INSERT INTO NAMES (name) VALUES ('Thomas')"
invokestatic com.datastax.oss.driver.api.core.cql.SimpleStatement.newInstance:(Ljava/lang/String;)Lcom/datastax/oss/driver/api/core/cql/SimpleStatement;
invokeinterface com.datastax.oss.driver.api.core.cql.BatchStatement.add:(Lcom/datastax/oss/driver/api/core/cql/BatchableStatement;)Lcom/datastax/oss/driver/api/core/cql/BatchStatement;
3: ldc "INSERT INTO NAMES (name) VALUES ('Julien')"
invokestatic com.datastax.oss.driver.api.core.cql.SimpleStatement.newInstance:(Ljava/lang/String;)Lcom/datastax/oss/driver/api/core/cql/SimpleStatement;
invokeinterface com.datastax.oss.driver.api.core.cql.BatchStatement.add:(Lcom/datastax/oss/driver/api/core/cql/BatchableStatement;)Lcom/datastax/oss/driver/api/core/cql/BatchStatement;
4: astore 2
start local 2 5: aload 1
aload 2
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/CassandraClientExamples.lambda$12(Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.cassandra.CassandraClient.execute:(Lcom/datastax/oss/driver/api/core/cql/Statement;Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
pop
6: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lexamples/CassandraClientExamples;
0 7 1 cassandraClient Lio/vertx/cassandra/CassandraClient;
5 7 2 batchStatement Lcom/datastax/oss/driver/api/core/cql/BatchStatement;
MethodParameters:
Name Flags
cassandraClient
private static void lambda$0(io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 11
1: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.cassandra.ResultSet
astore 1
start local 1 2: aload 1
invokeinterface io.vertx.cassandra.ResultSet.remaining:()I
ifeq 6
3: aload 1
invokeinterface io.vertx.cassandra.ResultSet.one:()Lcom/datastax/oss/driver/api/core/cql/Row;
pop
4: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "One row successfully fetched"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
5: goto 13
StackMap locals: io.vertx.cassandra.ResultSet
StackMap stack:
6: aload 1
invokeinterface io.vertx.cassandra.ResultSet.hasMorePages:()Z
ifne 9
7: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "No pages to fetch"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
8: goto 13
9: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.vertx.cassandra.ResultSet.fetchNextPage:()Lio/vertx/core/Future;
aload 1
invokedynamic handle(Lio/vertx/cassandra/ResultSet;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/CassandraClientExamples.lambda$1(Lio/vertx/cassandra/ResultSet;Lio/vertx/core/AsyncResult;)V (6)
(Lio/vertx/core/AsyncResult;)V
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
end local 1 10: goto 13
11: StackMap locals:
StackMap stack:
getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Unable to execute the query"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
12: aload 0
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokevirtual java.lang.Throwable.printStackTrace:()V
13: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 execute Lio/vertx/core/AsyncResult<Lio/vertx/cassandra/ResultSet;>;
2 10 1 resultSet Lio/vertx/cassandra/ResultSet;
private static void lambda$2(io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=2, args_size=1
start local 0 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 4
1: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast java.lang.String
astore 1
start local 1 2: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "Got "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
end local 1 3: goto 5
4: StackMap locals:
StackMap stack:
getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "Failure: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
5: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 ar Lio/vertx/core/AsyncResult<Ljava/lang/String;>;
2 3 1 list Ljava/lang/String;
private static void lambda$3(io.vertx.core.http.HttpServerResponse, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/http/HttpServerResponse;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=2
start local 1 0: aload 1
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 6
1: aload 1
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.cassandra.CassandraRowStream
astore 2
start local 2 2: aload 0
aload 2
invokedynamic handle(Lio/vertx/cassandra/CassandraRowStream;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/CassandraClientExamples.lambda$4(Lio/vertx/cassandra/CassandraRowStream;Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.http.HttpServerResponse.drainHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpServerResponse;
pop
3: aload 2
aload 0
aload 2
invokedynamic handle(Lio/vertx/core/http/HttpServerResponse;Lio/vertx/cassandra/CassandraRowStream;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/CassandraClientExamples.lambda$5(Lio/vertx/core/http/HttpServerResponse;Lio/vertx/cassandra/CassandraRowStream;Lcom/datastax/oss/driver/api/core/cql/Row;)V (6)
(Lcom/datastax/oss/driver/api/core/cql/Row;)V
invokeinterface io.vertx.cassandra.CassandraRowStream.handler:(Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraRowStream;
pop
4: aload 2
aload 0
invokedynamic handle(Lio/vertx/core/http/HttpServerResponse;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/CassandraClientExamples.lambda$6(Lio/vertx/core/http/HttpServerResponse;Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.cassandra.CassandraRowStream.endHandler:(Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraRowStream;
pop
end local 2 5: goto 10
6: StackMap locals:
StackMap stack:
aload 1
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokevirtual java.lang.Throwable.printStackTrace:()V
7: aload 0
8: sipush 500
invokeinterface io.vertx.core.http.HttpServerResponse.setStatusCode:(I)Lio/vertx/core/http/HttpServerResponse;
9: ldc "Unable to execute the query"
invokeinterface io.vertx.core.http.HttpServerResponse.end:(Ljava/lang/String;)Lio/vertx/core/Future;
pop
10: StackMap locals:
StackMap stack:
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 11 1 queryStream Lio/vertx/core/AsyncResult<Lio/vertx/cassandra/CassandraRowStream;>;
2 5 2 stream Lio/vertx/cassandra/CassandraRowStream;
private static void lambda$7(io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=1
start local 0 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 6
1: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast java.util.List
astore 1
start local 1 2: aload 1
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 2
goto 4
StackMap locals: java.util.List java.util.Iterator
StackMap stack:
3: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.cql.Row
pop
StackMap locals:
StackMap stack:
4: aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
end local 1 5: goto 8
6: StackMap locals:
StackMap stack:
getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Unable to execute the query"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
7: aload 0
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokevirtual java.lang.Throwable.printStackTrace:()V
8: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 executeWithFullFetch Lio/vertx/core/AsyncResult<Ljava/util/List<Lcom/datastax/oss/driver/api/core/cql/Row;>;>;
2 5 1 rows Ljava/util/List<Lcom/datastax/oss/driver/api/core/cql/Row;>;
private static void lambda$8(io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 4
1: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "The query has successfully been prepared"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
2: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.cql.PreparedStatement
pop
3: goto 6
4: StackMap locals:
StackMap stack:
getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Unable to prepare the query"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
5: aload 0
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokevirtual java.lang.Throwable.printStackTrace:()V
6: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 preparedStatementResult Lio/vertx/core/AsyncResult<Lcom/datastax/oss/driver/api/core/cql/PreparedStatement;>;
private static void lambda$9(io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.cassandra.ResultSet
pop
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 done Lio/vertx/core/AsyncResult<Lio/vertx/cassandra/ResultSet;>;
private static void lambda$10(io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast java.util.List
pop
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 done Lio/vertx/core/AsyncResult<Ljava/util/List<Lcom/datastax/oss/driver/api/core/cql/Row;>;>;
private static void lambda$11(io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
checkcast io.vertx.cassandra.CassandraRowStream
pop
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 done Lio/vertx/core/AsyncResult<Lio/vertx/cassandra/CassandraRowStream;>;
private static void lambda$12(io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 3
1: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "The given batch executed successfully"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
2: goto 5
3: StackMap locals:
StackMap stack:
getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Unable to execute the batch"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
4: aload 0
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokevirtual java.lang.Throwable.printStackTrace:()V
5: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 result Lio/vertx/core/AsyncResult<Lio/vertx/cassandra/ResultSet;>;
private static void lambda$1(io.vertx.cassandra.ResultSet, io.vertx.core.AsyncResult);
descriptor: (Lio/vertx/cassandra/ResultSet;Lio/vertx/core/AsyncResult;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=3, args_size=2
start local 1 0: aload 1
invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
ifeq 4
1: aload 0
invokeinterface io.vertx.cassandra.ResultSet.remaining:()I
istore 2
start local 2 2: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "Now we have "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
iload 2
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc " rows fetched, but not consumed!"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
end local 2 3: goto 6
4: StackMap locals:
StackMap stack:
getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Unable to fetch more results"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
5: aload 1
invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
invokevirtual java.lang.Throwable.printStackTrace:()V
6: StackMap locals:
StackMap stack:
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 7 1 fetchMoreResults Lio/vertx/core/AsyncResult<Lio/vertx/cassandra/ResultSet;>;
2 3 2 availableWithoutFetching I
private static void lambda$4(io.vertx.cassandra.CassandraRowStream, java.lang.Void);
descriptor: (Lio/vertx/cassandra/CassandraRowStream;Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 1 0: aload 0
invokeinterface io.vertx.cassandra.CassandraRowStream.resume:()Lio/vertx/cassandra/CassandraRowStream;
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 v Ljava/lang/Void;
private static void lambda$5(io.vertx.core.http.HttpServerResponse, io.vertx.cassandra.CassandraRowStream, com.datastax.oss.driver.api.core.cql.Row);
descriptor: (Lio/vertx/core/http/HttpServerResponse;Lio/vertx/cassandra/CassandraRowStream;Lcom/datastax/oss/driver/api/core/cql/Row;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=4, args_size=3
start local 2 0: aload 2
ldc "my_string_col"
invokeinterface com.datastax.oss.driver.api.core.cql.Row.getString:(Ljava/lang/String;)Ljava/lang/String;
astore 3
start local 3 1: aload 0
aload 3
invokeinterface io.vertx.core.http.HttpServerResponse.write:(Ljava/lang/String;)Lio/vertx/core/Future;
pop
2: aload 0
invokeinterface io.vertx.core.http.HttpServerResponse.writeQueueFull:()Z
ifeq 4
3: aload 1
invokeinterface io.vertx.cassandra.CassandraRowStream.pause:()Lio/vertx/cassandra/CassandraRowStream;
pop
end local 3 4: StackMap locals:
StackMap stack:
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 5 2 row Lcom/datastax/oss/driver/api/core/cql/Row;
1 4 3 value Ljava/lang/String;
private static void lambda$6(io.vertx.core.http.HttpServerResponse, java.lang.Void);
descriptor: (Lio/vertx/core/http/HttpServerResponse;Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 1 0: aload 0
invokeinterface io.vertx.core.http.HttpServerResponse.end:()Lio/vertx/core/Future;
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 end Ljava/lang/Void;
}
SourceFile: "CassandraClientExamples.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles