class org.apache.hadoop.hive.metastore.ReplChangeManager$3 extends org.apache.hadoop.hive.metastore.utils.Retry
{
final org.apache.hadoop.fs.Path val$cmroot;
void <init>(java.lang.Class, org.apache.hadoop.fs.Path)
{
org.apache.hadoop.fs.Path v;
java.lang.Class v;
org.apache.hadoop.hive.metastore.ReplChangeManager$3 v;
v := @this: org.apache.hadoop.hive.metastore.ReplChangeManager$3;
v := @parameter: java.lang.Class;
v := @parameter: org.apache.hadoop.fs.Path;
v.<org.apache.hadoop.hive.metastore.ReplChangeManager$3: org.apache.hadoop.fs.Path val$cmroot> = v;
specialinvoke v.<org.apache.hadoop.hive.metastore.utils.Retry: void <init>(java.lang.Class)>(v);
return;
}
public java.lang.Void execute() throws java.io.IOException
{
org.apache.hadoop.fs.FileSystem v;
org.apache.hadoop.hive.metastore.ReplChangeManager$3 v;
org.apache.hadoop.conf.Configuration v;
org.apache.hadoop.fs.Path v, v, v, v;
boolean v;
v := @this: org.apache.hadoop.hive.metastore.ReplChangeManager$3;
v = v.<org.apache.hadoop.hive.metastore.ReplChangeManager$3: org.apache.hadoop.fs.Path val$cmroot>;
v = <org.apache.hadoop.hive.metastore.ReplChangeManager: org.apache.hadoop.conf.Configuration conf>;
v = virtualinvoke v.<org.apache.hadoop.fs.Path: org.apache.hadoop.fs.FileSystem getFileSystem(org.apache.hadoop.conf.Configuration)>(v);
v = v.<org.apache.hadoop.hive.metastore.ReplChangeManager$3: org.apache.hadoop.fs.Path val$cmroot>;
v = virtualinvoke v.<org.apache.hadoop.fs.FileSystem: boolean exists(org.apache.hadoop.fs.Path)>(v);
if v != 0 goto label;
v = v.<org.apache.hadoop.hive.metastore.ReplChangeManager$3: org.apache.hadoop.fs.Path val$cmroot>;
virtualinvoke v.<org.apache.hadoop.fs.FileSystem: boolean mkdirs(org.apache.hadoop.fs.Path)>(v);
v = v.<org.apache.hadoop.hive.metastore.ReplChangeManager$3: org.apache.hadoop.fs.Path val$cmroot>;
staticinvoke <org.apache.hadoop.hive.metastore.ReplChangeManager: void setCmRootPermissions(org.apache.hadoop.fs.Path)>(v);
label:
return null;
}
}