public class oadd.org.apache.drill.exec.rpc.user.UserRpcConfig extends java.lang.Object
{
public static final int RPC_VERSION;
public static final java.util.Set SUPPORTED_SERVER_METHODS;
public static oadd.org.apache.drill.exec.rpc.RpcConfig getMapping(oadd.org.apache.drill.common.config.DrillConfig, java.util.concurrent.Executor)
{
oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.drill.common.config.DrillConfig v;
oadd.org.apache.drill.exec.proto.UserProtos$RpcType 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;
int v;
oadd.org.apache.drill.exec.rpc.RpcConfig v;
java.util.concurrent.Executor v;
v := @parameter: oadd.org.apache.drill.common.config.DrillConfig;
v := @parameter: java.util.concurrent.Executor;
v = staticinvoke <oadd.org.apache.drill.exec.rpc.RpcConfig: oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder newBuilder()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder: oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder name(java.lang.String)>("USER");
v = virtualinvoke v.<oadd.org.apache.drill.common.config.DrillConfig: int getInt(java.lang.String)>("drill.exec.rpc.user.timeout");
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder: oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder timeout(int)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder: oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder executor(java.util.concurrent.Executor)>(v);
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType HANDSHAKE>;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType HANDSHAKE>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder: oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder add(oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class,oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class)>(v, class "Loadd/org/apache/drill/exec/proto/UserProtos$UserToBitHandshake;", v, class "Loadd/org/apache/drill/exec/proto/UserProtos$BitToUserHandshake;");
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType RUN_QUERY>;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType QUERY_HANDLE>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder: oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder add(oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class,oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class)>(v, class "Loadd/org/apache/drill/exec/proto/UserProtos$RunQuery;", v, class "Loadd/org/apache/drill/exec/proto/UserBitShared$QueryId;");
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType CANCEL_QUERY>;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType ACK>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder: oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder add(oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class,oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class)>(v, class "Loadd/org/apache/drill/exec/proto/UserBitShared$QueryId;", v, class "Loadd/org/apache/drill/exec/proto/GeneralRPCProtos$Ack;");
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType QUERY_DATA>;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType ACK>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder: oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder add(oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class,oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class)>(v, class "Loadd/org/apache/drill/exec/proto/UserBitShared$QueryData;", v, class "Loadd/org/apache/drill/exec/proto/GeneralRPCProtos$Ack;");
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType QUERY_RESULT>;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType ACK>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder: oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder add(oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class,oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class)>(v, class "Loadd/org/apache/drill/exec/proto/UserBitShared$QueryResult;", v, class "Loadd/org/apache/drill/exec/proto/GeneralRPCProtos$Ack;");
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType RESUME_PAUSED_QUERY>;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType ACK>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder: oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder add(oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class,oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class)>(v, class "Loadd/org/apache/drill/exec/proto/UserBitShared$QueryId;", v, class "Loadd/org/apache/drill/exec/proto/GeneralRPCProtos$Ack;");
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType GET_QUERY_PLAN_FRAGMENTS>;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType QUERY_PLAN_FRAGMENTS>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder: oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder add(oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class,oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class)>(v, class "Loadd/org/apache/drill/exec/proto/UserProtos$GetQueryPlanFragments;", v, class "Loadd/org/apache/drill/exec/proto/UserProtos$QueryPlanFragments;");
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType GET_CATALOGS>;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType CATALOGS>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder: oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder add(oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class,oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class)>(v, class "Loadd/org/apache/drill/exec/proto/UserProtos$GetCatalogsReq;", v, class "Loadd/org/apache/drill/exec/proto/UserProtos$GetCatalogsResp;");
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType GET_SCHEMAS>;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType SCHEMAS>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder: oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder add(oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class,oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class)>(v, class "Loadd/org/apache/drill/exec/proto/UserProtos$GetSchemasReq;", v, class "Loadd/org/apache/drill/exec/proto/UserProtos$GetSchemasResp;");
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType GET_TABLES>;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType TABLES>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder: oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder add(oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class,oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class)>(v, class "Loadd/org/apache/drill/exec/proto/UserProtos$GetTablesReq;", v, class "Loadd/org/apache/drill/exec/proto/UserProtos$GetTablesResp;");
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType GET_COLUMNS>;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType COLUMNS>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder: oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder add(oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class,oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class)>(v, class "Loadd/org/apache/drill/exec/proto/UserProtos$GetColumnsReq;", v, class "Loadd/org/apache/drill/exec/proto/UserProtos$GetColumnsResp;");
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType CREATE_PREPARED_STATEMENT>;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType PREPARED_STATEMENT>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder: oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder add(oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class,oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class)>(v, class "Loadd/org/apache/drill/exec/proto/UserProtos$CreatePreparedStatementReq;", v, class "Loadd/org/apache/drill/exec/proto/UserProtos$CreatePreparedStatementResp;");
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType SASL_MESSAGE>;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType SASL_MESSAGE>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder: oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder add(oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class,oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class)>(v, class "Loadd/org/apache/drill/exec/proto/UserBitShared$SaslMessage;", v, class "Loadd/org/apache/drill/exec/proto/UserBitShared$SaslMessage;");
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType GET_SERVER_META>;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType SERVER_META>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder: oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder add(oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class,oadd.com.google.protobuf.Internal$EnumLite,java.lang.Class)>(v, class "Loadd/org/apache/drill/exec/proto/UserProtos$GetServerMetaReq;", v, class "Loadd/org/apache/drill/exec/proto/UserProtos$GetServerMetaResp;");
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.RpcConfig$RpcConfigBuilder: oadd.org.apache.drill.exec.rpc.RpcConfig build()>();
return v;
}
private void <init>()
{
oadd.org.apache.drill.exec.rpc.user.UserRpcConfig v;
v := @this: oadd.org.apache.drill.exec.rpc.user.UserRpcConfig;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
static void <clinit>()
{
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder v, v;
oadd.org.apache.drill.exec.proto.UserProtos$RpcType v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.drill.exec.proto.UserProtos$RpcType[] v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet v, v;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder builder()>();
v = newarray (oadd.org.apache.drill.exec.proto.UserProtos$RpcType)[10];
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType RUN_QUERY>;
v[0] = v;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType CANCEL_QUERY>;
v[1] = v;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType GET_QUERY_PLAN_FRAGMENTS>;
v[2] = v;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType RESUME_PAUSED_QUERY>;
v[3] = v;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType GET_CATALOGS>;
v[4] = v;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType GET_SCHEMAS>;
v[5] = v;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType GET_TABLES>;
v[6] = v;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType GET_COLUMNS>;
v[7] = v;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType CREATE_PREPARED_STATEMENT>;
v[8] = v;
v = <oadd.org.apache.drill.exec.proto.UserProtos$RpcType: oadd.org.apache.drill.exec.proto.UserProtos$RpcType GET_SERVER_META>;
v[9] = v;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder add(java.lang.Object[])>(v);
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet build()>();
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Sets: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet immutableEnumSet(java.lang.Iterable)>(v);
<oadd.org.apache.drill.exec.rpc.user.UserRpcConfig: java.util.Set SUPPORTED_SERVER_METHODS> = v;
return;
}
}