public class org.apache.hadoop.hive.metastore.Warehouse extends java.lang.Object { public static final java.lang.String DEFAULT_CATALOG_NAME; public static final java.lang.String DEFAULT_CATALOG_COMMENT; public static final java.lang.String DEFAULT_DATABASE_NAME; public static final java.lang.String DEFAULT_DATABASE_COMMENT; public static final java.lang.String DEFAULT_SERIALIZATION_FORMAT; public static final java.lang.String DATABASE_WAREHOUSE_SUFFIX; private static final java.lang.String CAT_DB_TABLE_SEPARATOR; private org.apache.hadoop.fs.Path whRoot; private org.apache.hadoop.fs.Path whRootExternal; private final org.apache.hadoop.conf.Configuration conf; private final java.lang.String whRootString; private final java.lang.String whRootExternalString; private final boolean isTenantBasedStorage; public static final org.slf4j.Logger LOG; private org.apache.hadoop.hive.metastore.MetaStoreFS fsHandler; private boolean storageAuthCheck; private org.apache.hadoop.hive.metastore.ReplChangeManager cm; static final java.util.regex.Pattern pat; private static final java.util.regex.Pattern slash; static final boolean $assertionsDisabled; public void (org.apache.hadoop.conf.Configuration) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.hive.metastore.api.MetaException v; org.apache.hadoop.hive.metastore.Warehouse v; org.apache.hadoop.conf.Configuration v; org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars v, v, v, v, v; java.lang.String v, v, v, v, v; org.apache.hadoop.hive.metastore.MetaStoreFS v; boolean v, v, v; org.apache.hadoop.hive.metastore.ReplChangeManager v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.conf.Configuration; specialinvoke v.()>(); v. = null; v. = 0; v. = null; v. = v; v = ; v = staticinvoke (v, v); v. = v; v = v.; v = staticinvoke (v); if v == 0 goto label; v = new org.apache.hadoop.hive.metastore.api.MetaException; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u is not set in the config or blank"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = ; v = staticinvoke (v, v); v. = v; v = specialinvoke v.(v); v. = v; v = staticinvoke (v); v. = v; v = ; v = staticinvoke (v, v); v. = v; v = ; v = staticinvoke (v, v); v. = v; return; } private org.apache.hadoop.hive.metastore.MetaStoreFS getMetaStoreFsHandler(org.apache.hadoop.conf.Configuration) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.hive.metastore.api.MetaException v; org.apache.hadoop.hive.metastore.Warehouse v; org.apache.hadoop.conf.Configuration v; org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars v; java.lang.Class v; java.lang.ClassNotFoundException v; java.lang.Object v; java.lang.ClassLoader v; java.lang.String v, v, v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.conf.Configuration; v = ; v = staticinvoke (v, v); label: v = staticinvoke (); v = staticinvoke (v, 1, v); v = staticinvoke (v, v); label: return v; label: v := @caughtexception; v = new org.apache.hadoop.hive.metastore.api.MetaException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Error in loading MetaStoreFS handler.\u0001"); specialinvoke v.(java.lang.String)>(v); throw v; catch java.lang.ClassNotFoundException from label to label with label; } public static org.apache.hadoop.fs.FileSystem getFs(org.apache.hadoop.fs.Path, org.apache.hadoop.conf.Configuration) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.fs.FileSystem v; org.apache.hadoop.conf.Configuration v; org.apache.hadoop.fs.Path v; java.io.IOException v; v := @parameter: org.apache.hadoop.fs.Path; v := @parameter: org.apache.hadoop.conf.Configuration; label: v = virtualinvoke v.(v); label: return v; label: v := @caughtexception; staticinvoke (v); return null; catch java.io.IOException from label to label with label; } public org.apache.hadoop.fs.FileSystem getFs(org.apache.hadoop.fs.Path) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.fs.FileSystem v; org.apache.hadoop.conf.Configuration v; org.apache.hadoop.fs.Path v; org.apache.hadoop.hive.metastore.Warehouse v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.fs.Path; v = v.; v = staticinvoke (v, v); return v; } public static org.apache.hadoop.fs.Path getDnsPath(org.apache.hadoop.fs.Path, org.apache.hadoop.conf.Configuration) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.fs.FileSystem v; org.apache.hadoop.conf.Configuration v; org.apache.hadoop.fs.Path v, v, v; java.lang.String v, v, v, v, v, v, v, v; java.net.URI v, v, v, v, v, v, v, v; boolean v, v, v, v; v := @parameter: org.apache.hadoop.fs.Path; v := @parameter: org.apache.hadoop.conf.Configuration; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); if v != null goto label; if v == null goto label; label: v = virtualinvoke v.(); v = staticinvoke (v, v); if v == 0 goto label; label: if v != null goto label; v = virtualinvoke v.(); label: if v != null goto label; v = virtualinvoke v.(); label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = "/"; label: v = new org.apache.hadoop.fs.Path; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>(v, v, v); return v; label: return v; label: v = staticinvoke (v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = "/"; label: v = new org.apache.hadoop.fs.Path; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>(v, v, v); return v; } private static boolean isBlobStorageScheme(org.apache.hadoop.conf.Configuration, java.lang.String) { java.util.function.Predicate v; java.util.Collection v; java.util.stream.Stream v; org.apache.hadoop.conf.Configuration v; org.apache.hadoop.hive.metastore.conf.MetastoreConf$ConfVars v; java.lang.String v, v; java.net.URI v; boolean v; v := @parameter: org.apache.hadoop.conf.Configuration; v := @parameter: java.lang.String; if v != null goto label; v = staticinvoke (v); v = virtualinvoke v.(); goto label; label: v = v; label: v = ; v = staticinvoke (v, v); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); return v; } public org.apache.hadoop.fs.Path getDnsPath(org.apache.hadoop.fs.Path) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.conf.Configuration v; org.apache.hadoop.fs.Path v, v; org.apache.hadoop.hive.metastore.Warehouse v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.fs.Path; v = v.; v = staticinvoke (v, v); return v; } public org.apache.hadoop.fs.Path getWhRoot() throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.fs.Path v, v, v, v, v; java.lang.String v; org.apache.hadoop.hive.metastore.Warehouse v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v = v.; if v == null goto label; v = v.; return v; label: v = new org.apache.hadoop.fs.Path; v = v.; specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(v); v. = v; v = v.; return v; } public org.apache.hadoop.fs.Path getWhRootExternal() throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.hive.metastore.Warehouse v; org.apache.hadoop.fs.Path v, v, v, v, v, v; java.lang.String v; boolean v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v = v.; if v == null goto label; v = v.; return v; label: v = specialinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); v. = v; goto label; label: v = new org.apache.hadoop.fs.Path; v = v.; specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(v); v. = v; label: v = v.; return v; } public org.apache.hadoop.fs.Path determineDatabasePath(org.apache.hadoop.hive.metastore.api.Catalog, org.apache.hadoop.hive.metastore.api.Database) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.hive.metastore.Warehouse v; org.apache.hadoop.hive.metastore.api.Catalog v; org.apache.hadoop.hive.metastore.api.DatabaseType v, v; org.apache.hadoop.fs.Path v, v, v, v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v; boolean v, v, v; org.apache.hadoop.hive.metastore.api.Database v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.hive.metastore.api.Catalog; v := @parameter: org.apache.hadoop.hive.metastore.api.Database; v = virtualinvoke v.(); v = ; if v != v goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v, 1); return v; label: v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.hadoop.fs.Path; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(v); return v; label: if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.("hive"); if v == 0 goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.("default"); if v == 0 goto label; v = virtualinvoke v.(); return v; label: v = new org.apache.hadoop.fs.Path; v = virtualinvoke v.(); v = specialinvoke v.(v); specialinvoke v.(org.apache.hadoop.fs.Path,java.lang.String)>(v, v); return v; label: v = new org.apache.hadoop.fs.Path; v = new org.apache.hadoop.fs.Path; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(v); v = specialinvoke v.(v); specialinvoke v.(org.apache.hadoop.fs.Path,java.lang.String)>(v, v); return v; } private java.lang.String dbDirFromDbName(org.apache.hadoop.hive.metastore.api.Database) throws org.apache.hadoop.hive.metastore.api.MetaException { java.lang.String v, v, v; org.apache.hadoop.hive.metastore.api.Database v; org.apache.hadoop.hive.metastore.Warehouse v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.hive.metastore.api.Database; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u.db"); return v; } public org.apache.hadoop.fs.Path getDatabasePath(org.apache.hadoop.hive.metastore.api.Database) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.hive.metastore.Warehouse v; org.apache.hadoop.fs.Path v, v, v, v; java.lang.String v, v, v, v, v; org.apache.hadoop.hive.metastore.api.Database v; boolean v, v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.hive.metastore.api.Database; v = virtualinvoke v.(); if v == null goto label; v = new org.apache.hadoop.fs.Path; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(v); return v; label: v = virtualinvoke v.(); v = virtualinvoke v.("hive"); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.("default"); if v == 0 goto label; v = virtualinvoke v.(); return v; label: v = new org.apache.hadoop.fs.Path; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); return v; } public org.apache.hadoop.fs.Path getDatabaseExternalPath(org.apache.hadoop.hive.metastore.api.Database) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.hive.metastore.Warehouse v; org.apache.hadoop.fs.Path v, v, v, v; java.lang.String v, v, v, v, v; org.apache.hadoop.hive.metastore.api.Database v; boolean v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.hive.metastore.api.Database; v = new org.apache.hadoop.fs.Path; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); v = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001/"); v = staticinvoke (v, v); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); label: v = virtualinvoke v.(v); return v; } public org.apache.hadoop.fs.Path getDatabaseManagedPath(org.apache.hadoop.hive.metastore.api.Database) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.hive.metastore.Warehouse v; org.apache.hadoop.fs.Path v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v; boolean v, v; org.apache.hadoop.hive.metastore.api.Database v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.hive.metastore.api.Database; v = virtualinvoke v.(); if v == null goto label; v = new org.apache.hadoop.fs.Path; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(v); return v; label: v = virtualinvoke v.(); v = virtualinvoke v.("hive"); if v != 0 goto label; v = new org.apache.hadoop.fs.Path; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); return v; label: v = virtualinvoke v.(); v = virtualinvoke v.("default"); if v == 0 goto label; v = virtualinvoke v.(); return v; label: v = new org.apache.hadoop.fs.Path; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u.db"); specialinvoke v.(org.apache.hadoop.fs.Path,java.lang.String)>(v, v); return v; } public org.apache.hadoop.fs.Path getDefaultDatabasePath(java.lang.String) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.fs.Path v; java.lang.String v; org.apache.hadoop.hive.metastore.Warehouse v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: java.lang.String; v = virtualinvoke v.(v, 0); return v; } public org.apache.hadoop.fs.Path getDefaultExternalDatabasePath(java.lang.String) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.fs.Path v; java.lang.String v; org.apache.hadoop.hive.metastore.Warehouse v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: java.lang.String; v = virtualinvoke v.(v, 1); return v; } public org.apache.hadoop.fs.Path getDefaultDatabasePath(java.lang.String, boolean) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.hive.metastore.Warehouse v; org.apache.hadoop.fs.Path v, v, v, v, v, v; java.lang.String v, v, v, v, v; boolean v, v, v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: java.lang.String; v := @parameter: boolean; if v == 0 goto label; v = virtualinvoke v.("default"); if v == 0 goto label; v = virtualinvoke v.(); return v; label: v = new org.apache.hadoop.fs.Path; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u.db"); specialinvoke v.(org.apache.hadoop.fs.Path,java.lang.String)>(v, v); return v; label: v = virtualinvoke v.("default"); if v == 0 goto label; v = virtualinvoke v.(); return v; label: v = new org.apache.hadoop.fs.Path; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u.db"); specialinvoke v.(org.apache.hadoop.fs.Path,java.lang.String)>(v, v); return v; } private boolean hasExternalWarehouseRoot() { java.lang.String v; boolean v, v; org.apache.hadoop.hive.metastore.Warehouse v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v = v.; v = staticinvoke (v); if v != 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public org.apache.hadoop.fs.Path getDefaultTablePath(org.apache.hadoop.hive.metastore.api.Database, java.lang.String) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.fs.Path v; java.lang.String v; org.apache.hadoop.hive.metastore.api.Database v; org.apache.hadoop.hive.metastore.Warehouse v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.hive.metastore.api.Database; v := @parameter: java.lang.String; v = virtualinvoke v.(v, v, 1); return v; } public org.apache.hadoop.fs.Path getDefaultTablePath(org.apache.hadoop.hive.metastore.api.Database, java.lang.String, boolean) throws org.apache.hadoop.hive.metastore.api.MetaException { java.lang.String[] v; org.apache.hadoop.hive.metastore.Warehouse v; java.lang.CharSequence[] v; org.apache.hadoop.fs.Path v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; boolean v, v, v, v; org.apache.hadoop.hive.metastore.api.Database v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.hive.metastore.api.Database; v := @parameter: java.lang.String; v := @parameter: boolean; if v == 0 goto label; v = new org.apache.hadoop.fs.Path; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); v = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v); if v != 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(v); label: if v != 0 goto label; v = virtualinvoke v.("(.*)\\.v\\d+"); if v == 0 goto label; v = virtualinvoke v.("\\.v"); v = newarray (java.lang.CharSequence)[2]; v = v[0]; v = virtualinvoke v.(); v = staticinvoke (v); v[0] = v; v = v[1]; v[1] = v; v = staticinvoke (".v", v); goto label; label: v = virtualinvoke v.(); v = staticinvoke (v); label: v = new org.apache.hadoop.fs.Path; specialinvoke v.(org.apache.hadoop.fs.Path,java.lang.String)>(v, v); v = virtualinvoke v.(v); return v; } public org.apache.hadoop.fs.Path getDefaultManagedTablePath(org.apache.hadoop.hive.metastore.api.Database, java.lang.String) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.hive.metastore.Warehouse v; org.apache.hadoop.fs.Path v, v, v; java.lang.String v, v, v; org.apache.hadoop.hive.metastore.api.Database v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.hive.metastore.api.Database; v := @parameter: java.lang.String; v = virtualinvoke v.(v); v = new org.apache.hadoop.fs.Path; v = virtualinvoke v.(); v = staticinvoke (v); specialinvoke v.(org.apache.hadoop.fs.Path,java.lang.String)>(v, v); v = virtualinvoke v.(v); return v; } public org.apache.hadoop.fs.Path getDefaultTablePath(java.lang.String, java.lang.String, boolean) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.hive.metastore.Warehouse v; org.apache.hadoop.fs.Path v, v, v; java.lang.String v, v, v, v; boolean v, v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: boolean; if v == 0 goto label; v = specialinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(v); label: v = new org.apache.hadoop.fs.Path; v = virtualinvoke v.(); v = staticinvoke (v); specialinvoke v.(org.apache.hadoop.fs.Path,java.lang.String)>(v, v); v = virtualinvoke v.(v); return v; } public org.apache.hadoop.fs.Path getDefaultTablePath(org.apache.hadoop.hive.metastore.api.Database, org.apache.hadoop.hive.metastore.api.Table) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.fs.Path v; java.lang.String v; org.apache.hadoop.hive.metastore.api.Database v; org.apache.hadoop.hive.metastore.api.Table v; boolean v; org.apache.hadoop.hive.metastore.Warehouse v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.hive.metastore.api.Database; v := @parameter: org.apache.hadoop.hive.metastore.api.Table; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v, v, v); return v; } public static java.lang.String getQualifiedName(org.apache.hadoop.hive.metastore.api.Table) { java.lang.String v, v, v; org.apache.hadoop.hive.metastore.api.Table v; v := @parameter: org.apache.hadoop.hive.metastore.api.Table; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v); return v; } public static java.lang.String getQualifiedName(java.lang.String, java.lang.String) { java.lang.String v, v, v; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = staticinvoke (v, v); return v; } public static java.lang.String getQualifiedName(org.apache.hadoop.hive.metastore.api.Partition) { java.util.List v; java.lang.String v, v, v; org.apache.hadoop.hive.metastore.api.Partition v; v := @parameter: org.apache.hadoop.hive.metastore.api.Partition; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("\u.\u0001\u0001"); return v; } public static java.lang.String getCatalogQualifiedTableName(org.apache.hadoop.hive.metastore.api.Table) { java.lang.String v, v, v, v; org.apache.hadoop.hive.metastore.api.Table v; v := @parameter: org.apache.hadoop.hive.metastore.api.Table; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v, v); return v; } public boolean mkdirs(org.apache.hadoop.fs.Path) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.fs.FileSystem v; org.apache.hadoop.fs.Path v; java.io.IOException v; boolean v; org.apache.hadoop.hive.metastore.Warehouse v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.fs.Path; label: v = virtualinvoke v.(v); v = staticinvoke (v, v); label: return v; label: v := @caughtexception; staticinvoke (v); return 0; catch java.io.IOException from label to label with label; } public boolean renameDir(org.apache.hadoop.fs.Path, org.apache.hadoop.fs.Path, boolean) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.hive.metastore.ReplChangeManager v; org.apache.hadoop.fs.FileSystem v, v; java.lang.Exception v; org.apache.hadoop.hive.metastore.ReplChangeManager$RecycleType v; org.apache.hadoop.hive.metastore.Warehouse v; org.apache.hadoop.fs.Path v, v; boolean v, v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.fs.Path; v := @parameter: org.apache.hadoop.fs.Path; v := @parameter: boolean; label: if v == 0 goto label; v = v.; v = ; virtualinvoke v.(v, v, 1); label: v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = staticinvoke (v, v, v, v); label: return v; label: v := @caughtexception; staticinvoke (v); return 0; catch java.lang.Exception from label to label with label; } public boolean copyDir(org.apache.hadoop.fs.Path, org.apache.hadoop.fs.Path, boolean) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.hive.metastore.ReplChangeManager v; org.apache.hadoop.fs.FileSystem v, v; java.lang.Exception v; org.apache.hadoop.hive.metastore.ReplChangeManager$RecycleType v; org.apache.hadoop.hive.metastore.Warehouse v; org.apache.hadoop.conf.Configuration v; org.apache.hadoop.fs.Path v, v; boolean v, v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.fs.Path; v := @parameter: org.apache.hadoop.fs.Path; v := @parameter: boolean; label: if v == 0 goto label; v = v.; v = ; virtualinvoke v.(v, v, 1); label: v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = v.; v = staticinvoke (v, v, v, v, 0, 0, v); label: return v; label: v := @caughtexception; staticinvoke (v); return 0; catch java.lang.Exception from label to label with label; } void addToChangeManagement(org.apache.hadoop.fs.Path) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.hive.metastore.ReplChangeManager v; org.apache.hadoop.hive.metastore.api.MetaException v; org.apache.hadoop.fs.Path v; java.io.IOException v; java.lang.String v; org.apache.hadoop.hive.metastore.ReplChangeManager$RecycleType v; org.apache.hadoop.hive.metastore.Warehouse v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.fs.Path; label: v = v.; v = ; virtualinvoke v.(v, v, 1); label: goto label; label: v := @caughtexception; v = new org.apache.hadoop.hive.metastore.api.MetaException; v = staticinvoke (v); specialinvoke v.(java.lang.String)>(v); throw v; label: return; catch java.io.IOException from label to label with label; } public boolean deleteDir(org.apache.hadoop.fs.Path, boolean, org.apache.hadoop.hive.metastore.api.Database) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.fs.Path v; org.apache.hadoop.hive.metastore.api.Database v; boolean v, v; org.apache.hadoop.hive.metastore.Warehouse v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.fs.Path; v := @parameter: boolean; v := @parameter: org.apache.hadoop.hive.metastore.api.Database; v = virtualinvoke v.(v, v, 0, v); return v; } public boolean deleteDir(org.apache.hadoop.fs.Path, boolean, boolean, org.apache.hadoop.hive.metastore.api.Database) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.fs.Path v; org.apache.hadoop.hive.metastore.api.Database v; boolean v, v, v, v; org.apache.hadoop.hive.metastore.Warehouse v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.fs.Path; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: org.apache.hadoop.hive.metastore.api.Database; v = staticinvoke (v); v = virtualinvoke v.(v, v, v, v); return v; } public boolean deleteDir(org.apache.hadoop.fs.Path, boolean, boolean, boolean) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.hive.metastore.ReplChangeManager v; org.apache.hadoop.hive.metastore.api.MetaException v; org.apache.hadoop.fs.FileSystem v; java.io.IOException v; org.apache.hadoop.hive.metastore.ReplChangeManager$RecycleType v; org.apache.hadoop.hive.metastore.Warehouse v; org.apache.hadoop.conf.Configuration v; org.apache.hadoop.fs.Path v; java.lang.String v; org.apache.hadoop.hive.metastore.MetaStoreFS v; boolean v, v, v, v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.fs.Path; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: boolean; if v == 0 goto label; label: v = v.; v = ; virtualinvoke v.(v, v, v); label: goto label; label: v := @caughtexception; v = new org.apache.hadoop.hive.metastore.api.MetaException; v = staticinvoke (v); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(v); v = v.; v = v.; v = interfaceinvoke v.(v, v, v, v, v); return v; catch java.io.IOException from label to label with label; } public void recycleDirToCmPath(org.apache.hadoop.fs.Path, boolean) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.hive.metastore.ReplChangeManager v; org.apache.hadoop.hive.metastore.api.MetaException v; java.io.IOException v; org.apache.hadoop.hive.metastore.ReplChangeManager$RecycleType v; org.apache.hadoop.hive.metastore.Warehouse v; org.apache.hadoop.fs.Path v; java.lang.String v; boolean v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.fs.Path; v := @parameter: boolean; label: v = v.; v = ; virtualinvoke v.(v, v, v); label: goto label; label: v := @caughtexception; v = new org.apache.hadoop.hive.metastore.api.MetaException; v = staticinvoke (v); specialinvoke v.(java.lang.String)>(v); throw v; label: return; catch java.io.IOException from label to label with label; } public boolean isEmptyDir(org.apache.hadoop.fs.Path) throws java.io.IOException, org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.fs.FileStatus[] v; org.apache.hadoop.fs.FileSystem v; int v; org.apache.hadoop.fs.Path v; java.io.FileNotFoundException v; org.apache.hadoop.hive.metastore.Warehouse v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.fs.Path; label: v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = lengthof v; if v != 0 goto label; label: return 1; label: v := @caughtexception; return 0; label: return 0; catch java.io.FileNotFoundException from label to label with label; } public boolean isWritable(org.apache.hadoop.fs.Path) throws java.io.IOException { org.slf4j.Logger v, v; org.apache.hadoop.fs.FileSystem v; org.apache.hadoop.fs.FileStatus v; java.io.FileNotFoundException v; java.lang.Exception v; org.apache.hadoop.fs.permission.FsAction v; org.apache.hadoop.hive.metastore.Warehouse v; org.apache.hadoop.fs.Path v; java.lang.String v; boolean v, v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.fs.Path; v = v.; if v != 0 goto label; return 1; label: if v != null goto label; return 0; label: v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = ; staticinvoke (v, v, v); label: return 1; label: v := @caughtexception; return 1; label: v := @caughtexception; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Exception when checking if path (\u)"); interfaceinvoke v.(v, v); label: return 0; catch java.io.FileNotFoundException from label to label with label; catch java.lang.Exception from label to label with label; } public static java.lang.String escapePathName(java.lang.String) { java.lang.String v, v; v := @parameter: java.lang.String; v = staticinvoke (v); return v; } private static java.lang.String unescapePathName(java.lang.String) { java.lang.String v, v; v := @parameter: java.lang.String; v = staticinvoke (v); return v; } public static java.lang.String makePartPath(java.util.Map) throws org.apache.hadoop.hive.metastore.api.MetaException { java.lang.String v; java.util.Map v; v := @parameter: java.util.Map; v = staticinvoke (v, 1); return v; } public static java.lang.String makePartNameUtil(java.util.Map, boolean, boolean) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.hive.metastore.api.MetaException v; java.util.Map v; int v, v; java.lang.String v, v, v, v; boolean v, v, v; java.util.Iterator v; java.util.Set v; java.lang.Object v, v, v, v, v; java.lang.StringBuilder v; v := @parameter: java.util.Map; v := @parameter: boolean; v := @parameter: boolean; v = new java.lang.StringBuilder; specialinvoke v.()>(); v = 0; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v == null goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; label: if v != 0 goto label; v = new org.apache.hadoop.hive.metastore.api.MetaException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Partition spec is incorrect. \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v <= 0 goto label; virtualinvoke v.("/"); label: v = interfaceinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v); virtualinvoke v.(61); v = interfaceinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v); v = v + 1; goto label; label: if v == 0 goto label; if v <= 0 goto label; virtualinvoke v.("/"); label: v = virtualinvoke v.(); return v; } public static java.lang.String makePartName(java.util.Map, boolean) throws org.apache.hadoop.hive.metastore.api.MetaException { java.lang.String v; boolean v; java.util.Map v; v := @parameter: java.util.Map; v := @parameter: boolean; v = staticinvoke (v, v, 0); return v; } public static java.lang.String makeDynamicPartName(java.util.Map) { java.lang.String v; java.util.Map v; v := @parameter: java.util.Map; v = staticinvoke (v, 1, 1); return v; } public static java.lang.String makeDynamicPartNameNoTrailingSeperator(java.util.Map) { java.lang.String v; java.util.Map v; v := @parameter: java.util.Map; v = staticinvoke (v, 0, 1); return v; } public static java.util.AbstractList makeValsFromName(java.lang.String, java.util.AbstractList) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.hive.metastore.api.MetaException v, v; java.util.AbstractList v; java.lang.String[] v; java.lang.AssertionError v; java.util.ArrayList v; int v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v; boolean v; java.util.regex.Pattern v; v := @parameter: java.lang.String; v := @parameter: java.util.AbstractList; v = ; if v != 0 goto label; if v != null goto label; v = new java.lang.AssertionError; specialinvoke v.()>(); throw v; label: v = ; v = virtualinvoke v.(v, 0); if v != null goto label; v = new java.util.ArrayList; v = lengthof v; specialinvoke v.(int)>(v); v = v; v = 0; label: v = lengthof v; if v >= v goto label; virtualinvoke v.(null); v = v + 1; goto label; label: v = lengthof v; v = virtualinvoke v.(); if v == v goto label; v = new org.apache.hadoop.hive.metastore.api.MetaException; v = virtualinvoke v.(); v = lengthof v; v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("Expected \u components, got \u (\u)"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = 0; label: v = lengthof v; if v >= v goto label; v = v[v]; v = virtualinvoke v.(61); if v > 0 goto label; v = new org.apache.hadoop.hive.metastore.api.MetaException; v = v[v]; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unexpected component \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v[v]; v = v + 1; v = virtualinvoke v.(v); v = staticinvoke (v); virtualinvoke v.(v, v); v = v + 1; goto label; label: return v; } public static java.util.LinkedHashMap makeSpecFromName(java.lang.String) throws org.apache.hadoop.hive.metastore.api.MetaException { java.util.LinkedHashMap v; org.apache.hadoop.hive.metastore.api.MetaException v; org.apache.hadoop.fs.Path v; java.lang.String v, v; boolean v; v := @parameter: java.lang.String; if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; label: v = new org.apache.hadoop.hive.metastore.api.MetaException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Partition name is invalid. \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new java.util.LinkedHashMap; specialinvoke v.()>(); v = new org.apache.hadoop.fs.Path; specialinvoke v.(java.lang.String)>(v); staticinvoke (v, v, null); return v; } public static boolean makeSpecFromName(java.util.Map, org.apache.hadoop.fs.Path, java.util.Set) { java.lang.String[] v; java.util.ArrayList v; java.util.regex.Matcher v; java.util.Map v; int v, v, v; org.apache.hadoop.fs.Path v; java.lang.String v, v, v, v, v, v, v, v, v; boolean v, v, v; org.slf4j.Logger v; java.util.Set v; java.lang.Object v, v; java.util.regex.Pattern v; v := @parameter: java.util.Map; v := @parameter: org.apache.hadoop.fs.Path; v := @parameter: java.util.Set; v = new java.util.ArrayList; specialinvoke v.()>(); label: v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(1); v = staticinvoke (v); v = virtualinvoke v.(2); v = staticinvoke (v); v = newarray (java.lang.String)[2]; v[0] = v; v[1] = v; interfaceinvoke v.(v); label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; label: v = interfaceinvoke v.(); label: if v <= 0 goto label; v = v - 1; v = interfaceinvoke v.(v); v = v[0]; if v == null goto label; interfaceinvoke v.(v); label: v = v - 1; v = interfaceinvoke v.(v); v = v[1]; interfaceinvoke v.(v, v); v = v - 1; goto label; label: if v == null goto label; v = interfaceinvoke v.(); if v == 0 goto label; label: return 1; label: v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Cannot create partition spec from \u; missing keys \u0001"); interfaceinvoke v.(v); return 0; } public static java.util.Map makeEscSpecFromName(java.lang.String) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.hive.metastore.api.MetaException v; java.lang.String[] v; java.util.ArrayList v; java.util.LinkedHashMap v; java.util.regex.Matcher v; int v, v, v; org.apache.hadoop.fs.Path v, v; java.lang.String v, v, v, v, v, v, v, v; boolean v, v, v; java.lang.Object v, v; java.util.regex.Pattern v; v := @parameter: java.lang.String; if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; label: v = new org.apache.hadoop.hive.metastore.api.MetaException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Partition name is invalid. \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new java.util.LinkedHashMap; specialinvoke v.()>(); v = new org.apache.hadoop.fs.Path; specialinvoke v.(java.lang.String)>(v); v = v; v = new java.util.ArrayList; specialinvoke v.()>(); label: v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(1); v = virtualinvoke v.(2); v = newarray (java.lang.String)[2]; v[0] = v; v[1] = v; interfaceinvoke v.(v); label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; label: v = interfaceinvoke v.(); label: if v <= 0 goto label; v = v - 1; v = interfaceinvoke v.(v); v = v[0]; v = v - 1; v = interfaceinvoke v.(v); v = v[1]; virtualinvoke v.(v, v); v = v - 1; goto label; label: return v; } public org.apache.hadoop.fs.Path getDefaultPartitionPath(org.apache.hadoop.hive.metastore.api.Database, org.apache.hadoop.hive.metastore.api.Table, java.util.Map) throws org.apache.hadoop.hive.metastore.api.MetaException { java.util.Map v; org.apache.hadoop.fs.Path v, v; org.apache.hadoop.hive.metastore.api.Database v; org.apache.hadoop.hive.metastore.api.Table v; org.apache.hadoop.hive.metastore.Warehouse v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.hive.metastore.api.Database; v := @parameter: org.apache.hadoop.hive.metastore.api.Table; v := @parameter: java.util.Map; v = virtualinvoke v.(v, v); v = virtualinvoke v.(v, v); return v; } public org.apache.hadoop.fs.Path getPartitionPath(org.apache.hadoop.fs.Path, java.util.Map) throws org.apache.hadoop.hive.metastore.api.MetaException { java.util.Map v; org.apache.hadoop.fs.Path v, v; java.lang.String v; org.apache.hadoop.hive.metastore.Warehouse v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.fs.Path; v := @parameter: java.util.Map; v = new org.apache.hadoop.fs.Path; v = staticinvoke (v); specialinvoke v.(org.apache.hadoop.fs.Path,java.lang.String)>(v, v); return v; } public org.apache.hadoop.fs.Path getPartitionPath(org.apache.hadoop.hive.metastore.api.Database, org.apache.hadoop.hive.metastore.api.Table, java.util.List) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.hive.metastore.api.MetaException v; org.apache.hadoop.hive.metastore.Warehouse v; java.util.LinkedHashMap v; int v, v, v, v; org.apache.hadoop.fs.Path v, v, v, v; java.lang.String v, v, v, v, v; org.apache.hadoop.hive.metastore.api.StorageDescriptor v, v; boolean v; java.util.Iterator v; org.apache.hadoop.hive.metastore.api.Table v; java.util.List v, v; java.lang.Object v, v; org.apache.hadoop.hive.metastore.api.Database v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.hive.metastore.api.Database; v := @parameter: org.apache.hadoop.hive.metastore.api.Table; v := @parameter: java.util.List; v = virtualinvoke v.(); if v == null goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v == v goto label; label: v = new org.apache.hadoop.hive.metastore.api.MetaException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Invalid number of partition keys found for \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new java.util.LinkedHashMap; v = interfaceinvoke v.(); specialinvoke v.(int)>(v); v = 0; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); interfaceinvoke v.(v, v); v = v + 1; goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = new org.apache.hadoop.fs.Path; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(v); v = virtualinvoke v.(v, v); return v; label: v = virtualinvoke v.(v, v, v); return v; } public boolean isDir(org.apache.hadoop.fs.Path) throws org.apache.hadoop.hive.metastore.api.MetaException { org.apache.hadoop.fs.FileSystem v; org.apache.hadoop.fs.Path v; java.io.IOException v; org.apache.hadoop.fs.FileStatus v; java.io.FileNotFoundException v; boolean v; org.apache.hadoop.hive.metastore.Warehouse v; v := @this: org.apache.hadoop.hive.metastore.Warehouse; v := @parameter: org.apache.hadoop.fs.Path; label: v = virtualinvoke v.