public class oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl extends java.lang.Object implements oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfig
{
private static final java.lang.String MAX_ADMISSIBLE_KEY;
private static final java.lang.String MAX_WAITING_KEY;
private static final java.lang.String MAX_WAIT_TIMEOUT_KEY;
private static final java.lang.String WAIT_FOR_PREFERRED_NODES_KEY;
private static final java.lang.String MAX_QUERY_MEMORY_PER_NODE_FORMAT;
private static final java.lang.String MAX_QUERY_MEMORY_PER_NODE_KEY;
private final java.lang.String queueUUID;
private final java.lang.String queueName;
private int maxAdmissibleQuery;
private int maxWaitingQuery;
private int maxWaitingTimeout;
private boolean waitForPreferredNodes;
private final oadd.org.apache.drill.exec.resourcemgr.NodeResources queueResourceShare;
private oadd.org.apache.drill.exec.resourcemgr.NodeResources queryPerNodeResourceShare;
public void <init>(oadd.com.typesafe.config.Config, java.lang.String, oadd.org.apache.drill.exec.resourcemgr.NodeResources) throws oadd.org.apache.drill.exec.resourcemgr.config.exception.RMConfigException
{
oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl v;
oadd.org.apache.drill.exec.resourcemgr.NodeResources v;
oadd.com.typesafe.config.Config v;
java.lang.String v, v;
java.util.UUID v;
v := @this: oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl;
v := @parameter: oadd.com.typesafe.config.Config;
v := @parameter: java.lang.String;
v := @parameter: oadd.org.apache.drill.exec.resourcemgr.NodeResources;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <java.util.UUID: java.util.UUID randomUUID()>();
v = virtualinvoke v.<java.util.UUID: java.lang.String toString()>();
v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: java.lang.String queueUUID> = v;
v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: java.lang.String queueName> = v;
v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: oadd.org.apache.drill.exec.resourcemgr.NodeResources queueResourceShare> = v;
specialinvoke v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: void parseQueueConfig(oadd.com.typesafe.config.Config)>(v);
return;
}
private void parseQueueConfig(oadd.com.typesafe.config.Config) throws oadd.org.apache.drill.exec.resourcemgr.config.exception.RMConfigException
{
oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl v;
oadd.org.apache.drill.exec.resourcemgr.NodeResources v;
oadd.com.typesafe.config.Config v;
int v, v, v;
boolean v, v, v, v, v;
v := @this: oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl;
v := @parameter: oadd.com.typesafe.config.Config;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: boolean hasPath(java.lang.String)>("max_admissible");
if v == 0 goto label;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: int getInt(java.lang.String)>("max_admissible");
goto label;
label:
v = 10;
label:
v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: int maxAdmissibleQuery> = v;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: boolean hasPath(java.lang.String)>("max_waiting");
if v == 0 goto label;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: int getInt(java.lang.String)>("max_waiting");
goto label;
label:
v = 10;
label:
v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: int maxWaitingQuery> = v;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: boolean hasPath(java.lang.String)>("max_wait_timeout");
if v == 0 goto label;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: int getInt(java.lang.String)>("max_wait_timeout");
goto label;
label:
v = 30000;
label:
v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: int maxWaitingTimeout> = v;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: boolean hasPath(java.lang.String)>("wait_for_preferred_nodes");
if v == 0 goto label;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: boolean getBoolean(java.lang.String)>("wait_for_preferred_nodes");
goto label;
label:
v = 1;
label:
v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: boolean waitForPreferredNodes> = v;
v = specialinvoke v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: oadd.org.apache.drill.exec.resourcemgr.NodeResources parseAndGetNodeShare(oadd.com.typesafe.config.Config)>(v);
v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: oadd.org.apache.drill.exec.resourcemgr.NodeResources queryPerNodeResourceShare> = v;
return;
}
public java.lang.String getQueueId()
{
oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl v;
java.lang.String v;
v := @this: oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl;
v = v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: java.lang.String queueUUID>;
return v;
}
public java.lang.String getQueueName()
{
oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl v;
java.lang.String v;
v := @this: oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl;
v = v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: java.lang.String queueName>;
return v;
}
public long getQueueTotalMemoryInMB(int)
{
oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl v;
oadd.org.apache.drill.exec.resourcemgr.NodeResources v;
int v;
long v, v;
v := @this: oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl;
v := @parameter: int;
v = v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: oadd.org.apache.drill.exec.resourcemgr.NodeResources queueResourceShare>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.resourcemgr.NodeResources: long getMemoryInMB()>();
v = v * v;
return v;
}
public long getMaxQueryMemoryInMBPerNode()
{
oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl v;
long v;
oadd.org.apache.drill.exec.resourcemgr.NodeResources v;
v := @this: oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl;
v = v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: oadd.org.apache.drill.exec.resourcemgr.NodeResources queryPerNodeResourceShare>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.resourcemgr.NodeResources: long getMemoryInMB()>();
return v;
}
public long getMaxQueryTotalMemoryInMB(int)
{
oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl v;
oadd.org.apache.drill.exec.resourcemgr.NodeResources v;
int v;
long v, v;
v := @this: oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl;
v := @parameter: int;
v = v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: oadd.org.apache.drill.exec.resourcemgr.NodeResources queryPerNodeResourceShare>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.resourcemgr.NodeResources: long getMemoryInMB()>();
v = v * v;
return v;
}
public boolean waitForPreferredNodes()
{
oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl v;
boolean v;
v := @this: oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl;
v = v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: boolean waitForPreferredNodes>;
return v;
}
public int getMaxAdmissibleQueries()
{
int v;
oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl v;
v := @this: oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl;
v = v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: int maxAdmissibleQuery>;
return v;
}
public int getMaxWaitingQueries()
{
int v;
oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl v;
v := @this: oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl;
v = v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: int maxWaitingQuery>;
return v;
}
public int getWaitTimeoutInMs()
{
int v;
oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl v;
v := @this: oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl;
v = v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: int maxWaitingTimeout>;
return v;
}
private oadd.org.apache.drill.exec.resourcemgr.NodeResources parseAndGetNodeShare(oadd.com.typesafe.config.Config) throws oadd.org.apache.drill.exec.resourcemgr.config.exception.RMConfigException
{
oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl v;
java.lang.Object[] v;
oadd.org.apache.drill.exec.resourcemgr.NodeResources v;
long v;
oadd.com.typesafe.config.Config v;
java.lang.Exception v;
oadd.org.apache.drill.exec.resourcemgr.config.exception.RMConfigException v;
java.lang.String v, v, v;
v := @this: oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl;
v := @parameter: oadd.com.typesafe.config.Config;
label:
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: java.lang.String getString(java.lang.String)>("max_query_memory_per_node");
v = staticinvoke <oadd.org.apache.drill.exec.resourcemgr.util.MemoryConfigParser: long parseMemoryConfigString(java.lang.String,java.lang.String)>(v, "([0-9]+)\\s*([kKmMgG]?)\\s*$");
v = new oadd.org.apache.drill.exec.resourcemgr.NodeResources;
specialinvoke v.<oadd.org.apache.drill.exec.resourcemgr.NodeResources: void <init>(long,int)>(v, 2147483647);
label:
return v;
label:
v := @caughtexception;
v = new oadd.org.apache.drill.exec.resourcemgr.config.exception.RMConfigException;
v = newarray (java.lang.Object)[2];
v[0] = "max_query_memory_per_node";
v = v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: java.lang.String queueName>;
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Failed while parsing %s for queue %s", v);
specialinvoke v.<oadd.org.apache.drill.exec.resourcemgr.config.exception.RMConfigException: void <init>(java.lang.String,java.lang.Exception)>(v, v);
throw v;
catch java.lang.Exception from label to label with label;
}
public java.lang.String toString()
{
oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl v;
oadd.org.apache.drill.exec.resourcemgr.NodeResources v, v;
int v, v, v;
java.lang.String v, v, v, v, v;
boolean v;
v := @this: oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl;
v = v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: java.lang.String queueName>;
v = v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: java.lang.String queueUUID>;
v = v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: oadd.org.apache.drill.exec.resourcemgr.NodeResources queryPerNodeResourceShare>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.resourcemgr.NodeResources: java.lang.String toString()>();
v = v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: oadd.org.apache.drill.exec.resourcemgr.NodeResources queryPerNodeResourceShare>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.resourcemgr.NodeResources: java.lang.String toString()>();
v = v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: int maxAdmissibleQuery>;
v = v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: int maxWaitingQuery>;
v = v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: int maxWaitingTimeout>;
v = v.<oadd.org.apache.drill.exec.resourcemgr.config.QueryQueueConfigImpl: boolean waitForPreferredNodes>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String,java.lang.String,int,int,int,boolean)>(v, v, v, v, v, v, v, 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[])>("{ QueueName: \u, QueueId: \u, QueuePerNodeResource(MB): \u, MaxQueryMemPerNode(MB): \u, MaxAdmissible: \u, MaxWaiting: \u, MaxWaitTimeout: \u, WaitForPreferredNodes: \u0001}");
return v;
}
}