public class oadd.org.apache.drill.exec.client.QuerySubmitter extends java.lang.Object
{
public void <init>()
{
oadd.org.apache.drill.exec.client.QuerySubmitter v;
v := @this: oadd.org.apache.drill.exec.client.QuerySubmitter;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static void main(java.lang.String[]) throws java.lang.Exception
{
java.lang.Throwable v;
oadd.org.apache.drill.exec.client.QuerySubmitter v;
java.lang.String[] v, v;
int v, v, v, v;
java.lang.String v, v, v, v, v, v;
boolean v, v;
java.io.PrintStream v;
oadd.org.apache.drill.exec.client.QuerySubmitter$Options v;
oadd.com.beust.jcommander.JCommander v, v, v;
v := @parameter: java.lang.String[];
v = new oadd.org.apache.drill.exec.client.QuerySubmitter;
specialinvoke v.<oadd.org.apache.drill.exec.client.QuerySubmitter: void <init>()>();
v = new oadd.org.apache.drill.exec.client.QuerySubmitter$Options;
specialinvoke v.<oadd.org.apache.drill.exec.client.QuerySubmitter$Options: void <init>()>();
v = null;
label:
v = new oadd.com.beust.jcommander.JCommander;
specialinvoke v.<oadd.com.beust.jcommander.JCommander: void <init>(java.lang.Object,java.lang.String[])>(v, v);
v = v;
virtualinvoke v.<oadd.com.beust.jcommander.JCommander: void setProgramName(java.lang.String)>("./submit_plan");
label:
goto label;
label:
v := @caughtexception;
v = <java.lang.System: java.io.PrintStream out>;
v = virtualinvoke v.<oadd.com.beust.jcommander.ParameterException: java.lang.String getMessage()>();
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
v = newarray (java.lang.String)[4];
v[0] = "-f";
v[1] = "file";
v[2] = "-t";
v[3] = "physical";
v = new oadd.com.beust.jcommander.JCommander;
specialinvoke v.<oadd.com.beust.jcommander.JCommander: void <init>(java.lang.Object,java.lang.String[])>(v, v);
virtualinvoke v.<oadd.com.beust.jcommander.JCommander: void usage()>();
v = (int) -1;
staticinvoke <java.lang.System: void exit(int)>(v);
label:
v = v.<oadd.org.apache.drill.exec.client.QuerySubmitter$Options: boolean help>;
if v == 0 goto label;
virtualinvoke v.<oadd.com.beust.jcommander.JCommander: void usage()>();
staticinvoke <java.lang.System: void exit(int)>(0);
label:
v = v.<oadd.org.apache.drill.exec.client.QuerySubmitter$Options: java.lang.String location>;
v = v.<oadd.org.apache.drill.exec.client.QuerySubmitter$Options: java.lang.String queryString>;
v = v.<oadd.org.apache.drill.exec.client.QuerySubmitter$Options: java.lang.String planType>;
v = v.<oadd.org.apache.drill.exec.client.QuerySubmitter$Options: java.lang.String zk>;
v = v.<oadd.org.apache.drill.exec.client.QuerySubmitter$Options: boolean local>;
v = v.<oadd.org.apache.drill.exec.client.QuerySubmitter$Options: int bits>;
v = v.<oadd.org.apache.drill.exec.client.QuerySubmitter$Options: java.lang.String format>;
v = v.<oadd.org.apache.drill.exec.client.QuerySubmitter$Options: int width>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.client.QuerySubmitter: int submitQuery(java.lang.String,java.lang.String,java.lang.String,java.lang.String,boolean,int,java.lang.String,int)>(v, v, v, v, v, v, v, v);
staticinvoke <java.lang.System: void exit(int)>(v);
return;
catch oadd.com.beust.jcommander.ParameterException from label to label with label;
}
public int submitQuery(java.lang.String, java.lang.String, java.lang.String, java.lang.String, boolean, int, java.lang.String) throws java.lang.Exception
{
oadd.org.apache.drill.exec.client.QuerySubmitter v;
int v, v;
java.lang.String v, v, v, v, v;
boolean v;
v := @this: oadd.org.apache.drill.exec.client.QuerySubmitter;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v := @parameter: int;
v := @parameter: java.lang.String;
v = virtualinvoke v.<oadd.org.apache.drill.exec.client.QuerySubmitter: int submitQuery(java.lang.String,java.lang.String,java.lang.String,java.lang.String,boolean,int,java.lang.String,int)>(v, v, v, v, v, v, v, 15);
return v;
}
public int submitQuery(java.lang.String, java.lang.String, java.lang.String, java.lang.String, boolean, int, java.lang.String, int) throws java.lang.Exception
{
oadd.org.apache.drill.exec.client.QuerySubmitter v;
byte[] v;
java.nio.ByteBuffer v;
java.nio.file.Path v;
boolean v, v, v;
java.nio.CharBuffer v;
oadd.org.apache.drill.exec.coord.zk.ZKClusterCoordinator v;
oadd.org.apache.drill.exec.coord.ClusterCoordinator v;
java.lang.Throwable v, v;
oadd.org.apache.drill.exec.server.Drillbit[] v, v, v, v;
oadd.org.apache.drill.common.config.DrillConfig v;
oadd.org.apache.drill.exec.server.RemoteServiceSet v;
java.lang.String[] v;
oadd.org.apache.drill.exec.server.Drillbit v, v, v, v, v;
java.nio.charset.Charset v;
int v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v;
java.io.PrintStream v;
oadd.org.apache.drill.exec.client.DrillClient v, v, v;
v := @this: oadd.org.apache.drill.exec.client.QuerySubmitter;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v := @parameter: int;
v := @parameter: java.lang.String;
v := @parameter: int;
v = staticinvoke <oadd.org.apache.drill.common.config.DrillConfig: oadd.org.apache.drill.common.config.DrillConfig create()>();
v = null;
if v != null goto label;
if v == null goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Preconditions: void checkArgument(boolean,java.lang.Object)>(v, "Must provide either query file or query string");
if v == null goto label;
if v != null goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Preconditions: void checkArgument(boolean,java.lang.Object)>(v, "Must provide either query file or query string, not both");
v = null;
v = null;
label:
if v == 0 goto label;
v = staticinvoke <oadd.org.apache.drill.exec.server.RemoteServiceSet: oadd.org.apache.drill.exec.server.RemoteServiceSet getLocalServiceSet()>();
v = newarray (oadd.org.apache.drill.exec.server.Drillbit)[v];
v = 0;
label:
if v >= v goto label;
v = new oadd.org.apache.drill.exec.server.Drillbit;
specialinvoke v.<oadd.org.apache.drill.exec.server.Drillbit: void <init>(oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.drill.exec.server.RemoteServiceSet)>(v, v);
v[v] = v;
v = v[v];
virtualinvoke v.<oadd.org.apache.drill.exec.server.Drillbit: void run()>();
v = v + 1;
goto label;
label:
v = new oadd.org.apache.drill.exec.client.DrillClient;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.RemoteServiceSet: oadd.org.apache.drill.exec.coord.ClusterCoordinator getCoordinator()>();
specialinvoke v.<oadd.org.apache.drill.exec.client.DrillClient: void <init>(oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.drill.exec.coord.ClusterCoordinator)>(v, v);
v = v;
goto label;
label:
v = new oadd.org.apache.drill.exec.coord.zk.ZKClusterCoordinator;
specialinvoke v.<oadd.org.apache.drill.exec.coord.zk.ZKClusterCoordinator: void <init>(oadd.org.apache.drill.common.config.DrillConfig,java.lang.String)>(v, v);
virtualinvoke v.<oadd.org.apache.drill.exec.coord.zk.ZKClusterCoordinator: void start(long)>(10000L);
v = new oadd.org.apache.drill.exec.client.DrillClient;
specialinvoke v.<oadd.org.apache.drill.exec.client.DrillClient: void <init>(oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.drill.exec.coord.ClusterCoordinator)>(v, v);
v = v;
label:
virtualinvoke v.<oadd.org.apache.drill.exec.client.DrillClient: void connect()>();
if v != null goto label;
v = <org.apache.drill.shaded.guava.com.google.common.base.Charsets: java.nio.charset.Charset UTF_8>;
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>(v, v);
v = staticinvoke <java.nio.file.Files: byte[] readAllBytes(java.nio.file.Path)>(v);
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer wrap(byte[])>(v);
v = virtualinvoke v.<java.nio.charset.Charset: java.nio.CharBuffer decode(java.nio.ByteBuffer)>(v);
v = virtualinvoke v.<java.nio.CharBuffer: java.lang.String toString()>();
goto label;
label:
v = v;
label:
v = virtualinvoke v.<oadd.org.apache.drill.exec.client.QuerySubmitter: int submitQuery(oadd.org.apache.drill.exec.client.DrillClient,java.lang.String,java.lang.String,java.lang.String,int)>(v, v, v, v, v);
label:
virtualinvoke v.<oadd.org.apache.drill.exec.client.DrillClient: void close()>();
if v == 0 goto label;
v = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
virtualinvoke v.<oadd.org.apache.drill.exec.server.Drillbit: void close()>();
v = v + 1;
goto label;
label:
virtualinvoke v.<oadd.org.apache.drill.exec.server.RemoteServiceSet: void close()>();
label:
return v;
label:
v := @caughtexception;
v = <java.lang.System: java.io.PrintStream err>;
v = virtualinvoke v.<java.lang.Throwable: java.lang.String getMessage()>();
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[])>("Query Failed due to : \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
label:
if v == null goto label;
virtualinvoke v.<oadd.org.apache.drill.exec.client.DrillClient: void close()>();
label:
if v == 0 goto label;
v = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
virtualinvoke v.<oadd.org.apache.drill.exec.server.Drillbit: void close()>();
v = v + 1;
goto label;
label:
virtualinvoke v.<oadd.org.apache.drill.exec.server.RemoteServiceSet: void close()>();
label:
return -1;
label:
v := @caughtexception;
if v == null goto label;
virtualinvoke v.<oadd.org.apache.drill.exec.client.DrillClient: void close()>();
label:
if v == 0 goto label;
v = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
virtualinvoke v.<oadd.org.apache.drill.exec.server.Drillbit: void close()>();
v = v + 1;
goto label;
label:
virtualinvoke v.<oadd.org.apache.drill.exec.server.RemoteServiceSet: void close()>();
label:
throw v;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public int submitQuery(oadd.org.apache.drill.exec.client.DrillClient, java.lang.String, java.lang.String, java.lang.String, int) throws java.lang.Exception
{
oadd.org.apache.drill.exec.client.QuerySubmitter v;
java.lang.Float v;
java.lang.Integer v;
oadd.org.apache.drill.exec.proto.UserBitShared$QueryType v;
byte v, v;
oadd.org.apache.drill.exec.rpc.user.AwaitableUserResultsListener v;
oadd.org.apache.drill.exec.client.QuerySubmitter$Format v;
boolean v, v, v, v, v, v;
org.apache.drill.shaded.guava.com.google.common.base.Stopwatch v;
float v;
java.lang.Object[] v;
oadd.org.apache.drill.common.config.DrillConfig v;
java.lang.String[] v, v, v, v;
long v;
int v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v;
java.io.PrintStream v, v, v, v;
oadd.org.apache.drill.exec.client.LoggingResultsListener v;
java.util.concurrent.TimeUnit v;
oadd.org.apache.drill.exec.client.DrillClient v;
v := @this: oadd.org.apache.drill.exec.client.QuerySubmitter;
v := @parameter: oadd.org.apache.drill.exec.client.DrillClient;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: int;
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
v = -1;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
lookupswitch(v)
{
case -989077289: goto label;
case 114126: goto label;
case 342334473: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("sql");
if v == 0 goto label;
v = 0;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("logical");
if v == 0 goto label;
v = 1;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("physical");
if v == 0 goto label;
v = 2;
label:
tableswitch(v)
{
case 0: goto label;
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
v = <oadd.org.apache.drill.exec.proto.UserBitShared$QueryType: oadd.org.apache.drill.exec.proto.UserBitShared$QueryType SQL>;
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(";");
goto label;
label:
v = <oadd.org.apache.drill.exec.proto.UserBitShared$QueryType: oadd.org.apache.drill.exec.proto.UserBitShared$QueryType LOGICAL>;
v = newarray (java.lang.String)[1];
v[0] = v;
v = v;
goto label;
label:
v = <oadd.org.apache.drill.exec.proto.UserBitShared$QueryType: oadd.org.apache.drill.exec.proto.UserBitShared$QueryType PHYSICAL>;
v = newarray (java.lang.String)[1];
v[0] = v;
v = v;
goto label;
label:
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[])>("Invalid query type: \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
v = (int) -1;
return v;
label:
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase()>();
v = -1;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
lookupswitch(v)
{
case 98822: goto label;
case 115159: goto label;
case 110115790: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("csv");
if v == 0 goto label;
v = 0;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("tsv");
if v == 0 goto label;
v = 1;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("table");
if v == 0 goto label;
v = 2;
label:
tableswitch(v)
{
case 0: goto label;
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
v = <oadd.org.apache.drill.exec.client.QuerySubmitter$Format: oadd.org.apache.drill.exec.client.QuerySubmitter$Format CSV>;
goto label;
label:
v = <oadd.org.apache.drill.exec.client.QuerySubmitter$Format: oadd.org.apache.drill.exec.client.QuerySubmitter$Format TSV>;
goto label;
label:
v = <oadd.org.apache.drill.exec.client.QuerySubmitter$Format: oadd.org.apache.drill.exec.client.QuerySubmitter$Format TABLE>;
goto label;
label:
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[])>("Invalid format type: \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
v = (int) -1;
return v;
label:
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Stopwatch: org.apache.drill.shaded.guava.com.google.common.base.Stopwatch createUnstarted()>();
v = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = new oadd.org.apache.drill.exec.rpc.user.AwaitableUserResultsListener;
v = new oadd.org.apache.drill.exec.client.LoggingResultsListener;
v = virtualinvoke v.<oadd.org.apache.drill.exec.client.DrillClient: oadd.org.apache.drill.common.config.DrillConfig getConfig()>();
specialinvoke v.<oadd.org.apache.drill.exec.client.LoggingResultsListener: void <init>(oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.drill.exec.client.QuerySubmitter$Format,int)>(v, v, v);
specialinvoke v.<oadd.org.apache.drill.exec.rpc.user.AwaitableUserResultsListener: void <init>(oadd.org.apache.drill.exec.rpc.user.UserResultsListener)>(v);
virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.base.Stopwatch: org.apache.drill.shaded.guava.com.google.common.base.Stopwatch start()>();
virtualinvoke v.<oadd.org.apache.drill.exec.client.DrillClient: void runQuery(oadd.org.apache.drill.exec.proto.UserBitShared$QueryType,java.lang.String,oadd.org.apache.drill.exec.rpc.user.UserResultsListener)>(v, v, v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.rpc.user.AwaitableUserResultsListener: int await()>();
v = <java.lang.System: java.io.PrintStream out>;
v = newarray (java.lang.Object)[3];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
if v <= 1 goto label;
v = "s";
goto label;
label:
v = "";
label:
v[1] = v;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.base.Stopwatch: long elapsed(java.util.concurrent.TimeUnit)>(v);
v = v / 1000.0F;
v = staticinvoke <java.lang.Float: java.lang.Float valueOf(float)>(v);
v[2] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("%d record%s selected (%f seconds)", v);
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
v = lengthof v;
v = v - 1;
v = v[v];
if v == v goto label;
v = <java.lang.System: java.io.PrintStream out>;
virtualinvoke v.<java.io.PrintStream: void println()>();
label:
virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.base.Stopwatch: org.apache.drill.shaded.guava.com.google.common.base.Stopwatch stop()>();
virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.base.Stopwatch: org.apache.drill.shaded.guava.com.google.common.base.Stopwatch reset()>();
v = v + 1;
goto label;
label:
return 0;
}
}