public class org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage extends java.lang.Object implements org.apache.hive.hcatalog.templeton.tool.TempletonStorage
{
public static final java.lang.String TRACKINGDIR;
public java.lang.String storage_root;
public java.lang.String job_path;
public java.lang.String job_trackingpath;
public java.lang.String overhead_path;
public static final java.lang.String ZK_HOSTS;
public static final java.lang.String ZK_SESSION_TIMEOUT;
public static final java.lang.String ZK_SSL_ENABLE;
public static final java.lang.String ZK_KEYSTORE_LOCATION;
public static final java.lang.String ZK_KEYSTORE_PASSWORD;
public static final java.lang.String ZK_TRUSTSTORE_LOCATION;
public static final java.lang.String ZK_TRUSTSTORE_PASSWORD;
public static final java.lang.String ENCODING;
private static final org.slf4j.Logger LOG;
private org.apache.curator.framework.CuratorFramework zk;
public static org.apache.curator.framework.CuratorFramework zkOpen(org.apache.hadoop.conf.Configuration) throws java.io.IOException
{
org.apache.hadoop.hive.common.ZooKeeperHiveHelper v;
org.apache.hadoop.hive.common.ZooKeeperHiveHelper$ZooKeeperHiveHelperBuilder v, v, v, v, v, v, v, v, v, v;
org.apache.hadoop.conf.Configuration v;
int v, v;
org.apache.curator.framework.CuratorFrameworkFactory$Builder v;
java.lang.String v, v, v, v, v;
boolean v;
org.apache.curator.framework.CuratorFramework v;
v := @parameter: org.apache.hadoop.conf.Configuration;
v = staticinvoke <org.apache.hadoop.hive.common.ZooKeeperHiveHelper: org.apache.hadoop.hive.common.ZooKeeperHiveHelper$ZooKeeperHiveHelperBuilder builder()>();
v = virtualinvoke v.<org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String)>("templeton.zookeeper.hosts");
v = virtualinvoke v.<org.apache.hadoop.hive.common.ZooKeeperHiveHelper$ZooKeeperHiveHelperBuilder: org.apache.hadoop.hive.common.ZooKeeperHiveHelper$ZooKeeperHiveHelperBuilder quorum(java.lang.String)>(v);
v = staticinvoke <org.apache.curator.framework.CuratorFrameworkFactory: org.apache.curator.framework.CuratorFrameworkFactory$Builder builder()>();
v = virtualinvoke v.<org.apache.curator.framework.CuratorFrameworkFactory$Builder: int getSessionTimeoutMs()>();
v = virtualinvoke v.<org.apache.hadoop.conf.Configuration: int getInt(java.lang.String,int)>("templeton.zookeeper.session-timeout", v);
v = virtualinvoke v.<org.apache.hadoop.hive.common.ZooKeeperHiveHelper$ZooKeeperHiveHelperBuilder: org.apache.hadoop.hive.common.ZooKeeperHiveHelper$ZooKeeperHiveHelperBuilder sessionTimeout(int)>(v);
v = virtualinvoke v.<org.apache.hadoop.hive.common.ZooKeeperHiveHelper$ZooKeeperHiveHelperBuilder: org.apache.hadoop.hive.common.ZooKeeperHiveHelper$ZooKeeperHiveHelperBuilder baseSleepTime(int)>(1000);
v = virtualinvoke v.<org.apache.hadoop.hive.common.ZooKeeperHiveHelper$ZooKeeperHiveHelperBuilder: org.apache.hadoop.hive.common.ZooKeeperHiveHelper$ZooKeeperHiveHelperBuilder maxRetries(int)>(3);
v = virtualinvoke v.<org.apache.hadoop.conf.Configuration: boolean getBoolean(java.lang.String,boolean)>("templeton.zookeeper.ssl.client.enable", 0);
v = virtualinvoke v.<org.apache.hadoop.hive.common.ZooKeeperHiveHelper$ZooKeeperHiveHelperBuilder: org.apache.hadoop.hive.common.ZooKeeperHiveHelper$ZooKeeperHiveHelperBuilder sslEnabled(boolean)>(v);
v = virtualinvoke v.<org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String,java.lang.String)>("templeton.zookeeper.keystore.location", "");
v = virtualinvoke v.<org.apache.hadoop.hive.common.ZooKeeperHiveHelper$ZooKeeperHiveHelperBuilder: org.apache.hadoop.hive.common.ZooKeeperHiveHelper$ZooKeeperHiveHelperBuilder keyStoreLocation(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String,java.lang.String)>("templeton.zookeeper.keystore.password", "");
v = virtualinvoke v.<org.apache.hadoop.hive.common.ZooKeeperHiveHelper$ZooKeeperHiveHelperBuilder: org.apache.hadoop.hive.common.ZooKeeperHiveHelper$ZooKeeperHiveHelperBuilder keyStorePassword(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String,java.lang.String)>("templeton.zookeeper.truststore.location", "");
v = virtualinvoke v.<org.apache.hadoop.hive.common.ZooKeeperHiveHelper$ZooKeeperHiveHelperBuilder: org.apache.hadoop.hive.common.ZooKeeperHiveHelper$ZooKeeperHiveHelperBuilder trustStoreLocation(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String,java.lang.String)>("templeton.zookeeper.truststore.password", "");
v = virtualinvoke v.<org.apache.hadoop.hive.common.ZooKeeperHiveHelper$ZooKeeperHiveHelperBuilder: org.apache.hadoop.hive.common.ZooKeeperHiveHelper$ZooKeeperHiveHelperBuilder trustStorePassword(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.hadoop.hive.common.ZooKeeperHiveHelper$ZooKeeperHiveHelperBuilder: org.apache.hadoop.hive.common.ZooKeeperHiveHelper build()>();
v = virtualinvoke v.<org.apache.hadoop.hive.common.ZooKeeperHiveHelper: org.apache.curator.framework.CuratorFramework getNewZookeeperClient()>();
interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: void start()>();
return v;
}
public void <init>()
{
org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage v;
v := @this: org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String storage_root> = null;
v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String job_path> = null;
v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String job_trackingpath> = null;
v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String overhead_path> = null;
return;
}
public void close() throws java.io.IOException
{
org.apache.curator.framework.CuratorFramework v, v;
org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage v;
v := @this: org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage;
v = v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: org.apache.curator.framework.CuratorFramework zk>;
if v == null goto label;
v = v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: org.apache.curator.framework.CuratorFramework zk>;
interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: void close()>();
label:
return;
}
public void startCleanup(org.apache.hadoop.conf.Configuration)
{
org.slf4j.Logger v;
org.apache.hadoop.conf.Configuration v;
org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage v;
java.lang.Exception v;
v := @this: org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage;
v := @parameter: org.apache.hadoop.conf.Configuration;
label:
staticinvoke <org.apache.hive.hcatalog.templeton.tool.ZooKeeperCleanup: void startInstance(org.apache.hadoop.conf.Configuration)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>("Cleanup instance didn\'t start.");
label:
return;
catch java.lang.Exception from label to label with label;
}
public void create(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type, java.lang.String) throws java.io.IOException
{
org.apache.zookeeper.CreateMode v;
org.apache.hive.hcatalog.templeton.tool.NotFoundException v;
org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type v, v;
boolean v, v;
java.lang.Exception v, v, v, v;
org.apache.curator.framework.CuratorFramework v, v, v, v;
java.lang.Throwable v;
org.apache.curator.framework.api.CreateBuilder v;
long v;
java.util.ArrayList v;
org.apache.curator.framework.api.DeleteBuilder v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v;
org.apache.curator.framework.api.ExistsBuilder v;
java.io.IOException v, v, v, v, v;
org.apache.hive.hcatalog.templeton.tool.JobStateTracker v;
org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage v;
java.lang.Object v, v, v;
org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable v;
v := @this: org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage;
v := @parameter: org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type;
v := @parameter: java.lang.String;
v = 0;
label:
v = v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: org.apache.curator.framework.CuratorFramework zk>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.CreateBuilder create()>();
v = interfaceinvoke v.<org.apache.curator.framework.api.CreateBuilder: org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable creatingParentsIfNeeded()>();
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
v = interfaceinvoke v.<org.apache.curator.framework.api.ProtectACLCreateModeStatPathAndBytesable: java.lang.Object withMode(org.apache.zookeeper.CreateMode)>(v);
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = interfaceinvoke v.<org.apache.curator.framework.api.ACLBackgroundPathAndBytesable: java.lang.Object withACL(java.util.List)>(v);
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String makeZnode(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type,java.lang.String)>(v, v);
interfaceinvoke v.<org.apache.curator.framework.api.BackgroundPathAndBytesable: java.lang.Object forPath(java.lang.String)>(v);
v = 1;
label:
goto label;
label:
v := @caughtexception;
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String makeZnode(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type,java.lang.String)>(v, v);
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[])>("Error creating \u0001");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
if v == 0 goto label;
label:
v = <org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type: org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type JOB>;
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = new org.apache.hive.hcatalog.templeton.tool.JobStateTracker;
v = v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: org.apache.curator.framework.CuratorFramework zk>;
v = v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String job_trackingpath>;
specialinvoke v.<org.apache.hive.hcatalog.templeton.tool.JobStateTracker: void <init>(java.lang.String,org.apache.curator.framework.CuratorFramework,boolean,java.lang.String)>(v, v, 0, v);
virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.JobStateTracker: void create()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: org.slf4j.Logger LOG>;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Error tracking (jobId=\u): \u0001");
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>(v);
label:
v = v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: org.apache.curator.framework.CuratorFramework zk>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.DeleteBuilder delete()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String makeZnode(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type,java.lang.String)>(v, v);
interfaceinvoke v.<org.apache.curator.framework.api.DeleteBuilder: java.lang.Object forPath(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String makeZnode(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type,java.lang.String)>(v, v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.Exception)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to delete \u0001:\u0001");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: org.apache.curator.framework.CuratorFramework zk>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.ExistsBuilder checkExists()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String makeZnode(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type,java.lang.String)>(v, v);
v = interfaceinvoke v.<org.apache.curator.framework.api.ExistsBuilder: java.lang.Object forPath(java.lang.String)>(v);
if v != null goto label;
v = new java.io.IOException;
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String makeZnode(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type,java.lang.String)>(v, v);
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[])>("Unable to create \u0001");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>(v);
throw v;
label:
v := @caughtexception;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
if v == 0 goto label;
label:
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = staticinvoke <java.lang.Long: java.lang.String toString(long)>(v);
virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: void saveField(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type,java.lang.String,java.lang.String,java.lang.String)>(v, v, "created", v);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.IOException;
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[])>("Couldn\'t write to node \u0001");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch org.apache.zookeeper.KeeperException$NodeExistsException from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch org.apache.hive.hcatalog.templeton.tool.NotFoundException from label to label with label;
}
public java.lang.String getPath(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type)
{
org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type v;
int[] v;
org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage v;
int v, v;
java.lang.String v;
v := @this: org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage;
v := @parameter: org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type;
v = v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String overhead_path>;
v = <org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage$1: int[] $SwitchMap$org$apache$hive$hcatalog$templeton$tool$TempletonStorage$Type>;
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
v = v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String job_path>;
goto label;
label:
v = v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String job_trackingpath>;
label:
return v;
}
public static java.lang.String[] getPaths(java.lang.String)
{
java.lang.Object[] v;
java.lang.String[] v;
java.util.ArrayList v;
int v, v, v, v, v;
java.lang.String v, v;
v := @parameter: java.lang.String;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = virtualinvoke v.<java.lang.String: int length()>();
if v >= 2 goto label;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
goto label;
label:
v = 0;
label:
v = v + 1;
v = virtualinvoke v.<java.lang.String: int indexOf(java.lang.String,int)>("/", v);
v = v;
if v <= 0 goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
goto label;
label:
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<java.util.ArrayList: int size()>();
v = newarray (java.lang.String)[v];
v = virtualinvoke v.<java.util.ArrayList: java.lang.Object[] toArray(java.lang.Object[])>(v);
return v;
}
private void setFieldData(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type, java.lang.String, java.lang.String, java.lang.String) throws java.lang.Exception
{
java.lang.Throwable v;
org.apache.zookeeper.CreateMode v;
byte[] v, v;
org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type v;
org.apache.curator.framework.api.CreateBuilder v;
java.util.ArrayList v;
org.apache.curator.framework.api.SetDataBuilder v;
java.lang.String v, v, v, v, v;
org.apache.curator.framework.CuratorFramework v, v;
org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage v;
java.lang.Object v, v;
v := @this: org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage;
v := @parameter: org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
label:
v = v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: org.apache.curator.framework.CuratorFramework zk>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.CreateBuilder create()>();
v = <org.apache.zookeeper.CreateMode: org.apache.zookeeper.CreateMode PERSISTENT>;
v = interfaceinvoke v.<org.apache.curator.framework.api.CreateBuilder: java.lang.Object withMode(org.apache.zookeeper.CreateMode)>(v);
v = <org.apache.zookeeper.ZooDefs$Ids: java.util.ArrayList OPEN_ACL_UNSAFE>;
v = interfaceinvoke v.<org.apache.curator.framework.api.ACLBackgroundPathAndBytesable: java.lang.Object withACL(java.util.List)>(v);
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String makeFieldZnode(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type,java.lang.String,java.lang.String)>(v, v, v);
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.lang.String)>("UTF-8");
interfaceinvoke v.<org.apache.curator.framework.api.BackgroundPathAndBytesable: java.lang.Object forPath(java.lang.String,byte[])>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: org.apache.curator.framework.CuratorFramework zk>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.SetDataBuilder setData()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String makeFieldZnode(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type,java.lang.String,java.lang.String)>(v, v, v);
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.lang.String)>("UTF-8");
interfaceinvoke v.<org.apache.curator.framework.api.SetDataBuilder: java.lang.Object forPath(java.lang.String,byte[])>(v, v);
label:
return;
catch org.apache.zookeeper.KeeperException$NodeExistsException from label to label with label;
}
public java.lang.String makeFieldZnode(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type, java.lang.String, java.lang.String)
{
org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type v;
org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage v;
java.lang.String v, v, v, v;
v := @this: org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage;
v := @parameter: org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String makeZnode(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type,java.lang.String)>(v, v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/\u0001");
return v;
}
public java.lang.String makeZnode(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type, java.lang.String)
{
org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type v;
org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage v;
java.lang.String v, v, v;
v := @this: org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage;
v := @parameter: org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String getPath(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001/\u0001");
return v;
}
public void saveField(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type, java.lang.String, java.lang.String, java.lang.String) throws org.apache.hive.hcatalog.templeton.tool.NotFoundException
{
org.apache.hive.hcatalog.templeton.tool.NotFoundException v;
org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type v;
java.lang.Exception v;
org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage v;
java.lang.String v, v, v, v, v;
v := @this: org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage;
v := @parameter: org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
label:
if v == null goto label;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: void create(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type,java.lang.String)>(v, v);
specialinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: void setFieldData(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.hive.hcatalog.templeton.tool.NotFoundException;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Writing \u0001: \u, \u0001");
specialinvoke v.<org.apache.hive.hcatalog.templeton.tool.NotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
}
public java.lang.String getField(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type, java.lang.String, java.lang.String)
{
org.apache.curator.framework.api.GetDataBuilder v;
org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type v;
java.lang.Exception v;
org.apache.curator.framework.CuratorFramework v;
org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage v;
java.lang.Object v;
java.lang.String v, v, v, v;
v := @this: org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage;
v := @parameter: org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
label:
v = v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: org.apache.curator.framework.CuratorFramework zk>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.GetDataBuilder getData()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String makeFieldZnode(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type,java.lang.String,java.lang.String)>(v, v, v);
v = interfaceinvoke v.<org.apache.curator.framework.api.GetDataBuilder: java.lang.Object forPath(java.lang.String)>(v);
v = new java.lang.String;
specialinvoke v.<java.lang.String: void <init>(byte[],java.lang.String)>(v, "UTF-8");
label:
return v;
label:
v := @caughtexception;
return null;
catch java.lang.Exception from label to label with label;
}
public boolean delete(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type, java.lang.String) throws org.apache.hive.hcatalog.templeton.tool.NotFoundException
{
org.apache.curator.framework.api.GetChildrenBuilder v;
org.apache.hive.hcatalog.templeton.tool.NotFoundException v, v, v;
org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type v;
org.apache.curator.framework.api.DeleteBuilder v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
boolean v;
java.util.Iterator v;
java.lang.Exception v, v, v;
org.apache.curator.framework.CuratorFramework v, v, v;
org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage v;
java.lang.Object v, v;
v := @this: org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage;
v := @parameter: org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type;
v := @parameter: java.lang.String;
label:
v = v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: org.apache.curator.framework.CuratorFramework zk>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.GetChildrenBuilder getChildren()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String makeZnode(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type,java.lang.String)>(v, v);
v = interfaceinvoke v.<org.apache.curator.framework.api.GetChildrenBuilder: java.lang.Object forPath(java.lang.String)>(v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
label:
v = v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: org.apache.curator.framework.CuratorFramework zk>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.DeleteBuilder delete()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String makeFieldZnode(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type,java.lang.String,java.lang.String)>(v, v, v);
interfaceinvoke v.<org.apache.curator.framework.api.DeleteBuilder: java.lang.Object forPath(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.hive.hcatalog.templeton.tool.NotFoundException;
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String makeFieldZnode(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type,java.lang.String,java.lang.String)>(v, v, v);
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[])>("Couldn\'t delete \u0001");
specialinvoke v.<org.apache.hive.hcatalog.templeton.tool.NotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: org.apache.curator.framework.CuratorFramework zk>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.DeleteBuilder delete()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String makeZnode(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type,java.lang.String)>(v, v);
interfaceinvoke v.<org.apache.curator.framework.api.DeleteBuilder: java.lang.Object forPath(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.hive.hcatalog.templeton.tool.NotFoundException;
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String makeZnode(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type,java.lang.String)>(v, v);
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[])>("Couldn\'t delete \u0001");
specialinvoke v.<org.apache.hive.hcatalog.templeton.tool.NotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
v := @caughtexception;
v = new org.apache.hive.hcatalog.templeton.tool.NotFoundException;
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String makeZnode(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type,java.lang.String)>(v, v);
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[])>("Couldn\'t get children of \u0001");
specialinvoke v.<org.apache.hive.hcatalog.templeton.tool.NotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
return 1;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
public java.util.List getAllForType(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type)
{
org.apache.curator.framework.api.GetChildrenBuilder v;
org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type v;
java.lang.Exception v;
java.util.List v;
org.apache.curator.framework.CuratorFramework v;
org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage;
v := @parameter: org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type;
label:
v = v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: org.apache.curator.framework.CuratorFramework zk>;
v = interfaceinvoke v.<org.apache.curator.framework.CuratorFramework: org.apache.curator.framework.api.GetChildrenBuilder getChildren()>();
v = virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String getPath(org.apache.hive.hcatalog.templeton.tool.TempletonStorage$Type)>(v);
v = interfaceinvoke v.<org.apache.curator.framework.api.GetChildrenBuilder: java.lang.Object forPath(java.lang.String)>(v);
label:
return v;
label:
v := @caughtexception;
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
return v;
catch java.lang.Exception from label to label with label;
}
public void openStorage(org.apache.hadoop.conf.Configuration) throws java.io.IOException
{
org.apache.curator.framework.CuratorFramework v, v;
org.apache.hadoop.conf.Configuration v;
org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage v;
java.lang.String v, v, v, v, v, v, v;
v := @this: org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage;
v := @parameter: org.apache.hadoop.conf.Configuration;
v = virtualinvoke v.<org.apache.hadoop.conf.Configuration: java.lang.String get(java.lang.String)>("templeton.storage.root");
v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String storage_root> = v;
v = v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String storage_root>;
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[])>("\u0001/jobs");
v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String job_path> = v;
v = v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String storage_root>;
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[])>("\u0001/created");
v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String job_trackingpath> = v;
v = v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String storage_root>;
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[])>("\u0001/overhead");
v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: java.lang.String overhead_path> = v;
v = v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: org.apache.curator.framework.CuratorFramework zk>;
if v != null goto label;
v = staticinvoke <org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: org.apache.curator.framework.CuratorFramework zkOpen(org.apache.hadoop.conf.Configuration)>(v);
v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: org.apache.curator.framework.CuratorFramework zk> = v;
label:
return;
}
public void closeStorage() throws java.io.IOException
{
org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage v;
v := @this: org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage;
virtualinvoke v.<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: void close()>();
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/hive/hcatalog/templeton/tool/ZooKeeperStorage;");
<org.apache.hive.hcatalog.templeton.tool.ZooKeeperStorage: org.slf4j.Logger LOG> = v;
return;
}
}