public class org.apache.drill.yarn.client.StatusCommand extends org.apache.drill.yarn.client.ClientCommand
{
public void <init>()
{
org.apache.drill.yarn.client.StatusCommand v;
v := @this: org.apache.drill.yarn.client.StatusCommand;
specialinvoke v.<org.apache.drill.yarn.client.ClientCommand: void <init>()>();
return;
}
public static java.lang.String getAmUrl(org.apache.hadoop.yarn.api.records.ApplicationReport)
{
org.apache.hadoop.yarn.api.records.ApplicationReport v;
java.lang.String v, v;
v := @parameter: org.apache.hadoop.yarn.api.records.ApplicationReport;
v = virtualinvoke v.<org.apache.hadoop.yarn.api.records.ApplicationReport: java.lang.String getOriginalTrackingUrl()>();
v = staticinvoke <org.apache.drill.yarn.core.DoYUtil: java.lang.String unwrapAmUrl(java.lang.String)>(v);
return v;
}
public void run() throws org.apache.drill.yarn.client.ClientException
{
java.io.PrintStream v, v;
org.apache.drill.yarn.client.StatusCommand v;
org.apache.drill.yarn.core.YarnRMClient v;
org.apache.drill.yarn.client.StatusCommand$Reporter v;
java.lang.Exception v;
org.apache.hadoop.yarn.api.records.ApplicationId v;
org.apache.drill.yarn.client.CommandLineOptions v;
org.apache.hadoop.yarn.api.records.ApplicationReport v;
java.lang.String v, v;
boolean v, v;
v := @this: org.apache.drill.yarn.client.StatusCommand;
v = virtualinvoke v.<org.apache.drill.yarn.client.StatusCommand: org.apache.drill.yarn.core.YarnRMClient getClient()>();
v = <java.lang.System: java.io.PrintStream out>;
v = virtualinvoke v.<org.apache.drill.yarn.core.YarnRMClient: org.apache.hadoop.yarn.api.records.ApplicationId getAppId()>();
v = virtualinvoke v.<org.apache.hadoop.yarn.api.records.ApplicationId: java.lang.String toString()>();
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[])>("Application ID: \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
v = new org.apache.drill.yarn.client.StatusCommand$Reporter;
specialinvoke v.<org.apache.drill.yarn.client.StatusCommand$Reporter: void <init>(org.apache.drill.yarn.core.YarnRMClient)>(v);
label:
virtualinvoke v.<org.apache.drill.yarn.client.StatusCommand$Reporter: void getReport()>();
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.drill.yarn.client.StatusCommand: void removeAppIdFile()>();
v = <java.lang.System: java.io.PrintStream out>;
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>("Application is not running.");
return;
label:
v = v.<org.apache.drill.yarn.client.StatusCommand: org.apache.drill.yarn.client.CommandLineOptions opts>;
v = v.<org.apache.drill.yarn.client.CommandLineOptions: boolean verbose>;
virtualinvoke v.<org.apache.drill.yarn.client.StatusCommand$Reporter: void display(boolean,boolean)>(v, 0);
v = virtualinvoke v.<org.apache.drill.yarn.client.StatusCommand$Reporter: boolean isRunning()>();
if v == 0 goto label;
v = v.<org.apache.drill.yarn.client.StatusCommand$Reporter: org.apache.hadoop.yarn.api.records.ApplicationReport report>;
specialinvoke v.<org.apache.drill.yarn.client.StatusCommand: void showAmStatus(org.apache.hadoop.yarn.api.records.ApplicationReport)>(v);
label:
return;
catch java.lang.Exception from label to label with label;
}
private void showAmStatus(org.apache.hadoop.yarn.api.records.ApplicationReport)
{
org.apache.drill.yarn.client.SimpleRestClient v;
org.apache.drill.yarn.client.CommandLineOptions v;
org.apache.hadoop.yarn.api.records.ApplicationReport v;
java.lang.String v, v, v, v, v;
boolean v, v;
java.io.PrintStream v, v, v, v;
org.apache.drill.yarn.client.StatusCommand v;
org.apache.drill.yarn.client.ClientException v;
v := @this: org.apache.drill.yarn.client.StatusCommand;
v := @parameter: org.apache.hadoop.yarn.api.records.ApplicationReport;
label:
v = staticinvoke <org.apache.drill.yarn.client.StatusCommand: java.lang.String getAmUrl(org.apache.hadoop.yarn.api.records.ApplicationReport)>(v);
v = staticinvoke <org.apache.drill.yarn.core.DoYUtil: boolean isBlank(java.lang.String)>(v);
if v == 0 goto label;
label:
return;
label:
v = new org.apache.drill.yarn.client.SimpleRestClient;
specialinvoke v.<org.apache.drill.yarn.client.SimpleRestClient: void <init>()>();
v = v.<org.apache.drill.yarn.client.StatusCommand: org.apache.drill.yarn.client.CommandLineOptions opts>;
v = v.<org.apache.drill.yarn.client.CommandLineOptions: boolean verbose>;
if v == 0 goto label;
v = <java.lang.System: java.io.PrintStream out>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, "rest/status") <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[])>("Getting status with \u0001/\u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.drill.yarn.client.SimpleRestClient: java.lang.String send(java.lang.String,java.lang.String,boolean)>(v, "rest/status", 0);
specialinvoke v.<org.apache.drill.yarn.client.StatusCommand: void formatResponse(java.lang.String)>(v);
v = <java.lang.System: java.io.PrintStream out>;
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[])>("For more information, visit: \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <java.lang.System: java.io.PrintStream out>;
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>("Failed to get AM status");
v = <java.lang.System: java.io.PrintStream err>;
v = virtualinvoke v.<org.apache.drill.yarn.client.ClientException: java.lang.String getMessage()>();
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
label:
return;
catch org.apache.drill.yarn.client.ClientException from label to label with label;
catch org.apache.drill.yarn.client.ClientException from label to label with label;
}
private void formatResponse(java.lang.String)
{
java.lang.Throwable v;
org.apache.drill.yarn.client.CommandLineOptions v;
java.lang.String v, v;
boolean v;
java.io.PrintStream v, v, v;
org.apache.drill.yarn.client.StatusCommand v;
org.json.simple.parser.JSONParser v;
java.lang.Object v, v, v, v, v, v;
v := @this: org.apache.drill.yarn.client.StatusCommand;
v := @parameter: java.lang.String;
v = new org.json.simple.parser.JSONParser;
specialinvoke v.<org.json.simple.parser.JSONParser: void <init>()>();
label:
v = virtualinvoke v.<org.json.simple.parser.JSONParser: java.lang.Object parse(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <java.lang.System: java.io.PrintStream err>;
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>("Invalid response received from AM");
v = v.<org.apache.drill.yarn.client.StatusCommand: org.apache.drill.yarn.client.CommandLineOptions opts>;
v = v.<org.apache.drill.yarn.client.CommandLineOptions: boolean verbose>;
if v == 0 goto label;
v = <java.lang.System: java.io.PrintStream out>;
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
v = <java.lang.System: java.io.PrintStream out>;
v = virtualinvoke v.<org.json.simple.parser.ParseException: java.lang.String getMessage()>();
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
label:
return;
label:
specialinvoke v.<org.apache.drill.yarn.client.StatusCommand: void showMetric(java.lang.String,java.lang.Object,java.lang.String)>("AM State", v, "state");
v = virtualinvoke v.<org.json.simple.JSONObject: java.lang.Object get(java.lang.Object)>("summary");
specialinvoke v.<org.apache.drill.yarn.client.StatusCommand: void showMetric(java.lang.String,java.lang.Object,java.lang.String)>("Target Drillbit Count", v, "targetBitCount");
v = virtualinvoke v.<org.json.simple.JSONObject: java.lang.Object get(java.lang.Object)>("summary");
specialinvoke v.<org.apache.drill.yarn.client.StatusCommand: void showMetric(java.lang.String,java.lang.Object,java.lang.String)>("Live Drillbit Count", v, "liveBitCount");
v = virtualinvoke v.<org.json.simple.JSONObject: java.lang.Object get(java.lang.Object)>("summary");
specialinvoke v.<org.apache.drill.yarn.client.StatusCommand: void showMetric(java.lang.String,java.lang.Object,java.lang.String)>("Unmanaged Drillbit Count", v, "unmanagedCount");
v = virtualinvoke v.<org.json.simple.JSONObject: java.lang.Object get(java.lang.Object)>("summary");
specialinvoke v.<org.apache.drill.yarn.client.StatusCommand: void showMetric(java.lang.String,java.lang.Object,java.lang.String)>("Blacklisted Node Count", v, "blackListCount");
v = virtualinvoke v.<org.json.simple.JSONObject: java.lang.Object get(java.lang.Object)>("summary");
specialinvoke v.<org.apache.drill.yarn.client.StatusCommand: void showMetric(java.lang.String,java.lang.Object,java.lang.String)>("Free Node Count", v, "freeNodeCount");
return;
catch org.json.simple.parser.ParseException from label to label with label;
}
private void showMetric(java.lang.String, java.lang.Object, java.lang.String)
{
java.io.PrintStream v;
org.apache.drill.yarn.client.StatusCommand v;
java.lang.Object v, v;
java.lang.String v, v, v, v;
boolean v;
v := @this: org.apache.drill.yarn.client.StatusCommand;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object;
v := @parameter: java.lang.String;
if v != null goto label;
return;
label:
v = v instanceof org.json.simple.JSONObject;
if v != 0 goto label;
return;
label:
v = virtualinvoke v.<org.json.simple.JSONObject: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
return;
label:
v = <java.lang.System: java.io.PrintStream out>;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(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[])>("\u0001: \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
return;
}
}