public class org.apache.hadoop.hive.common.cli.ShellCmdExecutor extends java.lang.Object
{
private java.lang.String cmd;
private java.io.PrintStream out;
private java.io.PrintStream err;
public void <init>(java.lang.String, java.io.PrintStream, java.io.PrintStream)
{
java.io.PrintStream v, v;
org.apache.hadoop.hive.common.cli.ShellCmdExecutor v;
java.lang.String v;
v := @this: org.apache.hadoop.hive.common.cli.ShellCmdExecutor;
v := @parameter: java.lang.String;
v := @parameter: java.io.PrintStream;
v := @parameter: java.io.PrintStream;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.hadoop.hive.common.cli.ShellCmdExecutor: java.lang.String cmd> = v;
v.<org.apache.hadoop.hive.common.cli.ShellCmdExecutor: java.io.PrintStream out> = v;
v.<org.apache.hadoop.hive.common.cli.ShellCmdExecutor: java.io.PrintStream err> = v;
return;
}
public int execute() throws java.lang.Exception
{
org.apache.hadoop.hive.common.cli.ShellCmdExecutor v;
java.io.PrintStream[] v, v;
int v;
java.lang.String v, v, v;
java.io.PrintStream v, v;
java.lang.Process v;
java.lang.Runtime v;
java.io.IOException v;
java.lang.Exception v;
org.apache.hive.common.util.StreamPrinter v, v;
java.io.InputStream v, v;
v := @this: org.apache.hadoop.hive.common.cli.ShellCmdExecutor;
label:
v = staticinvoke <java.lang.Runtime: java.lang.Runtime getRuntime()>();
v = v.<org.apache.hadoop.hive.common.cli.ShellCmdExecutor: java.lang.String cmd>;
v = virtualinvoke v.<java.lang.Runtime: java.lang.Process exec(java.lang.String)>(v);
v = new org.apache.hive.common.util.StreamPrinter;
v = virtualinvoke v.<java.lang.Process: java.io.InputStream getInputStream()>();
v = newarray (java.io.PrintStream)[1];
v = v.<org.apache.hadoop.hive.common.cli.ShellCmdExecutor: java.io.PrintStream out>;
v[0] = v;
specialinvoke v.<org.apache.hive.common.util.StreamPrinter: void <init>(java.io.InputStream,java.lang.String,java.io.PrintStream[])>(v, null, v);
v = new org.apache.hive.common.util.StreamPrinter;
v = virtualinvoke v.<java.lang.Process: java.io.InputStream getErrorStream()>();
v = newarray (java.io.PrintStream)[1];
v = v.<org.apache.hadoop.hive.common.cli.ShellCmdExecutor: java.io.PrintStream err>;
v[0] = v;
specialinvoke v.<org.apache.hive.common.util.StreamPrinter: void <init>(java.io.InputStream,java.lang.String,java.io.PrintStream[])>(v, null, v);
virtualinvoke v.<org.apache.hive.common.util.StreamPrinter: void start()>();
virtualinvoke v.<org.apache.hive.common.util.StreamPrinter: void start()>();
v = virtualinvoke v.<java.lang.Process: int waitFor()>();
virtualinvoke v.<org.apache.hive.common.util.StreamPrinter: void join()>();
virtualinvoke v.<org.apache.hive.common.util.StreamPrinter: void join()>();
label:
return v;
label:
v := @caughtexception;
v = new java.lang.Exception;
v = v.<org.apache.hadoop.hive.common.cli.ShellCmdExecutor: java.lang.String cmd>;
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[])>("Failed to execute \u0001");
specialinvoke v.<java.lang.Exception: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.io.IOException from label to label with label;
}
}