public class org.apache.cassandra.cql3.CustomPayloadMirroringQueryHandler implements org.apache.cassandra.cql3.QueryHandler
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.cql3.CustomPayloadMirroringQueryHandler
super_class: java.lang.Object
{
static org.apache.cassandra.cql3.QueryProcessor queryProcessor;
descriptor: Lorg/apache/cassandra/cql3/QueryProcessor;
flags: (0x0008) ACC_STATIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic org.apache.cassandra.cql3.QueryProcessor.instance:Lorg/apache/cassandra/cql3/QueryProcessor;
putstatic org.apache.cassandra.cql3.CustomPayloadMirroringQueryHandler.queryProcessor:Lorg/apache/cassandra/cql3/QueryProcessor;
return
LocalVariableTable:
Start End Slot Name Signature
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/cql3/CustomPayloadMirroringQueryHandler;
public org.apache.cassandra.transport.messages.ResultMessage process(java.lang.String, org.apache.cassandra.service.QueryState, org.apache.cassandra.cql3.QueryOptions, java.util.Map<java.lang.String, java.nio.ByteBuffer>, long);
descriptor: (Ljava/lang/String;Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/QueryOptions;Ljava/util/Map;J)Lorg/apache/cassandra/transport/messages/ResultMessage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=8, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: getstatic org.apache.cassandra.cql3.CustomPayloadMirroringQueryHandler.queryProcessor:Lorg/apache/cassandra/cql3/QueryProcessor;
aload 1
aload 2
aload 3
aload 4
lload 5
invokevirtual org.apache.cassandra.cql3.QueryProcessor.process:(Ljava/lang/String;Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/QueryOptions;Ljava/util/Map;J)Lorg/apache/cassandra/transport/messages/ResultMessage;
astore 7
start local 7 1: aload 7
aload 4
invokevirtual org.apache.cassandra.transport.messages.ResultMessage.setCustomPayload:(Ljava/util/Map;)V
2: aload 7
areturn
end local 7 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 3 0 this Lorg/apache/cassandra/cql3/CustomPayloadMirroringQueryHandler;
0 3 1 query Ljava/lang/String;
0 3 2 state Lorg/apache/cassandra/service/QueryState;
0 3 3 options Lorg/apache/cassandra/cql3/QueryOptions;
0 3 4 customPayload Ljava/util/Map<Ljava/lang/String;Ljava/nio/ByteBuffer;>;
0 3 5 queryStartNanoTime J
1 3 7 result Lorg/apache/cassandra/transport/messages/ResultMessage;
Signature: (Ljava/lang/String;Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/QueryOptions;Ljava/util/Map<Ljava/lang/String;Ljava/nio/ByteBuffer;>;J)Lorg/apache/cassandra/transport/messages/ResultMessage;
MethodParameters:
Name Flags
query
state
options
customPayload
queryStartNanoTime
public org.apache.cassandra.transport.messages.ResultMessage$Prepared prepare(java.lang.String, org.apache.cassandra.service.QueryState, java.util.Map<java.lang.String, java.nio.ByteBuffer>);
descriptor: (Ljava/lang/String;Lorg/apache/cassandra/service/QueryState;Ljava/util/Map;)Lorg/apache/cassandra/transport/messages/ResultMessage$Prepared;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: getstatic org.apache.cassandra.cql3.CustomPayloadMirroringQueryHandler.queryProcessor:Lorg/apache/cassandra/cql3/QueryProcessor;
aload 1
aload 2
aload 3
invokevirtual org.apache.cassandra.cql3.QueryProcessor.prepare:(Ljava/lang/String;Lorg/apache/cassandra/service/QueryState;Ljava/util/Map;)Lorg/apache/cassandra/transport/messages/ResultMessage$Prepared;
astore 4
start local 4 1: aload 4
aload 3
invokevirtual org.apache.cassandra.transport.messages.ResultMessage$Prepared.setCustomPayload:(Ljava/util/Map;)V
2: aload 4
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/cql3/CustomPayloadMirroringQueryHandler;
0 3 1 query Ljava/lang/String;
0 3 2 state Lorg/apache/cassandra/service/QueryState;
0 3 3 customPayload Ljava/util/Map<Ljava/lang/String;Ljava/nio/ByteBuffer;>;
1 3 4 prepared Lorg/apache/cassandra/transport/messages/ResultMessage$Prepared;
Signature: (Ljava/lang/String;Lorg/apache/cassandra/service/QueryState;Ljava/util/Map<Ljava/lang/String;Ljava/nio/ByteBuffer;>;)Lorg/apache/cassandra/transport/messages/ResultMessage$Prepared;
MethodParameters:
Name Flags
query
state
customPayload
public org.apache.cassandra.cql3.statements.ParsedStatement$Prepared getPrepared(org.apache.cassandra.utils.MD5Digest);
descriptor: (Lorg/apache/cassandra/utils/MD5Digest;)Lorg/apache/cassandra/cql3/statements/ParsedStatement$Prepared;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.cql3.CustomPayloadMirroringQueryHandler.queryProcessor:Lorg/apache/cassandra/cql3/QueryProcessor;
aload 1
invokevirtual org.apache.cassandra.cql3.QueryProcessor.getPrepared:(Lorg/apache/cassandra/utils/MD5Digest;)Lorg/apache/cassandra/cql3/statements/ParsedStatement$Prepared;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/CustomPayloadMirroringQueryHandler;
0 1 1 id Lorg/apache/cassandra/utils/MD5Digest;
MethodParameters:
Name Flags
id
public org.apache.cassandra.cql3.statements.ParsedStatement$Prepared getPreparedForThrift(java.lang.Integer);
descriptor: (Ljava/lang/Integer;)Lorg/apache/cassandra/cql3/statements/ParsedStatement$Prepared;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.cql3.CustomPayloadMirroringQueryHandler.queryProcessor:Lorg/apache/cassandra/cql3/QueryProcessor;
aload 1
invokevirtual org.apache.cassandra.cql3.QueryProcessor.getPreparedForThrift:(Ljava/lang/Integer;)Lorg/apache/cassandra/cql3/statements/ParsedStatement$Prepared;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/CustomPayloadMirroringQueryHandler;
0 1 1 id Ljava/lang/Integer;
MethodParameters:
Name Flags
id
public org.apache.cassandra.transport.messages.ResultMessage processPrepared(org.apache.cassandra.cql3.CQLStatement, org.apache.cassandra.service.QueryState, org.apache.cassandra.cql3.QueryOptions, java.util.Map<java.lang.String, java.nio.ByteBuffer>, long);
descriptor: (Lorg/apache/cassandra/cql3/CQLStatement;Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/QueryOptions;Ljava/util/Map;J)Lorg/apache/cassandra/transport/messages/ResultMessage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=8, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: getstatic org.apache.cassandra.cql3.CustomPayloadMirroringQueryHandler.queryProcessor:Lorg/apache/cassandra/cql3/QueryProcessor;
aload 1
aload 2
aload 3
aload 4
lload 5
invokevirtual org.apache.cassandra.cql3.QueryProcessor.processPrepared:(Lorg/apache/cassandra/cql3/CQLStatement;Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/QueryOptions;Ljava/util/Map;J)Lorg/apache/cassandra/transport/messages/ResultMessage;
astore 7
start local 7 1: aload 7
aload 4
invokevirtual org.apache.cassandra.transport.messages.ResultMessage.setCustomPayload:(Ljava/util/Map;)V
2: aload 7
areturn
end local 7 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 3 0 this Lorg/apache/cassandra/cql3/CustomPayloadMirroringQueryHandler;
0 3 1 statement Lorg/apache/cassandra/cql3/CQLStatement;
0 3 2 state Lorg/apache/cassandra/service/QueryState;
0 3 3 options Lorg/apache/cassandra/cql3/QueryOptions;
0 3 4 customPayload Ljava/util/Map<Ljava/lang/String;Ljava/nio/ByteBuffer;>;
0 3 5 queryStartNanoTime J
1 3 7 result Lorg/apache/cassandra/transport/messages/ResultMessage;
Signature: (Lorg/apache/cassandra/cql3/CQLStatement;Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/QueryOptions;Ljava/util/Map<Ljava/lang/String;Ljava/nio/ByteBuffer;>;J)Lorg/apache/cassandra/transport/messages/ResultMessage;
MethodParameters:
Name Flags
statement
state
options
customPayload
queryStartNanoTime
public org.apache.cassandra.transport.messages.ResultMessage processBatch(org.apache.cassandra.cql3.statements.BatchStatement, org.apache.cassandra.service.QueryState, org.apache.cassandra.cql3.BatchQueryOptions, java.util.Map<java.lang.String, java.nio.ByteBuffer>, long);
descriptor: (Lorg/apache/cassandra/cql3/statements/BatchStatement;Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/BatchQueryOptions;Ljava/util/Map;J)Lorg/apache/cassandra/transport/messages/ResultMessage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=8, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: getstatic org.apache.cassandra.cql3.CustomPayloadMirroringQueryHandler.queryProcessor:Lorg/apache/cassandra/cql3/QueryProcessor;
aload 1
aload 2
aload 3
aload 4
lload 5
invokevirtual org.apache.cassandra.cql3.QueryProcessor.processBatch:(Lorg/apache/cassandra/cql3/statements/BatchStatement;Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/BatchQueryOptions;Ljava/util/Map;J)Lorg/apache/cassandra/transport/messages/ResultMessage;
astore 7
start local 7 1: aload 7
aload 4
invokevirtual org.apache.cassandra.transport.messages.ResultMessage.setCustomPayload:(Ljava/util/Map;)V
2: aload 7
areturn
end local 7 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 3 0 this Lorg/apache/cassandra/cql3/CustomPayloadMirroringQueryHandler;
0 3 1 statement Lorg/apache/cassandra/cql3/statements/BatchStatement;
0 3 2 state Lorg/apache/cassandra/service/QueryState;
0 3 3 options Lorg/apache/cassandra/cql3/BatchQueryOptions;
0 3 4 customPayload Ljava/util/Map<Ljava/lang/String;Ljava/nio/ByteBuffer;>;
0 3 5 queryStartNanoTime J
1 3 7 result Lorg/apache/cassandra/transport/messages/ResultMessage;
Signature: (Lorg/apache/cassandra/cql3/statements/BatchStatement;Lorg/apache/cassandra/service/QueryState;Lorg/apache/cassandra/cql3/BatchQueryOptions;Ljava/util/Map<Ljava/lang/String;Ljava/nio/ByteBuffer;>;J)Lorg/apache/cassandra/transport/messages/ResultMessage;
MethodParameters:
Name Flags
statement
state
options
customPayload
queryStartNanoTime
}
SourceFile: "CustomPayloadMirroringQueryHandler.java"
InnerClasses:
public Prepared = org.apache.cassandra.cql3.statements.ParsedStatement$Prepared of org.apache.cassandra.cql3.statements.ParsedStatement
public Prepared = org.apache.cassandra.transport.messages.ResultMessage$Prepared of org.apache.cassandra.transport.messages.ResultMessage