public class org.apache.drill.yarn.core.AppSpec extends org.apache.drill.yarn.core.LaunchSpec
{
private static final org.apache.commons.logging.Log LOG;
public int memoryMb;
public int vCores;
public double disks;
public java.lang.String appName;
public java.lang.String queueName;
public int priority;
public boolean unmanaged;
public java.lang.String nodeLabelExpr;
public void <init>()
{
org.apache.drill.yarn.core.AppSpec v;
v := @this: org.apache.drill.yarn.core.AppSpec;
specialinvoke v.<org.apache.drill.yarn.core.LaunchSpec: void <init>()>();
v.<org.apache.drill.yarn.core.AppSpec: int vCores> = 1;
v.<org.apache.drill.yarn.core.AppSpec: java.lang.String queueName> = "default";
v.<org.apache.drill.yarn.core.AppSpec: int priority> = 1;
return;
}
public org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext createAppLaunchContext(org.apache.hadoop.yarn.conf.YarnConfiguration, org.apache.hadoop.yarn.client.api.YarnClientApplication) throws java.io.IOException
{
org.apache.hadoop.yarn.client.api.YarnClientApplication v;
org.apache.hadoop.yarn.conf.YarnConfiguration v;
int v;
org.apache.hadoop.yarn.api.records.Resource v;
java.lang.String v, v, v, v, v, v;
boolean v, v;
org.apache.hadoop.yarn.api.records.Priority v;
org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext v;
org.apache.hadoop.yarn.api.records.ContainerLaunchContext v;
org.apache.commons.logging.Log v;
org.apache.drill.yarn.core.AppSpec v;
v := @this: org.apache.drill.yarn.core.AppSpec;
v := @parameter: org.apache.hadoop.yarn.conf.YarnConfiguration;
v := @parameter: org.apache.hadoop.yarn.client.api.YarnClientApplication;
v = virtualinvoke v.<org.apache.drill.yarn.core.AppSpec: org.apache.hadoop.yarn.api.records.ContainerLaunchContext createLaunchContext(org.apache.hadoop.yarn.conf.YarnConfiguration)>(v);
v = virtualinvoke v.<org.apache.hadoop.yarn.client.api.YarnClientApplication: org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext getApplicationSubmissionContext()>();
v = v.<org.apache.drill.yarn.core.AppSpec: java.lang.String appName>;
virtualinvoke v.<org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext: void setApplicationName(java.lang.String)>(v);
virtualinvoke v.<org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext: void setAMContainerSpec(org.apache.hadoop.yarn.api.records.ContainerLaunchContext)>(v);
v = virtualinvoke v.<org.apache.drill.yarn.core.AppSpec: org.apache.hadoop.yarn.api.records.Resource getCapability()>();
virtualinvoke v.<org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext: void setResource(org.apache.hadoop.yarn.api.records.Resource)>(v);
v = v.<org.apache.drill.yarn.core.AppSpec: java.lang.String queueName>;
virtualinvoke v.<org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext: void setQueue(java.lang.String)>(v);
v = v.<org.apache.drill.yarn.core.AppSpec: int priority>;
v = staticinvoke <org.apache.hadoop.yarn.api.records.Priority: org.apache.hadoop.yarn.api.records.Priority newInstance(int)>(v);
virtualinvoke v.<org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext: void setPriority(org.apache.hadoop.yarn.api.records.Priority)>(v);
v = v.<org.apache.drill.yarn.core.AppSpec: java.lang.String nodeLabelExpr>;
v = staticinvoke <org.apache.drill.yarn.core.DoYUtil: boolean isBlank(java.lang.String)>(v);
if v != 0 goto label;
v = <org.apache.drill.yarn.core.AppSpec: org.apache.commons.logging.Log LOG>;
v = v.<org.apache.drill.yarn.core.AppSpec: java.lang.String nodeLabelExpr>;
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[])>("Requesting to run the AM using node expression: \u0001");
interfaceinvoke v.<org.apache.commons.logging.Log: void info(java.lang.Object)>(v);
v = v.<org.apache.drill.yarn.core.AppSpec: java.lang.String nodeLabelExpr>;
virtualinvoke v.<org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext: void setNodeLabelExpression(java.lang.String)>(v);
label:
v = v.<org.apache.drill.yarn.core.AppSpec: boolean unmanaged>;
virtualinvoke v.<org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext: void setUnmanagedAM(boolean)>(v);
virtualinvoke v.<org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext: void setMaxAppAttempts(int)>(1);
return v;
}
public org.apache.hadoop.yarn.api.records.Resource getCapability()
{
int v, v;
java.lang.Object v;
org.apache.drill.yarn.core.AppSpec v;
double v;
v := @this: org.apache.drill.yarn.core.AppSpec;
v = staticinvoke <org.apache.hadoop.yarn.util.Records: java.lang.Object newRecord(java.lang.Class)>(class "Lorg/apache/hadoop/yarn/api/records/Resource;");
v = v.<org.apache.drill.yarn.core.AppSpec: int memoryMb>;
virtualinvoke v.<org.apache.hadoop.yarn.api.records.Resource: void setMemory(int)>(v);
v = v.<org.apache.drill.yarn.core.AppSpec: int vCores>;
virtualinvoke v.<org.apache.hadoop.yarn.api.records.Resource: void setVirtualCores(int)>(v);
v = v.<org.apache.drill.yarn.core.AppSpec: double disks>;
staticinvoke <org.apache.drill.yarn.core.DoYUtil: void callSetDiskIfExists(java.lang.Object,double)>(v, v);
return v;
}
public void dump(java.io.PrintStream)
{
java.io.PrintStream v;
int v, v, v;
java.lang.String v, v;
org.apache.drill.yarn.core.AppSpec v;
double v;
v := @this: org.apache.drill.yarn.core.AppSpec;
v := @parameter: java.io.PrintStream;
virtualinvoke v.<java.io.PrintStream: void print(java.lang.String)>("Memory (MB): ");
v = v.<org.apache.drill.yarn.core.AppSpec: int memoryMb>;
virtualinvoke v.<java.io.PrintStream: void println(int)>(v);
virtualinvoke v.<java.io.PrintStream: void print(java.lang.String)>("Vcores: ");
v = v.<org.apache.drill.yarn.core.AppSpec: int vCores>;
virtualinvoke v.<java.io.PrintStream: void println(int)>(v);
virtualinvoke v.<java.io.PrintStream: void print(java.lang.String)>("Disks: ");
v = v.<org.apache.drill.yarn.core.AppSpec: double disks>;
virtualinvoke v.<java.io.PrintStream: void println(double)>(v);
virtualinvoke v.<java.io.PrintStream: void print(java.lang.String)>("Application Name: ");
v = v.<org.apache.drill.yarn.core.AppSpec: java.lang.String appName>;
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
virtualinvoke v.<java.io.PrintStream: void print(java.lang.String)>("Queue: ");
v = v.<org.apache.drill.yarn.core.AppSpec: java.lang.String queueName>;
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
virtualinvoke v.<java.io.PrintStream: void print(java.lang.String)>("Priority: ");
v = v.<org.apache.drill.yarn.core.AppSpec: int priority>;
virtualinvoke v.<java.io.PrintStream: void println(int)>(v);
specialinvoke v.<org.apache.drill.yarn.core.LaunchSpec: void dump(java.io.PrintStream)>(v);
return;
}
static void <clinit>()
{
org.apache.commons.logging.Log v;
v = staticinvoke <org.apache.commons.logging.LogFactory: org.apache.commons.logging.Log getLog(java.lang.Class)>(class "Lorg/apache/drill/yarn/core/LaunchSpec;");
<org.apache.drill.yarn.core.AppSpec: org.apache.commons.logging.Log LOG> = v;
return;
}
}