public class oadd.org.apache.drill.exec.alias.PersistentAliasRegistry extends java.lang.Object implements oadd.org.apache.drill.exec.alias.AliasRegistry
{
public static final java.lang.String PUBLIC_ALIASES_KEY;
private final oadd.org.apache.drill.exec.store.sys.PersistentStore store;
private final boolean useUserAliases;
public void <init>(oadd.org.apache.drill.exec.server.DrillbitContext, java.lang.String)
{
oadd.org.apache.drill.common.config.LogicalPlanPersistence v;
oadd.org.apache.drill.common.config.DrillConfig v;
oadd.org.apache.drill.exec.alias.PersistentAliasRegistry$StoreProvider v;
java.util.function.Supplier v;
oadd.com.fasterxml.jackson.databind.ObjectMapper v, v;
oadd.org.apache.drill.exec.alias.PersistentAliasRegistry v;
java.lang.String v;
boolean v;
oadd.org.apache.drill.common.exceptions.DrillRuntimeException v;
oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider v;
oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig v;
oadd.com.fasterxml.jackson.databind.InjectableValues$Std v, v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig$StoreConfigBuilder v, v;
oadd.org.apache.drill.exec.exception.StoreException v;
oadd.org.apache.drill.exec.store.sys.PersistentStore v;
v := @this: oadd.org.apache.drill.exec.alias.PersistentAliasRegistry;
v := @parameter: oadd.org.apache.drill.exec.server.DrillbitContext;
v := @parameter: java.lang.String;
specialinvoke v.<java.lang.Object: void <init>()>();
label:
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.common.config.LogicalPlanPersistence getLpPersistence()>();
v = virtualinvoke v.<oadd.org.apache.drill.common.config.LogicalPlanPersistence: oadd.com.fasterxml.jackson.databind.ObjectMapper getMapper()>();
v = virtualinvoke v.<oadd.com.fasterxml.jackson.databind.ObjectMapper: oadd.com.fasterxml.jackson.databind.ObjectMapper copy()>();
v = new oadd.com.fasterxml.jackson.databind.InjectableValues$Std;
specialinvoke v.<oadd.com.fasterxml.jackson.databind.InjectableValues$Std: void <init>()>();
v = new oadd.org.apache.drill.exec.alias.PersistentAliasRegistry$StoreProvider;
v = staticinvoke <oadd.org.apache.drill.exec.alias.PersistentAliasRegistry$getStore__431: java.util.function.Supplier bootstrap$(oadd.org.apache.drill.exec.alias.PersistentAliasRegistry)>(v);
specialinvoke v.<oadd.org.apache.drill.exec.alias.PersistentAliasRegistry$StoreProvider: void <init>(java.util.function.Supplier)>(v);
v = virtualinvoke v.<oadd.com.fasterxml.jackson.databind.InjectableValues$Std: oadd.com.fasterxml.jackson.databind.InjectableValues$Std addValue(java.lang.Class,java.lang.Object)>(class "Loadd/org/apache/drill/exec/alias/PersistentAliasRegistry$StoreProvider;", v);
virtualinvoke v.<oadd.com.fasterxml.jackson.databind.ObjectMapper: oadd.com.fasterxml.jackson.databind.ObjectMapper setInjectableValues(oadd.com.fasterxml.jackson.databind.InjectableValues)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider getStoreProvider()>();
v = staticinvoke <oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig: oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig$StoreConfigBuilder newJacksonBuilder(oadd.com.fasterxml.jackson.databind.ObjectMapper,java.lang.Class)>(v, class "Loadd/org/apache/drill/exec/alias/PersistentAliasesTable;");
v = virtualinvoke v.<oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig$StoreConfigBuilder: oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig$StoreConfigBuilder name(java.lang.String)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig$StoreConfigBuilder: oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig build()>();
v = interfaceinvoke v.<oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider: oadd.org.apache.drill.exec.store.sys.PersistentStore getOrCreateStore(oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig)>(v);
v.<oadd.org.apache.drill.exec.alias.PersistentAliasRegistry: oadd.org.apache.drill.exec.store.sys.PersistentStore store> = v;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.common.config.DrillConfig getConfig()>();
v = virtualinvoke v.<oadd.org.apache.drill.common.config.DrillConfig: boolean getBoolean(java.lang.String)>("drill.exec.impersonation.enabled");
v.<oadd.org.apache.drill.exec.alias.PersistentAliasRegistry: boolean useUserAliases> = v;
label:
goto label;
label:
v := @caughtexception;
v = new oadd.org.apache.drill.common.exceptions.DrillRuntimeException;
specialinvoke v.<oadd.org.apache.drill.common.exceptions.DrillRuntimeException: void <init>(java.lang.String)>("Failure while reading and loading alias table.");
throw v;
label:
return;
catch oadd.org.apache.drill.exec.exception.StoreException from label to label with label;
}
public oadd.org.apache.drill.exec.store.sys.PersistentStore getStore()
{
oadd.org.apache.drill.exec.alias.PersistentAliasRegistry v;
oadd.org.apache.drill.exec.store.sys.PersistentStore v;
v := @this: oadd.org.apache.drill.exec.alias.PersistentAliasRegistry;
v = v.<oadd.org.apache.drill.exec.alias.PersistentAliasRegistry: oadd.org.apache.drill.exec.store.sys.PersistentStore store>;
return v;
}
private oadd.org.apache.drill.exec.alias.ResolvedAliases getResolvedAliases(java.lang.String)
{
oadd.org.apache.drill.exec.alias.ResolvedAliases v;
oadd.org.apache.drill.exec.alias.EmptyAliases v;
java.util.function.Supplier v, v;
oadd.org.apache.drill.exec.alias.PersistentAliasRegistry v;
java.lang.Object v;
java.lang.String v;
oadd.org.apache.drill.exec.store.sys.PersistentStore v;
boolean v;
v := @this: oadd.org.apache.drill.exec.alias.PersistentAliasRegistry;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.drill.exec.alias.PersistentAliasRegistry: boolean useUserAliases>;
if v == 0 goto label;
v = v.<oadd.org.apache.drill.exec.alias.PersistentAliasRegistry: oadd.org.apache.drill.exec.store.sys.PersistentStore store>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.store.sys.PersistentStore: java.lang.Object get(java.lang.String)>(v);
goto label;
label:
v = null;
label:
if v == null goto label;
v = new oadd.org.apache.drill.exec.alias.ResolvedAliases;
v = staticinvoke <oadd.org.apache.drill.exec.alias.PersistentAliasRegistry$getPublicAliases__433: java.util.function.Supplier bootstrap$(oadd.org.apache.drill.exec.alias.PersistentAliasRegistry)>(v);
specialinvoke v.<oadd.org.apache.drill.exec.alias.ResolvedAliases: void <init>(oadd.org.apache.drill.exec.alias.Aliases,java.util.function.Supplier)>(v, v);
goto label;
label:
v = new oadd.org.apache.drill.exec.alias.ResolvedAliases;
v = <oadd.org.apache.drill.exec.alias.EmptyAliases: oadd.org.apache.drill.exec.alias.EmptyAliases INSTANCE>;
v = staticinvoke <oadd.org.apache.drill.exec.alias.PersistentAliasRegistry$getPublicAliases__432: java.util.function.Supplier bootstrap$(oadd.org.apache.drill.exec.alias.PersistentAliasRegistry)>(v);
specialinvoke v.<oadd.org.apache.drill.exec.alias.ResolvedAliases: void <init>(oadd.org.apache.drill.exec.alias.Aliases,java.util.function.Supplier)>(v, v);
label:
return v;
}
public java.util.Iterator getAllAliases()
{
java.util.Iterator v;
oadd.org.apache.drill.exec.alias.PersistentAliasRegistry v;
oadd.org.apache.drill.exec.store.sys.PersistentStore v;
v := @this: oadd.org.apache.drill.exec.alias.PersistentAliasRegistry;
v = v.<oadd.org.apache.drill.exec.alias.PersistentAliasRegistry: oadd.org.apache.drill.exec.store.sys.PersistentStore store>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.store.sys.PersistentStore: java.util.Iterator getAll()>();
return v;
}
public oadd.org.apache.drill.exec.alias.Aliases getUserAliases(java.lang.String)
{
java.lang.String v;
oadd.org.apache.drill.exec.alias.ResolvedAliases v;
oadd.org.apache.drill.exec.alias.PersistentAliasRegistry v;
v := @this: oadd.org.apache.drill.exec.alias.PersistentAliasRegistry;
v := @parameter: java.lang.String;
v = specialinvoke v.<oadd.org.apache.drill.exec.alias.PersistentAliasRegistry: oadd.org.apache.drill.exec.alias.ResolvedAliases getResolvedAliases(java.lang.String)>(v);
return v;
}
public void createUserAliases(java.lang.String)
{
oadd.org.apache.drill.exec.alias.PersistentAliasRegistry$StoreProvider v;
java.util.HashMap v;
java.util.function.Supplier v;
oadd.org.apache.drill.exec.alias.PersistentAliasesTable v;
oadd.org.apache.drill.exec.alias.PersistentAliasRegistry v;
java.lang.String v;
oadd.org.apache.drill.exec.store.sys.PersistentStore v, v;
boolean v;
v := @this: oadd.org.apache.drill.exec.alias.PersistentAliasRegistry;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.drill.exec.alias.PersistentAliasRegistry: oadd.org.apache.drill.exec.store.sys.PersistentStore store>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.store.sys.PersistentStore: boolean contains(java.lang.String)>(v);
if v != 0 goto label;
v = new oadd.org.apache.drill.exec.alias.PersistentAliasesTable;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = new oadd.org.apache.drill.exec.alias.PersistentAliasRegistry$StoreProvider;
v = staticinvoke <oadd.org.apache.drill.exec.alias.PersistentAliasRegistry$getStore__434: java.util.function.Supplier bootstrap$(oadd.org.apache.drill.exec.alias.PersistentAliasRegistry)>(v);
specialinvoke v.<oadd.org.apache.drill.exec.alias.PersistentAliasRegistry$StoreProvider: void <init>(java.util.function.Supplier)>(v);
specialinvoke v.<oadd.org.apache.drill.exec.alias.PersistentAliasesTable: void <init>(java.util.Map,java.lang.String,oadd.org.apache.drill.exec.alias.PersistentAliasRegistry$StoreProvider)>(v, v, v);
v = v.<oadd.org.apache.drill.exec.alias.PersistentAliasRegistry: oadd.org.apache.drill.exec.store.sys.PersistentStore store>;
interfaceinvoke v.<oadd.org.apache.drill.exec.store.sys.PersistentStore: void put(java.lang.String,java.lang.Object)>(v, v);
label:
return;
}
public void createPublicAliases()
{
oadd.org.apache.drill.exec.alias.PersistentAliasRegistry$StoreProvider v;
java.util.HashMap v;
java.util.function.Supplier v;
oadd.org.apache.drill.exec.alias.PersistentAliasesTable v;
oadd.org.apache.drill.exec.alias.PersistentAliasRegistry v;
oadd.org.apache.drill.exec.store.sys.PersistentStore v, v;
boolean v;
v := @this: oadd.org.apache.drill.exec.alias.PersistentAliasRegistry;
v = v.<oadd.org.apache.drill.exec.alias.PersistentAliasRegistry: oadd.org.apache.drill.exec.store.sys.PersistentStore store>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.store.sys.PersistentStore: boolean contains(java.lang.String)>("$public_aliases");
if v != 0 goto label;
v = new oadd.org.apache.drill.exec.alias.PersistentAliasesTable;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = new oadd.org.apache.drill.exec.alias.PersistentAliasRegistry$StoreProvider;
v = staticinvoke <oadd.org.apache.drill.exec.alias.PersistentAliasRegistry$getStore__435: java.util.function.Supplier bootstrap$(oadd.org.apache.drill.exec.alias.PersistentAliasRegistry)>(v);
specialinvoke v.<oadd.org.apache.drill.exec.alias.PersistentAliasRegistry$StoreProvider: void <init>(java.util.function.Supplier)>(v);
specialinvoke v.<oadd.org.apache.drill.exec.alias.PersistentAliasesTable: void <init>(java.util.Map,java.lang.String,oadd.org.apache.drill.exec.alias.PersistentAliasRegistry$StoreProvider)>(v, "$public_aliases", v);
v = v.<oadd.org.apache.drill.exec.alias.PersistentAliasRegistry: oadd.org.apache.drill.exec.store.sys.PersistentStore store>;
interfaceinvoke v.<oadd.org.apache.drill.exec.store.sys.PersistentStore: void put(java.lang.String,java.lang.Object)>("$public_aliases", v);
label:
return;
}
public void deleteUserAliases(java.lang.String)
{
java.lang.String v;
oadd.org.apache.drill.exec.alias.PersistentAliasRegistry v;
oadd.org.apache.drill.exec.store.sys.PersistentStore v;
v := @this: oadd.org.apache.drill.exec.alias.PersistentAliasRegistry;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.drill.exec.alias.PersistentAliasRegistry: oadd.org.apache.drill.exec.store.sys.PersistentStore store>;
interfaceinvoke v.<oadd.org.apache.drill.exec.store.sys.PersistentStore: void delete(java.lang.String)>(v);
return;
}
public void deletePublicAliases()
{
oadd.org.apache.drill.exec.alias.PersistentAliasRegistry v;
oadd.org.apache.drill.exec.store.sys.PersistentStore v;
v := @this: oadd.org.apache.drill.exec.alias.PersistentAliasRegistry;
v = v.<oadd.org.apache.drill.exec.alias.PersistentAliasRegistry: oadd.org.apache.drill.exec.store.sys.PersistentStore store>;
interfaceinvoke v.<oadd.org.apache.drill.exec.store.sys.PersistentStore: void delete(java.lang.String)>("$public_aliases");
return;
}
public oadd.org.apache.drill.exec.alias.Aliases getPublicAliases()
{
oadd.org.apache.drill.exec.alias.EmptyAliases v;
oadd.org.apache.drill.exec.alias.PersistentAliasRegistry v;
java.util.Optional v;
java.lang.Object v, v;
oadd.org.apache.drill.exec.store.sys.PersistentStore v;
v := @this: oadd.org.apache.drill.exec.alias.PersistentAliasRegistry;
v = v.<oadd.org.apache.drill.exec.alias.PersistentAliasRegistry: oadd.org.apache.drill.exec.store.sys.PersistentStore store>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.store.sys.PersistentStore: java.lang.Object get(java.lang.String)>("$public_aliases");
v = staticinvoke <java.util.Optional: java.util.Optional ofNullable(java.lang.Object)>(v);
v = <oadd.org.apache.drill.exec.alias.EmptyAliases: oadd.org.apache.drill.exec.alias.EmptyAliases INSTANCE>;
v = virtualinvoke v.<java.util.Optional: java.lang.Object orElse(java.lang.Object)>(v);
return v;
}
public void close() throws java.lang.Exception
{
oadd.org.apache.drill.exec.alias.PersistentAliasRegistry v;
oadd.org.apache.drill.exec.store.sys.PersistentStore v;
v := @this: oadd.org.apache.drill.exec.alias.PersistentAliasRegistry;
v = v.<oadd.org.apache.drill.exec.alias.PersistentAliasRegistry: oadd.org.apache.drill.exec.store.sys.PersistentStore store>;
interfaceinvoke v.<oadd.org.apache.drill.exec.store.sys.PersistentStore: void close()>();
return;
}
}