public class oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl extends java.lang.Object implements oadd.org.apache.calcite.avatica.remote.ProtobufTranslation
{
private static final org.slf4j.Logger LOG;
private static final java.util.Map REQUEST_PARSERS;
private static final java.util.Map RESPONSE_PARSERS;
private static final java.util.Map MESSAGE_CLASSES;
private final java.lang.ThreadLocal threadLocalBuffer;
public void <init>()
{
oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$1 v;
oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl v;
v := @this: oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$1;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$1: void <init>(oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl)>(v);
v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: java.lang.ThreadLocal threadLocalBuffer> = v;
return;
}
private static java.util.List getAllMessageClasses()
{
java.util.ArrayList v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Requests$CatalogsRequest;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Requests$CloseConnectionRequest;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Requests$CloseStatementRequest;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Requests$ColumnsRequest;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Requests$CommitRequest;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Requests$ConnectionSyncRequest;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Requests$CreateStatementRequest;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Requests$DatabasePropertyRequest;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Requests$ExecuteRequest;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Requests$FetchRequest;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Requests$OpenConnectionRequest;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Requests$PrepareAndExecuteRequest;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Requests$PrepareRequest;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Requests$RollbackRequest;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Requests$SchemasRequest;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Requests$SyncResultsRequest;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Requests$TableTypesRequest;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Requests$TablesRequest;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Requests$TypeInfoRequest;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Requests$PrepareAndExecuteBatchRequest;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Requests$ExecuteBatchRequest;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Responses$CloseConnectionResponse;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Responses$CloseStatementResponse;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Responses$CommitResponse;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Responses$ConnectionSyncResponse;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Responses$CreateStatementResponse;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Responses$DatabasePropertyResponse;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Responses$ErrorResponse;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Responses$ExecuteResponse;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Responses$FetchResponse;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Responses$OpenConnectionResponse;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Responses$PrepareResponse;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Responses$ResultSetResponse;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Responses$RollbackResponse;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Responses$RpcMetadata;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Responses$SyncResultsResponse;");
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(class "Loadd/org/apache/calcite/avatica/proto/Responses$ExecuteBatchResponse;");
return v;
}
private static oadd.com.google.protobuf.ByteString wrapClassName(java.lang.Class)
{
byte[] v;
java.nio.charset.Charset v;
java.lang.Class v;
java.lang.String v;
oadd.com.google.protobuf.ByteString v;
v := @parameter: java.lang.Class;
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = staticinvoke <oadd.com.google.protobuf.UnsafeByteOperations: oadd.com.google.protobuf.ByteString unsafeWrap(byte[])>(v);
return v;
}
public static oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator getParserForRequest(java.lang.String)
{
java.lang.IllegalArgumentException v, v;
java.util.Map v;
java.lang.Object v;
java.lang.String v, v, v, v;
boolean v;
v := @parameter: java.lang.String;
if null == v goto label;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
label:
v = new java.lang.IllegalArgumentException;
if null != v goto label;
v = "null";
goto label;
label:
v = "missing";
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Cannot fetch parser for Request with \u class name");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = <oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: java.util.Map REQUEST_PARSERS>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if null != v goto label;
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Cannot find request parser for \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public static oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator getParserForResponse(java.lang.String)
{
java.lang.IllegalArgumentException v, v;
java.util.Map v;
java.lang.Object v;
java.lang.String v, v, v, v;
boolean v;
v := @parameter: java.lang.String;
if null == v goto label;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
label:
v = new java.lang.IllegalArgumentException;
if null != v goto label;
v = "null";
goto label;
label:
v = "missing";
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Cannot fetch parser for Response with \u class name");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = <oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: java.util.Map RESPONSE_PARSERS>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if null != v goto label;
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Cannot find response parser for \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public byte[] serializeResponse(oadd.org.apache.calcite.avatica.remote.Service$Response) throws java.io.IOException
{
java.lang.Throwable v;
byte[] v;
java.lang.ThreadLocal v;
org.slf4j.Logger v, v;
oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl v;
java.lang.Class v;
java.lang.Object v;
java.lang.String v, v;
oadd.com.google.protobuf.Message v;
oadd.org.apache.calcite.avatica.remote.Service$Response v;
boolean v;
v := @this: oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl;
v := @parameter: oadd.org.apache.calcite.avatica.remote.Service$Response;
v = v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: java.lang.ThreadLocal threadLocalBuffer>;
v = virtualinvoke v.<java.lang.ThreadLocal: java.lang.Object get()>();
label:
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$Response: oadd.com.google.protobuf.Message serialize()>();
v = <oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: org.slf4j.Logger LOG>;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = staticinvoke <oadd.com.google.protobuf.TextFormat: java.lang.String shortDebugString(oadd.com.google.protobuf.MessageOrBuilder)>(v);
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object,java.lang.Object)>("Serializing {} \'{}\'", v, v);
label:
virtualinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: void serializeMessage(java.io.OutputStream,oadd.com.google.protobuf.Message)>(v, v);
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: byte[] toArray()>();
label:
virtualinvoke v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: void reset()>();
return v;
label:
v := @caughtexception;
virtualinvoke v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: void reset()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
public byte[] serializeRequest(oadd.org.apache.calcite.avatica.remote.Service$Request) throws java.io.IOException
{
java.lang.Throwable v;
oadd.org.apache.calcite.avatica.remote.Service$Request v;
byte[] v;
java.lang.ThreadLocal v;
org.slf4j.Logger v, v;
oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl v;
java.lang.Class v;
java.lang.Object v;
java.lang.String v, v;
oadd.com.google.protobuf.Message v;
boolean v;
v := @this: oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl;
v := @parameter: oadd.org.apache.calcite.avatica.remote.Service$Request;
v = v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: java.lang.ThreadLocal threadLocalBuffer>;
v = virtualinvoke v.<java.lang.ThreadLocal: java.lang.Object get()>();
label:
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$Request: oadd.com.google.protobuf.Message serialize()>();
v = <oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isTraceEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: org.slf4j.Logger LOG>;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = staticinvoke <oadd.com.google.protobuf.TextFormat: java.lang.String shortDebugString(oadd.com.google.protobuf.MessageOrBuilder)>(v);
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object,java.lang.Object)>("Serializing {} \'{}\'", v, v);
label:
virtualinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: void serializeMessage(java.io.OutputStream,oadd.com.google.protobuf.Message)>(v, v);
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: byte[] toArray()>();
label:
virtualinvoke v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: void reset()>();
return v;
label:
v := @caughtexception;
virtualinvoke v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: void reset()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
void serializeMessage(java.io.OutputStream, oadd.com.google.protobuf.Message) throws java.io.IOException
{
java.io.OutputStream v;
java.lang.Throwable v;
byte[] v;
java.lang.ThreadLocal v;
oadd.com.google.protobuf.ByteString v, v;
oadd.org.apache.calcite.avatica.proto.Common$WireMessage$Builder v, v, v;
oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl v;
java.lang.Class v;
java.lang.Object v;
oadd.com.google.protobuf.Message v;
oadd.org.apache.calcite.avatica.proto.Common$WireMessage v;
v := @this: oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl;
v := @parameter: java.io.OutputStream;
v := @parameter: oadd.com.google.protobuf.Message;
v = v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: java.lang.ThreadLocal threadLocalBuffer>;
v = virtualinvoke v.<java.lang.ThreadLocal: java.lang.Object get()>();
label:
interfaceinvoke v.<oadd.com.google.protobuf.Message: void writeTo(java.io.OutputStream)>(v);
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: byte[] toArray()>();
v = staticinvoke <oadd.com.google.protobuf.UnsafeByteOperations: oadd.com.google.protobuf.ByteString unsafeWrap(byte[])>(v);
label:
virtualinvoke v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: void reset()>();
goto label;
label:
v := @caughtexception;
virtualinvoke v.<oadd.org.apache.calcite.avatica.util.UnsynchronizedBuffer: void reset()>();
throw v;
label:
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Common$WireMessage: oadd.org.apache.calcite.avatica.proto.Common$WireMessage$Builder newBuilder()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: oadd.com.google.protobuf.ByteString getClassNameBytes(java.lang.Class)>(v);
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.proto.Common$WireMessage$Builder: oadd.org.apache.calcite.avatica.proto.Common$WireMessage$Builder setNameBytes(oadd.com.google.protobuf.ByteString)>(v);
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.proto.Common$WireMessage$Builder: oadd.org.apache.calcite.avatica.proto.Common$WireMessage$Builder setWrappedMessage(oadd.com.google.protobuf.ByteString)>(v);
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.proto.Common$WireMessage$Builder: oadd.org.apache.calcite.avatica.proto.Common$WireMessage build()>();
virtualinvoke v.<oadd.org.apache.calcite.avatica.proto.Common$WireMessage: void writeTo(java.io.OutputStream)>(v);
return;
catch java.lang.Throwable from label to label with label;
}
oadd.com.google.protobuf.ByteString getClassNameBytes(java.lang.Class)
{
oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl v;
java.util.Map v;
java.lang.Class v;
java.lang.Object v;
java.lang.String v, v;
java.lang.IllegalArgumentException v;
v := @this: oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl;
v := @parameter: java.lang.Class;
v = <oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: java.util.Map MESSAGE_CLASSES>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if null != v goto label;
v = new java.lang.IllegalArgumentException;
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Missing ByteString for \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public oadd.org.apache.calcite.avatica.remote.Service$Request parseRequest(byte[]) throws java.io.IOException
{
oadd.org.apache.calcite.avatica.remote.Service$Request v;
byte[] v;
org.slf4j.Logger v, v;
java.lang.RuntimeException v;
oadd.com.google.protobuf.ByteString v, v;
oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator v;
oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl v;
oadd.com.google.protobuf.CodedInputStream v;
java.lang.String v, v;
oadd.org.apache.calcite.avatica.proto.Common$WireMessage v;
boolean v;
v := @this: oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl;
v := @parameter: byte[];
v = staticinvoke <oadd.com.google.protobuf.UnsafeByteOperations: oadd.com.google.protobuf.ByteString unsafeWrap(byte[])>(v);
v = virtualinvoke v.<oadd.com.google.protobuf.ByteString: oadd.com.google.protobuf.CodedInputStream newCodedInput()>();
virtualinvoke v.<oadd.com.google.protobuf.CodedInputStream: void enableAliasing(boolean)>(1);
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Common$WireMessage: oadd.org.apache.calcite.avatica.proto.Common$WireMessage parseFrom(oadd.com.google.protobuf.CodedInputStream)>(v);
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.proto.Common$WireMessage: java.lang.String getName()>();
label:
v = staticinvoke <oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator getParserForRequest(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.proto.Common$WireMessage: oadd.com.google.protobuf.ByteString getWrappedMessage()>();
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: oadd.org.apache.calcite.avatica.remote.Service$Request transform(oadd.com.google.protobuf.ByteString)>(v);
label:
return v;
label:
v := @caughtexception;
v = <oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: org.slf4j.Logger LOG>;
v = staticinvoke <oadd.com.google.protobuf.TextFormat: java.lang.String shortDebugString(oadd.com.google.protobuf.MessageOrBuilder)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Failed to parse request message \'{}\'", v);
label:
throw v;
catch java.lang.RuntimeException from label to label with label;
}
public oadd.org.apache.calcite.avatica.remote.Service$Response parseResponse(byte[]) throws java.io.IOException
{
byte[] v;
org.slf4j.Logger v, v;
java.lang.RuntimeException v;
oadd.com.google.protobuf.ByteString v, v;
oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator v;
oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl v;
oadd.com.google.protobuf.CodedInputStream v;
java.lang.String v, v;
oadd.org.apache.calcite.avatica.proto.Common$WireMessage v;
oadd.org.apache.calcite.avatica.remote.Service$Response v;
boolean v;
v := @this: oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl;
v := @parameter: byte[];
v = staticinvoke <oadd.com.google.protobuf.UnsafeByteOperations: oadd.com.google.protobuf.ByteString unsafeWrap(byte[])>(v);
v = virtualinvoke v.<oadd.com.google.protobuf.ByteString: oadd.com.google.protobuf.CodedInputStream newCodedInput()>();
virtualinvoke v.<oadd.com.google.protobuf.CodedInputStream: void enableAliasing(boolean)>(1);
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Common$WireMessage: oadd.org.apache.calcite.avatica.proto.Common$WireMessage parseFrom(oadd.com.google.protobuf.CodedInputStream)>(v);
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.proto.Common$WireMessage: java.lang.String getName()>();
label:
v = staticinvoke <oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator getParserForResponse(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.proto.Common$WireMessage: oadd.com.google.protobuf.ByteString getWrappedMessage()>();
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator: oadd.org.apache.calcite.avatica.remote.Service$Response transform(oadd.com.google.protobuf.ByteString)>(v);
label:
return v;
label:
v := @caughtexception;
v = <oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: org.slf4j.Logger LOG>;
v = staticinvoke <oadd.com.google.protobuf.TextFormat: java.lang.String shortDebugString(oadd.com.google.protobuf.MessageOrBuilder)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Failed to parse response message \'{}\'", v);
label:
throw v;
catch java.lang.RuntimeException from label to label with label;
}
static void <clinit>()
{
oadd.org.apache.calcite.avatica.remote.Service$PrepareAndExecuteRequest v;
oadd.org.apache.calcite.avatica.remote.Service$OpenConnectionRequest v;
oadd.org.apache.calcite.avatica.remote.Service$ConnectionSyncResponse v;
oadd.org.apache.calcite.avatica.remote.Service$TypeInfoRequest v;
java.util.Map v, v, v;
oadd.org.apache.calcite.avatica.remote.Service$FetchResponse v;
oadd.org.apache.calcite.avatica.remote.Service$TableTypesRequest v;
oadd.org.apache.calcite.avatica.remote.Service$TablesRequest v;
oadd.org.apache.calcite.avatica.remote.Service$PrepareAndExecuteBatchRequest v;
oadd.org.apache.calcite.avatica.remote.Service$ExecuteResponse v;
oadd.com.google.protobuf.Parser v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.calcite.avatica.remote.Service$OpenConnectionResponse v;
oadd.org.apache.calcite.avatica.remote.Service$DatabasePropertyResponse v;
oadd.org.apache.calcite.avatica.remote.Service$CloseConnectionResponse v;
oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.calcite.avatica.remote.Service$CloseStatementRequest v;
oadd.org.apache.calcite.avatica.remote.Service$ColumnsRequest v;
java.util.concurrent.ConcurrentHashMap v, v, v;
oadd.com.google.protobuf.ByteString v;
oadd.org.apache.calcite.avatica.remote.Service$ExecuteBatchResponse v;
oadd.org.apache.calcite.avatica.remote.Service$CreateStatementResponse v;
oadd.org.apache.calcite.avatica.remote.Service$CloseConnectionRequest v;
oadd.org.apache.calcite.avatica.remote.Service$CommitResponse v;
oadd.org.apache.calcite.avatica.remote.Service$PrepareResponse v;
oadd.org.apache.calcite.avatica.remote.Service$SchemasRequest v;
org.slf4j.Logger v;
java.lang.Class v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Object v;
oadd.org.apache.calcite.avatica.remote.Service$PrepareRequest v;
oadd.org.apache.calcite.avatica.remote.Service$CatalogsRequest v;
oadd.org.apache.calcite.avatica.remote.Service$CommitRequest v;
oadd.org.apache.calcite.avatica.remote.Service$RpcMetadataResponse v;
oadd.org.apache.calcite.avatica.remote.Service$RollbackRequest v;
oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.calcite.avatica.remote.Service$DatabasePropertyRequest v;
oadd.org.apache.calcite.avatica.remote.Service$FetchRequest v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.calcite.avatica.remote.Service$ConnectionSyncRequest v;
oadd.org.apache.calcite.avatica.remote.Service$ResultSetResponse v;
oadd.org.apache.calcite.avatica.remote.Service$CreateStatementRequest v;
oadd.org.apache.calcite.avatica.remote.Service$ExecuteBatchRequest v;
oadd.org.apache.calcite.avatica.remote.Service$ErrorResponse v;
boolean v;
java.util.List v;
oadd.org.apache.calcite.avatica.remote.Service$SyncResultsResponse v;
oadd.org.apache.calcite.avatica.remote.Service$RollbackResponse v;
java.util.Iterator v;
oadd.org.apache.calcite.avatica.remote.Service$SyncResultsRequest v;
oadd.org.apache.calcite.avatica.remote.Service$CloseStatementResponse v;
oadd.org.apache.calcite.avatica.remote.Service$ExecuteRequest v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/calcite/avatica/remote/ProtobufTranslationImpl;");
<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: org.slf4j.Logger LOG> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v = class "Loadd/org/apache/calcite/avatica/proto/Requests$CatalogsRequest;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Requests$CatalogsRequest: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$CatalogsRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$CatalogsRequest: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Request)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Requests$OpenConnectionRequest;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Requests$OpenConnectionRequest: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$OpenConnectionRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$OpenConnectionRequest: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Request)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Requests$CloseConnectionRequest;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Requests$CloseConnectionRequest: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$CloseConnectionRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$CloseConnectionRequest: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Request)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Requests$CloseStatementRequest;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Requests$CloseStatementRequest: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$CloseStatementRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$CloseStatementRequest: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Request)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Requests$ColumnsRequest;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Requests$ColumnsRequest: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$ColumnsRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$ColumnsRequest: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Request)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Requests$ConnectionSyncRequest;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Requests$ConnectionSyncRequest: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$ConnectionSyncRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$ConnectionSyncRequest: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Request)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Requests$CreateStatementRequest;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Requests$CreateStatementRequest: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$CreateStatementRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$CreateStatementRequest: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Request)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Requests$DatabasePropertyRequest;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Requests$DatabasePropertyRequest: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$DatabasePropertyRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$DatabasePropertyRequest: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Request)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Requests$FetchRequest;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Requests$FetchRequest: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$FetchRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$FetchRequest: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Request)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Requests$PrepareAndExecuteRequest;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Requests$PrepareAndExecuteRequest: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$PrepareAndExecuteRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$PrepareAndExecuteRequest: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Request)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Requests$PrepareRequest;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Requests$PrepareRequest: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$PrepareRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$PrepareRequest: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Request)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Requests$SchemasRequest;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Requests$SchemasRequest: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$SchemasRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$SchemasRequest: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Request)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Requests$TablesRequest;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Requests$TablesRequest: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$TablesRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$TablesRequest: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Request)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Requests$TableTypesRequest;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Requests$TableTypesRequest: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$TableTypesRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$TableTypesRequest: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Request)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Requests$TypeInfoRequest;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Requests$TypeInfoRequest: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$TypeInfoRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$TypeInfoRequest: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Request)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Requests$ExecuteRequest;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Requests$ExecuteRequest: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$ExecuteRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$ExecuteRequest: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Request)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Requests$SyncResultsRequest;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Requests$SyncResultsRequest: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$SyncResultsRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$SyncResultsRequest: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Request)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Requests$CommitRequest;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Requests$CommitRequest: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$CommitRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$CommitRequest: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Request)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Requests$RollbackRequest;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Requests$RollbackRequest: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$RollbackRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$RollbackRequest: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Request)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Requests$PrepareAndExecuteBatchRequest;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Requests$PrepareAndExecuteBatchRequest: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$PrepareAndExecuteBatchRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$PrepareAndExecuteBatchRequest: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Request)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Requests$ExecuteBatchRequest;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Requests$ExecuteBatchRequest: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$ExecuteBatchRequest;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$ExecuteBatchRequest: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$RequestTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Request)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.util.Collections: java.util.Map unmodifiableMap(java.util.Map)>(v);
<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: java.util.Map REQUEST_PARSERS> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v = class "Loadd/org/apache/calcite/avatica/proto/Responses$OpenConnectionResponse;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Responses$OpenConnectionResponse: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$OpenConnectionResponse;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$OpenConnectionResponse: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Response)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Responses$CloseConnectionResponse;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Responses$CloseConnectionResponse: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$CloseConnectionResponse;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$CloseConnectionResponse: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Response)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Responses$CloseStatementResponse;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Responses$CloseStatementResponse: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$CloseStatementResponse;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$CloseStatementResponse: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Response)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Responses$ConnectionSyncResponse;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Responses$ConnectionSyncResponse: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$ConnectionSyncResponse;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$ConnectionSyncResponse: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Response)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Responses$CreateStatementResponse;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Responses$CreateStatementResponse: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$CreateStatementResponse;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$CreateStatementResponse: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Response)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Responses$DatabasePropertyResponse;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Responses$DatabasePropertyResponse: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$DatabasePropertyResponse;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$DatabasePropertyResponse: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Response)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Responses$ExecuteResponse;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Responses$ExecuteResponse: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$ExecuteResponse;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$ExecuteResponse: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Response)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Responses$FetchResponse;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Responses$FetchResponse: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$FetchResponse;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$FetchResponse: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Response)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Responses$PrepareResponse;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Responses$PrepareResponse: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$PrepareResponse;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$PrepareResponse: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Response)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Responses$ResultSetResponse;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Responses$ResultSetResponse: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$ResultSetResponse;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$ResultSetResponse: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Response)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Responses$ErrorResponse;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Responses$ErrorResponse: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$ErrorResponse;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$ErrorResponse: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Response)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Responses$SyncResultsResponse;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Responses$SyncResultsResponse: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$SyncResultsResponse;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$SyncResultsResponse: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Response)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Responses$RpcMetadata;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Responses$RpcMetadata: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$RpcMetadataResponse;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$RpcMetadataResponse: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Response)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Responses$CommitResponse;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Responses$CommitResponse: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$CommitResponse;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$CommitResponse: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Response)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Responses$RollbackResponse;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Responses$RollbackResponse: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$RollbackResponse;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$RollbackResponse: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Response)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = class "Loadd/org/apache/calcite/avatica/proto/Responses$ExecuteBatchResponse;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = new oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator;
v = staticinvoke <oadd.org.apache.calcite.avatica.proto.Responses$ExecuteBatchResponse: oadd.com.google.protobuf.Parser parser()>();
v = new oadd.org.apache.calcite.avatica.remote.Service$ExecuteBatchResponse;
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.Service$ExecuteBatchResponse: void <init>()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl$ResponseTranslator: void <init>(oadd.com.google.protobuf.Parser,oadd.org.apache.calcite.avatica.remote.Service$Response)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.util.Collections: java.util.Map unmodifiableMap(java.util.Map)>(v);
<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: java.util.Map RESPONSE_PARSERS> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v = staticinvoke <oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: java.util.List getAllMessageClasses()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = staticinvoke <oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: oadd.com.google.protobuf.ByteString wrapClassName(java.lang.Class)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = staticinvoke <java.util.Collections: java.util.Map unmodifiableMap(java.util.Map)>(v);
<oadd.org.apache.calcite.avatica.remote.ProtobufTranslationImpl: java.util.Map MESSAGE_CLASSES> = v;
return;
}
}