public class org.apache.hive.hcatalog.templeton.Server extends java.lang.Object
{
public static final java.lang.String VERSION;
public static final java.lang.String DO_AS_PARAM;
public static final java.util.Map STATUS_OK;
public static final java.util.Map SUPPORTED_VERSIONS;
public static final java.util.Map SUPPORTED_FORMATS;
protected static org.apache.hive.hcatalog.templeton.ExecService execService;
private static org.apache.hive.hcatalog.templeton.AppConfig appConf;
private javax.ws.rs.core.SecurityContext theSecurityContext;
private javax.ws.rs.core.UriInfo theUriInfo;
private java.lang.String doAs;
private javax.servlet.http.HttpServletRequest request;
private static final org.slf4j.Logger LOG;
public static final java.util.regex.Pattern DDL_ID;
public static final java.util.regex.Pattern PROPERTY_ID;
public void <init>()
{
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
private static java.util.Map createStatusMsg()
{
java.util.HashMap v;
java.util.Map v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("status", "ok");
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("version", "v1");
v = staticinvoke <java.util.Collections: java.util.Map unmodifiableMap(java.util.Map)>(v);
return v;
}
private static java.util.Map createVersions()
{
java.util.HashMap v;
java.util.ArrayList v;
java.util.Map v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>("v1");
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("supportedVersions", v);
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("version", "v1");
v = staticinvoke <java.util.Collections: java.util.Map unmodifiableMap(java.util.Map)>(v);
return v;
}
private static java.util.Map createFormats()
{
java.util.HashMap v;
java.util.ArrayList v;
java.util.Map v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>("application/json");
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
virtualinvoke v.<java.util.HashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>("responseTypes", v);
v = staticinvoke <java.util.Collections: java.util.Map unmodifiableMap(java.util.Map)>(v);
return v;
}
public java.util.Map status()
{
org.apache.hive.hcatalog.templeton.Server v;
java.util.Map v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v = <org.apache.hive.hcatalog.templeton.Server: java.util.Map STATUS_OK>;
return v;
}
public java.util.Map requestFormats()
{
org.apache.hive.hcatalog.templeton.Server v;
java.util.Map v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v = <org.apache.hive.hcatalog.templeton.Server: java.util.Map SUPPORTED_FORMATS>;
return v;
}
public java.util.Map version()
{
org.apache.hive.hcatalog.templeton.Server v;
java.util.Map v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v = <org.apache.hive.hcatalog.templeton.Server: java.util.Map SUPPORTED_VERSIONS>;
return v;
}
public javax.ws.rs.core.Response hadoopVersion() throws java.io.IOException
{
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
org.apache.hive.hcatalog.templeton.VersionDelegator v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v = new org.apache.hive.hcatalog.templeton.VersionDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.VersionDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig)>(v);
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.VersionDelegator: javax.ws.rs.core.Response getVersion(java.lang.String)>("hadoop");
return v;
}
public javax.ws.rs.core.Response hiveVersion() throws java.io.IOException
{
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
org.apache.hive.hcatalog.templeton.VersionDelegator v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v = new org.apache.hive.hcatalog.templeton.VersionDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.VersionDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig)>(v);
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.VersionDelegator: javax.ws.rs.core.Response getVersion(java.lang.String)>("hive");
return v;
}
public javax.ws.rs.core.Response sqoopVersion() throws java.io.IOException
{
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
org.apache.hive.hcatalog.templeton.VersionDelegator v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v = new org.apache.hive.hcatalog.templeton.VersionDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.VersionDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig)>(v);
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.VersionDelegator: javax.ws.rs.core.Response getVersion(java.lang.String)>("sqoop");
return v;
}
public javax.ws.rs.core.Response pigVersion() throws java.io.IOException
{
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
org.apache.hive.hcatalog.templeton.VersionDelegator v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v = new org.apache.hive.hcatalog.templeton.VersionDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.VersionDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig)>(v);
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.VersionDelegator: javax.ws.rs.core.Response getVersion(java.lang.String)>("pig");
return v;
}
public org.apache.hive.hcatalog.templeton.ExecBean ddl(java.lang.String, java.lang.String, java.lang.String) throws org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.commons.exec.ExecuteException, java.io.IOException
{
org.apache.hive.hcatalog.templeton.ExecService v;
org.apache.hive.hcatalog.templeton.HcatDelegator v;
org.apache.hive.hcatalog.templeton.ExecBean v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.String v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyParam(java.lang.String,java.lang.String)>(v, "exec");
v = new org.apache.hive.hcatalog.templeton.HcatDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig,org.apache.hive.hcatalog.templeton.ExecService)>(v, v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: org.apache.hive.hcatalog.templeton.ExecBean run(java.lang.String,java.lang.String,boolean,java.lang.String,java.lang.String)>(v, v, 0, v, v);
return v;
}
public javax.ws.rs.core.Response listTables(java.lang.String, java.lang.String) throws org.apache.hive.hcatalog.templeton.HcatException, org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.commons.exec.ExecuteException, java.io.IOException
{
org.apache.hive.hcatalog.templeton.ExecService v;
org.apache.hive.hcatalog.templeton.HcatDelegator v;
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.String v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
boolean v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":db");
v = new org.apache.hive.hcatalog.templeton.HcatDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig,org.apache.hive.hcatalog.templeton.ExecService)>(v, v);
v = staticinvoke <org.apache.hive.hcatalog.templeton.tool.TempletonUtils: boolean isset(java.lang.String)>(v);
if v != 0 goto label;
v = "*";
label:
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: javax.ws.rs.core.Response listTables(java.lang.String,java.lang.String,java.lang.String)>(v, v, v);
return v;
}
public javax.ws.rs.core.Response createTable(java.lang.String, java.lang.String, org.apache.hive.hcatalog.templeton.TableDesc) throws org.apache.hive.hcatalog.templeton.SimpleWebException, org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.commons.exec.ExecuteException, java.io.IOException
{
org.apache.hive.hcatalog.templeton.ExecService v;
org.apache.hive.hcatalog.templeton.HcatDelegator v;
org.apache.hive.hcatalog.templeton.TableDesc v;
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.String v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hive.hcatalog.templeton.TableDesc;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":db");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":table");
v.<org.apache.hive.hcatalog.templeton.TableDesc: java.lang.String table> = v;
v = new org.apache.hive.hcatalog.templeton.HcatDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig,org.apache.hive.hcatalog.templeton.ExecService)>(v, v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: javax.ws.rs.core.Response createTable(java.lang.String,java.lang.String,org.apache.hive.hcatalog.templeton.TableDesc)>(v, v, v);
return v;
}
public javax.ws.rs.core.Response createTableLike(java.lang.String, java.lang.String, java.lang.String, org.apache.hive.hcatalog.templeton.TableLikeDesc) throws org.apache.hive.hcatalog.templeton.SimpleWebException, org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.commons.exec.ExecuteException, java.io.IOException
{
org.apache.hive.hcatalog.templeton.ExecService v;
org.apache.hive.hcatalog.templeton.HcatDelegator v;
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
org.apache.hive.hcatalog.templeton.TableLikeDesc v;
java.lang.String v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hive.hcatalog.templeton.TableLikeDesc;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":db");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":existingTable");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":newTable");
v.<org.apache.hive.hcatalog.templeton.TableLikeDesc: java.lang.String existingTable> = v;
v.<org.apache.hive.hcatalog.templeton.TableLikeDesc: java.lang.String newTable> = v;
v = new org.apache.hive.hcatalog.templeton.HcatDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig,org.apache.hive.hcatalog.templeton.ExecService)>(v, v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: javax.ws.rs.core.Response createTableLike(java.lang.String,java.lang.String,org.apache.hive.hcatalog.templeton.TableLikeDesc)>(v, v, v);
return v;
}
public javax.ws.rs.core.Response descTable(java.lang.String, java.lang.String, java.lang.String) throws org.apache.hive.hcatalog.templeton.HcatException, org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.commons.exec.ExecuteException, java.io.IOException
{
org.apache.hive.hcatalog.templeton.ExecService v;
org.apache.hive.hcatalog.templeton.HcatDelegator v;
javax.ws.rs.core.Response v, v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.String v, v, v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
boolean v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":db");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":table");
v = new org.apache.hive.hcatalog.templeton.HcatDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig,org.apache.hive.hcatalog.templeton.ExecService)>(v, v);
v = "extended";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: javax.ws.rs.core.Response descExtendedTable(java.lang.String,java.lang.String,java.lang.String)>(v, v, v);
return v;
label:
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: javax.ws.rs.core.Response descTable(java.lang.String,java.lang.String,java.lang.String,boolean)>(v, v, v, 0);
return v;
}
public javax.ws.rs.core.Response dropTable(java.lang.String, java.lang.String, boolean, java.lang.String, java.lang.String) throws org.apache.hive.hcatalog.templeton.HcatException, org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.commons.exec.ExecuteException, java.io.IOException
{
org.apache.hive.hcatalog.templeton.ExecService v;
org.apache.hive.hcatalog.templeton.HcatDelegator v;
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.String v, v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
boolean v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":db");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":table");
v = new org.apache.hive.hcatalog.templeton.HcatDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig,org.apache.hive.hcatalog.templeton.ExecService)>(v, v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: javax.ws.rs.core.Response dropTable(java.lang.String,java.lang.String,java.lang.String,boolean,java.lang.String,java.lang.String)>(v, v, v, v, v, v);
return v;
}
public javax.ws.rs.core.Response renameTable(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String) throws org.apache.hive.hcatalog.templeton.HcatException, org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.commons.exec.ExecuteException, java.io.IOException
{
org.apache.hive.hcatalog.templeton.ExecService v;
org.apache.hive.hcatalog.templeton.HcatDelegator v;
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.String v, v, v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":db");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":table");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, "rename");
v = new org.apache.hive.hcatalog.templeton.HcatDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig,org.apache.hive.hcatalog.templeton.ExecService)>(v, v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: javax.ws.rs.core.Response renameTable(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v, v);
return v;
}
public javax.ws.rs.core.Response descOneTableProperty(java.lang.String, java.lang.String, java.lang.String) throws org.apache.hive.hcatalog.templeton.HcatException, org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.commons.exec.ExecuteException, java.io.IOException
{
org.apache.hive.hcatalog.templeton.ExecService v;
org.apache.hive.hcatalog.templeton.HcatDelegator v;
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.String v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":db");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":table");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyPropertyParam(java.lang.String,java.lang.String)>(v, ":property");
v = new org.apache.hive.hcatalog.templeton.HcatDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig,org.apache.hive.hcatalog.templeton.ExecService)>(v, v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: javax.ws.rs.core.Response descTableProperty(java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v);
return v;
}
public javax.ws.rs.core.Response listTableProperties(java.lang.String, java.lang.String) throws org.apache.hive.hcatalog.templeton.HcatException, org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.commons.exec.ExecuteException, java.io.IOException
{
org.apache.hive.hcatalog.templeton.ExecService v;
org.apache.hive.hcatalog.templeton.HcatDelegator v;
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.String v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":db");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":table");
v = new org.apache.hive.hcatalog.templeton.HcatDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig,org.apache.hive.hcatalog.templeton.ExecService)>(v, v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: javax.ws.rs.core.Response listTableProperties(java.lang.String,java.lang.String,java.lang.String)>(v, v, v);
return v;
}
public javax.ws.rs.core.Response addOneTableProperty(java.lang.String, java.lang.String, java.lang.String, org.apache.hive.hcatalog.templeton.TablePropertyDesc) throws org.apache.hive.hcatalog.templeton.HcatException, org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.commons.exec.ExecuteException, java.io.IOException
{
org.apache.hive.hcatalog.templeton.ExecService v;
org.apache.hive.hcatalog.templeton.HcatDelegator v;
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.String v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
org.apache.hive.hcatalog.templeton.TablePropertyDesc v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hive.hcatalog.templeton.TablePropertyDesc;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":db");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":table");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyPropertyParam(java.lang.String,java.lang.String)>(v, ":property");
v.<org.apache.hive.hcatalog.templeton.TablePropertyDesc: java.lang.String name> = v;
v = new org.apache.hive.hcatalog.templeton.HcatDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig,org.apache.hive.hcatalog.templeton.ExecService)>(v, v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: javax.ws.rs.core.Response addOneTableProperty(java.lang.String,java.lang.String,java.lang.String,org.apache.hive.hcatalog.templeton.TablePropertyDesc)>(v, v, v, v);
return v;
}
public javax.ws.rs.core.Response listPartitions(java.lang.String, java.lang.String) throws org.apache.hive.hcatalog.templeton.HcatException, org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.commons.exec.ExecuteException, java.io.IOException
{
org.apache.hive.hcatalog.templeton.ExecService v;
org.apache.hive.hcatalog.templeton.HcatDelegator v;
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.String v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":db");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":table");
v = new org.apache.hive.hcatalog.templeton.HcatDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig,org.apache.hive.hcatalog.templeton.ExecService)>(v, v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: javax.ws.rs.core.Response listPartitions(java.lang.String,java.lang.String,java.lang.String)>(v, v, v);
return v;
}
public javax.ws.rs.core.Response descPartition(java.lang.String, java.lang.String, java.lang.String) throws org.apache.hive.hcatalog.templeton.HcatException, org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.commons.exec.ExecuteException, java.io.IOException
{
org.apache.hive.hcatalog.templeton.ExecService v;
org.apache.hive.hcatalog.templeton.HcatDelegator v;
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.String v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":db");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":table");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyParam(java.lang.String,java.lang.String)>(v, ":partition");
v = new org.apache.hive.hcatalog.templeton.HcatDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig,org.apache.hive.hcatalog.templeton.ExecService)>(v, v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: javax.ws.rs.core.Response descOnePartition(java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v);
return v;
}
public javax.ws.rs.core.Response addOnePartition(java.lang.String, java.lang.String, java.lang.String, org.apache.hive.hcatalog.templeton.PartitionDesc) throws org.apache.hive.hcatalog.templeton.HcatException, org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.commons.exec.ExecuteException, java.io.IOException
{
org.apache.hive.hcatalog.templeton.PartitionDesc v;
org.apache.hive.hcatalog.templeton.ExecService v;
org.apache.hive.hcatalog.templeton.HcatDelegator v;
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.String v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hive.hcatalog.templeton.PartitionDesc;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":db");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":table");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyParam(java.lang.String,java.lang.String)>(v, ":partition");
v.<org.apache.hive.hcatalog.templeton.PartitionDesc: java.lang.String partition> = v;
v = new org.apache.hive.hcatalog.templeton.HcatDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig,org.apache.hive.hcatalog.templeton.ExecService)>(v, v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: javax.ws.rs.core.Response addOnePartition(java.lang.String,java.lang.String,java.lang.String,org.apache.hive.hcatalog.templeton.PartitionDesc)>(v, v, v, v);
return v;
}
public javax.ws.rs.core.Response dropPartition(java.lang.String, java.lang.String, java.lang.String, boolean, java.lang.String, java.lang.String) throws org.apache.hive.hcatalog.templeton.HcatException, org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.commons.exec.ExecuteException, java.io.IOException
{
org.apache.hive.hcatalog.templeton.ExecService v;
org.apache.hive.hcatalog.templeton.HcatDelegator v;
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.String v, v, v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
boolean v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":db");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":table");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyParam(java.lang.String,java.lang.String)>(v, ":partition");
v = new org.apache.hive.hcatalog.templeton.HcatDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig,org.apache.hive.hcatalog.templeton.ExecService)>(v, v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: javax.ws.rs.core.Response dropPartition(java.lang.String,java.lang.String,java.lang.String,java.lang.String,boolean,java.lang.String,java.lang.String)>(v, v, v, v, v, v, v);
return v;
}
public javax.ws.rs.core.Response listDatabases(java.lang.String) throws org.apache.hive.hcatalog.templeton.HcatException, org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.commons.exec.ExecuteException, java.io.IOException
{
org.apache.hive.hcatalog.templeton.ExecService v;
org.apache.hive.hcatalog.templeton.HcatDelegator v;
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.String v, v;
org.apache.hive.hcatalog.templeton.Server v;
boolean v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
v = new org.apache.hive.hcatalog.templeton.HcatDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig,org.apache.hive.hcatalog.templeton.ExecService)>(v, v);
v = staticinvoke <org.apache.hive.hcatalog.templeton.tool.TempletonUtils: boolean isset(java.lang.String)>(v);
if v != 0 goto label;
v = "*";
label:
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: javax.ws.rs.core.Response listDatabases(java.lang.String,java.lang.String)>(v, v);
return v;
}
public javax.ws.rs.core.Response descDatabase(java.lang.String, java.lang.String) throws org.apache.hive.hcatalog.templeton.HcatException, org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.commons.exec.ExecuteException, java.io.IOException
{
org.apache.hive.hcatalog.templeton.ExecService v;
org.apache.hive.hcatalog.templeton.HcatDelegator v;
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.String v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
boolean v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":db");
v = new org.apache.hive.hcatalog.templeton.HcatDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig,org.apache.hive.hcatalog.templeton.ExecService)>(v, v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = "extended";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: javax.ws.rs.core.Response descDatabase(java.lang.String,java.lang.String,boolean)>(v, v, v);
return v;
}
public javax.ws.rs.core.Response createDatabase(java.lang.String, org.apache.hive.hcatalog.templeton.DatabaseDesc) throws org.apache.hive.hcatalog.templeton.HcatException, org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.commons.exec.ExecuteException, java.io.IOException
{
org.apache.hive.hcatalog.templeton.ExecService v;
org.apache.hive.hcatalog.templeton.HcatDelegator v;
org.apache.hive.hcatalog.templeton.DatabaseDesc v;
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.String v, v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hive.hcatalog.templeton.DatabaseDesc;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":db");
v.<org.apache.hive.hcatalog.templeton.DatabaseDesc: java.lang.String database> = v;
v = new org.apache.hive.hcatalog.templeton.HcatDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig,org.apache.hive.hcatalog.templeton.ExecService)>(v, v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: javax.ws.rs.core.Response createDatabase(java.lang.String,org.apache.hive.hcatalog.templeton.DatabaseDesc)>(v, v);
return v;
}
public javax.ws.rs.core.Response dropDatabase(java.lang.String, boolean, java.lang.String, java.lang.String, java.lang.String) throws org.apache.hive.hcatalog.templeton.HcatException, org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.commons.exec.ExecuteException, java.io.IOException
{
org.apache.hive.hcatalog.templeton.ExecService v;
org.apache.hive.hcatalog.templeton.HcatDelegator v;
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.String v, v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
boolean v, v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":db");
v = staticinvoke <org.apache.hive.hcatalog.templeton.tool.TempletonUtils: boolean isset(java.lang.String)>(v);
if v == 0 goto label;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, "option");
label:
v = new org.apache.hive.hcatalog.templeton.HcatDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig,org.apache.hive.hcatalog.templeton.ExecService)>(v, v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: javax.ws.rs.core.Response dropDatabase(java.lang.String,java.lang.String,boolean,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v, v);
return v;
}
public javax.ws.rs.core.Response listColumns(java.lang.String, java.lang.String) throws org.apache.hive.hcatalog.templeton.HcatException, org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.commons.exec.ExecuteException, java.io.IOException
{
org.apache.hive.hcatalog.templeton.ExecService v;
org.apache.hive.hcatalog.templeton.HcatDelegator v;
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.String v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":db");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":table");
v = new org.apache.hive.hcatalog.templeton.HcatDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig,org.apache.hive.hcatalog.templeton.ExecService)>(v, v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: javax.ws.rs.core.Response listColumns(java.lang.String,java.lang.String,java.lang.String)>(v, v, v);
return v;
}
public javax.ws.rs.core.Response descColumn(java.lang.String, java.lang.String, java.lang.String) throws org.apache.hive.hcatalog.templeton.SimpleWebException, org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.commons.exec.ExecuteException, java.io.IOException
{
org.apache.hive.hcatalog.templeton.ExecService v;
org.apache.hive.hcatalog.templeton.HcatDelegator v;
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.String v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":db");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":table");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyParam(java.lang.String,java.lang.String)>(v, ":column");
v = new org.apache.hive.hcatalog.templeton.HcatDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig,org.apache.hive.hcatalog.templeton.ExecService)>(v, v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: javax.ws.rs.core.Response descOneColumn(java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v);
return v;
}
public javax.ws.rs.core.Response addOneColumn(java.lang.String, java.lang.String, java.lang.String, org.apache.hive.hcatalog.templeton.ColumnDesc) throws org.apache.hive.hcatalog.templeton.HcatException, org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.commons.exec.ExecuteException, java.io.IOException
{
org.apache.hive.hcatalog.templeton.ColumnDesc v;
org.apache.hive.hcatalog.templeton.ExecService v;
org.apache.hive.hcatalog.templeton.HcatDelegator v;
javax.ws.rs.core.Response v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.String v, v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hive.hcatalog.templeton.ColumnDesc;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":db");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyDdlParam(java.lang.String,java.lang.String)>(v, ":table");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyParam(java.lang.String,java.lang.String)>(v, ":column");
v = v.<org.apache.hive.hcatalog.templeton.ColumnDesc: java.lang.String type>;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyParam(java.lang.String,java.lang.String)>(v, "type");
v.<org.apache.hive.hcatalog.templeton.ColumnDesc: java.lang.String name> = v;
v = new org.apache.hive.hcatalog.templeton.HcatDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig,org.apache.hive.hcatalog.templeton.ExecService)>(v, v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HcatDelegator: javax.ws.rs.core.Response addOneColumn(java.lang.String,java.lang.String,java.lang.String,org.apache.hive.hcatalog.templeton.ColumnDesc)>(v, v, v, v);
return v;
}
public org.apache.hive.hcatalog.templeton.EnqueueBean mapReduceStreaming(java.util.List, java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.util.List, java.lang.String, java.util.List, java.util.List, java.util.List, java.lang.String, java.lang.String, boolean, java.lang.Boolean) throws org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.hive.hcatalog.templeton.QueueException, org.apache.commons.exec.ExecuteException, java.io.IOException, java.lang.InterruptedException, org.apache.hive.hcatalog.templeton.TooManyRequestsException
{
org.apache.hive.hcatalog.templeton.EnqueueBean v;
java.util.HashMap v;
java.lang.Boolean v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
boolean v;
org.apache.hive.hcatalog.templeton.LauncherDelegator$JobType v;
java.util.List v, v, v, v, v;
org.apache.hive.hcatalog.templeton.AppConfig v;
org.apache.hive.hcatalog.templeton.StreamingDelegator v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
v := @parameter: java.util.List;
v := @parameter: java.util.List;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v := @parameter: java.lang.Boolean;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyParam(java.util.List,java.lang.String)>(v, "input");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyParam(java.lang.String,java.lang.String)>(v, "mapper");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyParam(java.lang.String,java.lang.String)>(v, "reducer");
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("user.name", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("input", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("inputreader", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("output", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("mapper", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("reducer", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("combiner", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("file", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("files", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("define", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("cmdenv", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("arg", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("statusdir", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("callback", v);
v = staticinvoke <java.lang.Boolean: java.lang.String toString(boolean)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("enablelog", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("enablejobreconnect", v);
specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: void checkEnableLogPrerequisite(boolean,java.lang.String)>(v, v);
v = new org.apache.hive.hcatalog.templeton.StreamingDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.StreamingDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig)>(v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getCompletedUrl()>();
v = <org.apache.hive.hcatalog.templeton.LauncherDelegator$JobType: org.apache.hive.hcatalog.templeton.LauncherDelegator$JobType STREAMING>;
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.StreamingDelegator: org.apache.hive.hcatalog.templeton.EnqueueBean run(java.lang.String,java.util.Map,java.util.List,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.lang.String,java.util.List,java.util.List,java.util.List,java.lang.String,java.lang.String,java.lang.String,boolean,java.lang.Boolean,org.apache.hive.hcatalog.templeton.LauncherDelegator$JobType)>(v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v);
return v;
}
public org.apache.hive.hcatalog.templeton.EnqueueBean mapReduceJar(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.util.List, java.util.List, java.lang.String, java.lang.String, boolean, boolean, java.lang.Boolean) throws org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.hive.hcatalog.templeton.QueueException, org.apache.commons.exec.ExecuteException, java.io.IOException, java.lang.InterruptedException, org.apache.hive.hcatalog.templeton.TooManyRequestsException
{
org.apache.hive.hcatalog.templeton.EnqueueBean v;
java.util.HashMap v;
java.lang.Boolean v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
boolean v, v;
org.apache.hive.hcatalog.templeton.JarDelegator v;
org.apache.hive.hcatalog.templeton.LauncherDelegator$JobType v;
java.util.List v, v;
org.apache.hive.hcatalog.templeton.AppConfig v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.util.List;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v := @parameter: boolean;
v := @parameter: java.lang.Boolean;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyParam(java.lang.String,java.lang.String)>(v, "jar");
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyParam(java.lang.String,java.lang.String)>(v, "class");
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("user.name", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("jar", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("class", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("libjars", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("files", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("arg", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("define", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("statusdir", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("callback", v);
v = staticinvoke <java.lang.Boolean: java.lang.String toString(boolean)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("enablelog", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("enablejobreconnect", v);
specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: void checkEnableLogPrerequisite(boolean,java.lang.String)>(v, v);
v = new org.apache.hive.hcatalog.templeton.JarDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.JarDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig)>(v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getCompletedUrl()>();
v = <org.apache.hive.hcatalog.templeton.LauncherDelegator$JobType: org.apache.hive.hcatalog.templeton.LauncherDelegator$JobType JAR>;
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.JarDelegator: org.apache.hive.hcatalog.templeton.EnqueueBean run(java.lang.String,java.util.Map,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.util.List,java.lang.String,java.lang.String,boolean,java.lang.String,boolean,java.lang.Boolean,org.apache.hive.hcatalog.templeton.LauncherDelegator$JobType)>(v, v, v, v, v, v, v, v, v, v, v, v, v, v, v);
return v;
}
public org.apache.hive.hcatalog.templeton.EnqueueBean pig(java.lang.String, java.lang.String, java.util.List, java.lang.String, java.lang.String, java.lang.String, boolean, boolean, java.lang.Boolean) throws org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.hive.hcatalog.templeton.QueueException, org.apache.commons.exec.ExecuteException, java.io.IOException, java.lang.InterruptedException, org.apache.hive.hcatalog.templeton.TooManyRequestsException
{
org.apache.hive.hcatalog.templeton.EnqueueBean v;
java.util.HashMap v;
org.apache.hive.hcatalog.templeton.BadParam v;
java.lang.Boolean v;
java.lang.String v, v, v, v, v, v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
boolean v, v;
java.util.List v;
org.apache.hive.hcatalog.templeton.AppConfig v;
org.apache.hive.hcatalog.templeton.PigDelegator v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v := @parameter: boolean;
v := @parameter: java.lang.Boolean;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
if v != null goto label;
if v != null goto label;
v = new org.apache.hive.hcatalog.templeton.BadParam;
specialinvoke v.<org.apache.hive.hcatalog.templeton.BadParam: void <init>(java.lang.String)>("Either execute or file parameter required");
throw v;
label:
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("user.name", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("execute", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("file", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("arg", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("files", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("statusdir", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("callback", v);
v = staticinvoke <java.lang.Boolean: java.lang.String toString(boolean)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("enablelog", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("enablejobreconnect", v);
specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: void checkEnableLogPrerequisite(boolean,java.lang.String)>(v, v);
v = new org.apache.hive.hcatalog.templeton.PigDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.PigDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig)>(v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getCompletedUrl()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.PigDelegator: org.apache.hive.hcatalog.templeton.EnqueueBean run(java.lang.String,java.util.Map,java.lang.String,java.lang.String,java.util.List,java.lang.String,java.lang.String,java.lang.String,boolean,java.lang.String,boolean,java.lang.Boolean)>(v, v, v, v, v, v, v, v, v, v, v, v);
return v;
}
public org.apache.hive.hcatalog.templeton.EnqueueBean sqoop(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String, boolean, java.lang.Boolean) throws org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.hive.hcatalog.templeton.QueueException, java.io.IOException, java.lang.InterruptedException, org.apache.hive.hcatalog.templeton.TooManyRequestsException
{
org.apache.hive.hcatalog.templeton.EnqueueBean v;
java.util.HashMap v;
org.apache.hive.hcatalog.templeton.BadParam v, v;
java.lang.Boolean v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
boolean v;
org.apache.hive.hcatalog.templeton.SqoopDelegator v;
org.apache.hive.hcatalog.templeton.AppConfig v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
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: java.lang.Boolean;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
if v != null goto label;
if v != null goto label;
v = new org.apache.hive.hcatalog.templeton.BadParam;
specialinvoke v.<org.apache.hive.hcatalog.templeton.BadParam: void <init>(java.lang.String)>("Must define Sqoop command or a optionsfile contains Sqoop command to run Sqoop job.");
throw v;
label:
if v == null goto label;
if v == null goto label;
v = new org.apache.hive.hcatalog.templeton.BadParam;
specialinvoke v.<org.apache.hive.hcatalog.templeton.BadParam: void <init>(java.lang.String)>("Cannot set command and optionsfile at the same time.");
throw v;
label:
specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: void checkEnableLogPrerequisite(boolean,java.lang.String)>(v, v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("user.name", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("command", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("optionsfile", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("libdir", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("files", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("statusdir", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("callback", v);
v = staticinvoke <java.lang.Boolean: java.lang.String toString(boolean)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("enablelog", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("enablejobreconnect", v);
v = new org.apache.hive.hcatalog.templeton.SqoopDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.SqoopDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig)>(v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getCompletedUrl()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.SqoopDelegator: org.apache.hive.hcatalog.templeton.EnqueueBean run(java.lang.String,java.util.Map,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,boolean,java.lang.Boolean,java.lang.String)>(v, v, v, v, v, v, v, v, v, v, v);
return v;
}
public org.apache.hive.hcatalog.templeton.EnqueueBean hive(java.lang.String, java.lang.String, java.util.List, java.lang.String, java.util.List, java.lang.String, java.lang.String, boolean, java.lang.Boolean) throws org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BusyException, org.apache.hive.hcatalog.templeton.BadParam, org.apache.hive.hcatalog.templeton.QueueException, org.apache.commons.exec.ExecuteException, java.io.IOException, java.lang.InterruptedException, org.apache.hive.hcatalog.templeton.TooManyRequestsException
{
org.apache.hive.hcatalog.templeton.EnqueueBean v;
java.util.HashMap v;
org.apache.hive.hcatalog.templeton.BadParam v;
java.lang.Boolean v;
org.apache.hive.hcatalog.templeton.HiveDelegator v;
java.lang.String v, v, v, v, v, v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
boolean v;
java.util.List v, v;
org.apache.hive.hcatalog.templeton.AppConfig v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v := @parameter: java.lang.Boolean;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
if v != null goto label;
if v != null goto label;
v = new org.apache.hive.hcatalog.templeton.BadParam;
specialinvoke v.<org.apache.hive.hcatalog.templeton.BadParam: void <init>(java.lang.String)>("Either execute or file parameter required");
throw v;
label:
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("user.name", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("execute", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("file", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("define", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("files", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("statusdir", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("callback", v);
v = staticinvoke <java.lang.Boolean: java.lang.String toString(boolean)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("enablelog", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("enablejobreconnect", v);
specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: void checkEnableLogPrerequisite(boolean,java.lang.String)>(v, v);
v = new org.apache.hive.hcatalog.templeton.HiveDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.HiveDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig)>(v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getCompletedUrl()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.HiveDelegator: org.apache.hive.hcatalog.templeton.EnqueueBean run(java.lang.String,java.util.Map,java.lang.String,java.lang.String,java.util.List,java.util.List,java.lang.String,java.lang.String,java.lang.String,java.lang.String,boolean,java.lang.Boolean)>(v, v, v, v, v, v, v, v, v, v, v, v);
return v;
}
public org.apache.hive.hcatalog.templeton.QueueStatusBean showJobId(java.lang.String) throws org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BadParam, java.io.IOException, java.lang.InterruptedException, org.apache.hive.hcatalog.templeton.BusyException, java.util.concurrent.TimeoutException, java.util.concurrent.ExecutionException, org.apache.hive.hcatalog.templeton.TooManyRequestsException
{
org.apache.hive.hcatalog.templeton.AppConfig v;
org.apache.hive.hcatalog.templeton.QueueStatusBean v;
org.apache.hive.hcatalog.templeton.StatusDelegator v;
java.lang.String v, v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyParam(java.lang.String,java.lang.String)>(v, ":jobid");
v = new org.apache.hive.hcatalog.templeton.StatusDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.StatusDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig)>(v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.StatusDelegator: org.apache.hive.hcatalog.templeton.QueueStatusBean run(java.lang.String,java.lang.String)>(v, v);
return v;
}
public org.apache.hive.hcatalog.templeton.QueueStatusBean deleteJobId(java.lang.String) throws org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BadParam, java.io.IOException, java.lang.InterruptedException
{
org.apache.hive.hcatalog.templeton.AppConfig v;
org.apache.hive.hcatalog.templeton.QueueStatusBean v;
org.apache.hive.hcatalog.templeton.DeleteDelegator v;
java.lang.String v, v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyParam(java.lang.String,java.lang.String)>(v, ":jobid");
v = new org.apache.hive.hcatalog.templeton.DeleteDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.DeleteDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig)>(v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.DeleteDelegator: org.apache.hive.hcatalog.templeton.QueueStatusBean run(java.lang.String,java.lang.String)>(v, v);
return v;
}
public java.util.List showJobList(java.lang.String, boolean, java.lang.String, java.lang.String) throws org.apache.hive.hcatalog.templeton.NotAuthorizedException, org.apache.hive.hcatalog.templeton.BadParam, java.io.IOException, java.lang.InterruptedException, org.apache.hive.hcatalog.templeton.BusyException, java.util.concurrent.TimeoutException, java.util.concurrent.ExecutionException, org.apache.hive.hcatalog.templeton.TooManyRequestsException
{
org.apache.hive.hcatalog.templeton.BadParam v, v, v;
org.apache.hive.hcatalog.templeton.ListDelegator v;
int v, v;
java.lang.String v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
boolean v, v, v, v;
java.lang.Exception v;
java.util.List v;
org.apache.hive.hcatalog.templeton.AppConfig v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyUser()>();
v = 0;
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("*");
if v != 0 goto label;
v = new org.apache.hive.hcatalog.templeton.BadParam;
specialinvoke v.<org.apache.hive.hcatalog.templeton.BadParam: void <init>(java.lang.String)>("fields value other than * is not supported");
throw v;
label:
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("*");
if v == 0 goto label;
v = 1;
label:
if v == null goto label;
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
if v > 0 goto label;
v = new org.apache.hive.hcatalog.templeton.BadParam;
specialinvoke v.<org.apache.hive.hcatalog.templeton.BadParam: void <init>(java.lang.String)>("numrecords should be an integer > 0");
throw v;
label:
v = (int) -1;
v = v;
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.hive.hcatalog.templeton.BadParam;
specialinvoke v.<org.apache.hive.hcatalog.templeton.BadParam: void <init>(java.lang.String)>("Invalid numrecords format: numrecords should be an integer > 0");
throw v;
label:
v = new org.apache.hive.hcatalog.templeton.ListDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.ListDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig)>(v);
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getDoAsUser()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.ListDelegator: java.util.List run(java.lang.String,boolean,java.lang.String,int,boolean)>(v, v, v, v, v);
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.hcatalog.templeton.CompleteBean completeJob(java.lang.String, java.lang.String) throws org.apache.hive.hcatalog.templeton.CallbackFailedException, java.io.IOException
{
org.slf4j.Logger v;
org.apache.hive.hcatalog.templeton.CompleteBean v;
org.apache.hive.hcatalog.templeton.CompleteDelegator v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.lang.String v, v, v;
java.net.URI v;
javax.ws.rs.core.UriInfo v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = <org.apache.hive.hcatalog.templeton.Server: org.slf4j.Logger LOG>;
v = v.<org.apache.hive.hcatalog.templeton.Server: javax.ws.rs.core.UriInfo theUriInfo>;
v = interfaceinvoke v.<javax.ws.rs.core.UriInfo: java.net.URI getRequestUri()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.net.URI)>(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[])>("Received callback \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = new org.apache.hive.hcatalog.templeton.CompleteDelegator;
v = <org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.CompleteDelegator: void <init>(org.apache.hive.hcatalog.templeton.AppConfig)>(v);
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.CompleteDelegator: org.apache.hive.hcatalog.templeton.CompleteBean run(java.lang.String,java.lang.String)>(v, v);
return v;
}
public void verifyUser() throws org.apache.hive.hcatalog.templeton.NotAuthorizedException
{
org.apache.hive.hcatalog.templeton.NotAuthorizedException v;
javax.servlet.http.HttpServletRequest v;
java.lang.String v, v, v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
boolean v, v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getRequestingUser()>();
if v != null goto label;
v = "No user found.";
v = staticinvoke <org.apache.hadoop.security.UserGroupInformation: boolean isSecurityEnabled()>();
if v != 0 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>("No user found.") <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[])>("\u  Missing user.name parameter.");
label:
v = new org.apache.hive.hcatalog.templeton.NotAuthorizedException;
specialinvoke v.<org.apache.hive.hcatalog.templeton.NotAuthorizedException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String doAs>;
if v == null goto label;
v = v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String doAs>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = v.<org.apache.hive.hcatalog.templeton.Server: javax.servlet.http.HttpServletRequest request>;
v = staticinvoke <org.apache.hive.hcatalog.templeton.Server: java.lang.String getRequestingHost(java.lang.String,javax.servlet.http.HttpServletRequest)>(v, v);
v = v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String doAs>;
staticinvoke <org.apache.hive.hcatalog.templeton.ProxyUserSupport: void validate(java.lang.String,java.lang.String,java.lang.String)>(v, v, v);
label:
return;
}
private java.lang.String getDoAsUser()
{
java.lang.String v, v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
boolean v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v = v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String doAs>;
if v == null goto label;
v = v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String doAs>;
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getRequestingUser()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String doAs>;
goto label;
label:
v = specialinvoke v.<org.apache.hive.hcatalog.templeton.Server: java.lang.String getRequestingUser()>();
label:
return v;
}
public void verifyParam(java.lang.String, java.lang.String) throws org.apache.hive.hcatalog.templeton.BadParam
{
java.lang.String v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
org.apache.hive.hcatalog.templeton.BadParam v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
if v != null goto label;
v = new org.apache.hive.hcatalog.templeton.BadParam;
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[])>("Missing \u parameter");
specialinvoke v.<org.apache.hive.hcatalog.templeton.BadParam: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public void verifyParam(java.util.List, java.lang.String) throws org.apache.hive.hcatalog.templeton.BadParam
{
java.util.List v;
java.lang.String v, v;
org.apache.hive.hcatalog.templeton.Server v;
boolean v;
org.apache.hive.hcatalog.templeton.BadParam v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
if v == null goto label;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
label:
v = new org.apache.hive.hcatalog.templeton.BadParam;
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[])>("Missing \u parameter");
specialinvoke v.<org.apache.hive.hcatalog.templeton.BadParam: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public void verifyDdlParam(java.lang.String, java.lang.String) throws org.apache.hive.hcatalog.templeton.BadParam
{
org.apache.hive.hcatalog.templeton.BadParam v;
java.util.regex.Matcher v;
java.lang.String v, v, v;
java.util.regex.Pattern v;
org.apache.hive.hcatalog.templeton.Server v;
boolean v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyParam(java.lang.String,java.lang.String)>(v, v);
v = <org.apache.hive.hcatalog.templeton.Server: java.util.regex.Pattern DDL_ID>;
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: boolean matches()>();
if v != 0 goto label;
v = new org.apache.hive.hcatalog.templeton.BadParam;
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 DDL identifier \u0001");
specialinvoke v.<org.apache.hive.hcatalog.templeton.BadParam: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public void verifyPropertyParam(java.lang.String, java.lang.String) throws org.apache.hive.hcatalog.templeton.BadParam
{
org.apache.hive.hcatalog.templeton.BadParam v;
java.util.regex.Matcher v;
java.lang.String v, v, v;
java.util.regex.Pattern v;
org.apache.hive.hcatalog.templeton.Server v;
boolean v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.Server: void verifyParam(java.lang.String,java.lang.String)>(v, v);
v = <org.apache.hive.hcatalog.templeton.Server: java.util.regex.Pattern PROPERTY_ID>;
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: boolean matches()>();
if v != 0 goto label;
v = new org.apache.hive.hcatalog.templeton.BadParam;
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 property name \u0001");
specialinvoke v.<org.apache.hive.hcatalog.templeton.BadParam: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
private java.lang.String getRequestingUser()
{
javax.ws.rs.core.SecurityContext v, v, v;
javax.servlet.http.HttpServletRequest v;
java.security.Principal v, v;
org.apache.hadoop.security.UserGroupInformation v;
java.lang.String v, v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v = v.<org.apache.hive.hcatalog.templeton.Server: javax.ws.rs.core.SecurityContext theSecurityContext>;
if v != null goto label;
return null;
label:
v = v.<org.apache.hive.hcatalog.templeton.Server: javax.ws.rs.core.SecurityContext theSecurityContext>;
v = interfaceinvoke v.<javax.ws.rs.core.SecurityContext: java.security.Principal getUserPrincipal()>();
if v != null goto label;
v = v.<org.apache.hive.hcatalog.templeton.Server: javax.servlet.http.HttpServletRequest request>;
v = staticinvoke <org.apache.hive.hcatalog.templeton.Main$UserNameHandler: java.lang.String getUserName(javax.servlet.http.HttpServletRequest)>(v);
goto label;
label:
v = v.<org.apache.hive.hcatalog.templeton.Server: javax.ws.rs.core.SecurityContext theSecurityContext>;
v = interfaceinvoke v.<javax.ws.rs.core.SecurityContext: java.security.Principal getUserPrincipal()>();
v = interfaceinvoke v.<java.security.Principal: java.lang.String getName()>();
label:
if v != null goto label;
return null;
label:
v = staticinvoke <org.apache.hadoop.security.UserGroupInformation: org.apache.hadoop.security.UserGroupInformation createRemoteUser(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.hadoop.security.UserGroupInformation: java.lang.String getShortUserName()>();
return v;
}
public java.lang.String getCompletedUrl()
{
java.lang.String v;
java.net.URI v, v;
javax.ws.rs.core.UriInfo v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v = v.<org.apache.hive.hcatalog.templeton.Server: javax.ws.rs.core.UriInfo theUriInfo>;
if v != null goto label;
return null;
label:
v = v.<org.apache.hive.hcatalog.templeton.Server: javax.ws.rs.core.UriInfo theUriInfo>;
v = interfaceinvoke v.<javax.ws.rs.core.UriInfo: java.net.URI getBaseUri()>();
if v != null goto label;
return null;
label:
v = v.<org.apache.hive.hcatalog.templeton.Server: javax.ws.rs.core.UriInfo theUriInfo>;
v = interfaceinvoke v.<javax.ws.rs.core.UriInfo: java.net.URI getBaseUri()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.net.URI)>(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[])>("\u0001v1/internal/complete/$jobId?status=$jobStatus");
return v;
}
private static java.lang.String getRequestingHost(java.lang.String, javax.servlet.http.HttpServletRequest)
{
java.lang.Object[] v, v, v;
java.net.InetAddress v;
javax.servlet.http.HttpServletRequest v;
java.lang.String v, v, v, v, v, v, v;
boolean v;
org.slf4j.Logger v, v, v, v, v;
java.net.UnknownHostException v;
v := @parameter: java.lang.String;
v := @parameter: javax.servlet.http.HttpServletRequest;
if v != null goto label;
v = <org.apache.hive.hcatalog.templeton.Server: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>("request is null; cannot determine hostname");
return "???";
label:
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getRemoteAddr()>();
if v != null goto label;
v = <org.apache.hive.hcatalog.templeton.Server: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.text.MessageFormat: java.lang.String format(java.lang.String,java.lang.Object[])>("Request remote address is NULL for user [{0}]", v);
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
label:
return "???";
label:
v = staticinvoke <java.net.InetAddress: java.net.InetAddress getByName(java.lang.String)>(v);
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getCanonicalHostName()>();
v = <org.apache.hive.hcatalog.templeton.Server: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.hive.hcatalog.templeton.Server: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.text.MessageFormat: java.lang.String format(java.lang.String,java.lang.Object[])>("Resolved remote hostname: [{0}]", v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
label:
return v;
label:
v := @caughtexception;
v = <org.apache.hive.hcatalog.templeton.Server: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[2];
v = virtualinvoke v.<java.net.UnknownHostException: java.lang.String toString()>();
v[0] = v;
v[1] = v;
v = staticinvoke <java.text.MessageFormat: java.lang.String format(java.lang.String,java.lang.Object[])>("Request remote address could not be resolved, {0}", v);
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
return "???";
catch java.net.UnknownHostException from label to label with label;
catch java.net.UnknownHostException from label to label with label;
}
private void checkEnableLogPrerequisite(boolean, java.lang.String) throws org.apache.hive.hcatalog.templeton.BadParam
{
org.apache.hive.hcatalog.templeton.BadParam v, v;
java.lang.String v, v, v;
org.apache.hive.hcatalog.templeton.Server v;
boolean v, v, v;
v := @this: org.apache.hive.hcatalog.templeton.Server;
v := @parameter: boolean;
v := @parameter: java.lang.String;
if v == 0 goto label;
v = staticinvoke <org.apache.hive.hcatalog.templeton.tool.TempletonUtils: boolean isset(java.lang.String)>(v);
if v != 0 goto label;
v = new org.apache.hive.hcatalog.templeton.BadParam;
specialinvoke v.<org.apache.hive.hcatalog.templeton.BadParam: void <init>(java.lang.String)>("enablelog is only applicable when statusdir is set");
throw v;
label:
if v == 0 goto label;
v = "0.23";
v = staticinvoke <org.apache.hadoop.hive.shims.ShimLoader: java.lang.String getMajorVersion()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
v = new org.apache.hive.hcatalog.templeton.BadParam;
specialinvoke v.<org.apache.hive.hcatalog.templeton.BadParam: void <init>(java.lang.String)>("enablelog=true is only supported with Hadoop 1.x");
throw v;
label:
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
org.apache.hive.hcatalog.templeton.ExecServiceImpl v;
java.util.Map v, v, v;
org.apache.hive.hcatalog.templeton.AppConfig v;
java.util.regex.Pattern v, v;
v = staticinvoke <org.apache.hive.hcatalog.templeton.Server: java.util.Map createStatusMsg()>();
<org.apache.hive.hcatalog.templeton.Server: java.util.Map STATUS_OK> = v;
v = staticinvoke <org.apache.hive.hcatalog.templeton.Server: java.util.Map createVersions()>();
<org.apache.hive.hcatalog.templeton.Server: java.util.Map SUPPORTED_VERSIONS> = v;
v = staticinvoke <org.apache.hive.hcatalog.templeton.Server: java.util.Map createFormats()>();
<org.apache.hive.hcatalog.templeton.Server: java.util.Map SUPPORTED_FORMATS> = v;
v = staticinvoke <org.apache.hive.hcatalog.templeton.ExecServiceImpl: org.apache.hive.hcatalog.templeton.ExecServiceImpl getInstance()>();
<org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.ExecService execService> = v;
v = staticinvoke <org.apache.hive.hcatalog.templeton.Main: org.apache.hive.hcatalog.templeton.AppConfig getAppConfigInstance()>();
<org.apache.hive.hcatalog.templeton.Server: org.apache.hive.hcatalog.templeton.AppConfig appConf> = v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/hive/hcatalog/templeton/Server;");
<org.apache.hive.hcatalog.templeton.Server: org.slf4j.Logger LOG> = v;
v = staticinvoke <java.util.regex.Pattern: java.util.regex.Pattern compile(java.lang.String)>("[a-zA-Z]\\w*");
<org.apache.hive.hcatalog.templeton.Server: java.util.regex.Pattern DDL_ID> = v;
v = staticinvoke <java.util.regex.Pattern: java.util.regex.Pattern compile(java.lang.String)>("[a-zA-Z0-9][\\w\\.\\-]*(?<!\\-)(?<!\\.)(?<!\\_)$");
<org.apache.hive.hcatalog.templeton.Server: java.util.regex.Pattern PROPERTY_ID> = v;
return;
}
}