public class oadd.org.apache.drill.exec.server.DrillbitContext extends java.lang.Object implements java.lang.AutoCloseable
{
private final oadd.org.apache.drill.exec.server.BootStrapContext context;
private final oadd.org.apache.drill.exec.planner.PhysicalPlanReader reader;
private final oadd.org.apache.drill.exec.coord.ClusterCoordinator coord;
private final oadd.org.apache.drill.exec.rpc.data.DataConnectionCreator connectionsPool;
private final oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint endpoint;
private final oadd.org.apache.drill.exec.store.StoragePluginRegistry storagePlugins;
private final oadd.org.apache.drill.exec.alias.AliasRegistryProvider aliasRegistryProvider;
private final oadd.org.apache.drill.exec.oauth.OAuthTokenProvider oAuthTokenProvider;
private final oadd.org.apache.drill.exec.physical.impl.OperatorCreatorRegistry operatorCreatorRegistry;
private final oadd.org.apache.drill.exec.rpc.control.Controller controller;
private final oadd.org.apache.drill.exec.rpc.control.WorkEventBus workBus;
private final oadd.org.apache.drill.exec.expr.fn.FunctionImplementationRegistry functionRegistry;
private final oadd.org.apache.drill.exec.server.options.SystemOptionManager systemOptions;
private final oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider provider;
private final oadd.org.apache.drill.exec.compile.CodeCompiler compiler;
private final oadd.org.apache.drill.common.scanner.persistence.ScanResult classpathScan;
private final oadd.org.apache.drill.common.config.LogicalPlanPersistence lpPersistence;
private final oadd.org.apache.drill.exec.planner.sql.DrillOperatorTable table;
private final oadd.org.apache.drill.exec.server.QueryProfileStoreContext profileStoreContext;
private oadd.org.apache.drill.exec.work.foreman.rm.ResourceManager resourceManager;
private final org.apache.drill.metastore.MetastoreRegistry metastoreRegistry;
private final oadd.org.apache.drill.exec.metrics.DrillCounters counters;
public void <init>(oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint, oadd.org.apache.drill.exec.server.BootStrapContext, oadd.org.apache.drill.exec.coord.ClusterCoordinator, oadd.org.apache.drill.exec.rpc.control.Controller, oadd.org.apache.drill.exec.rpc.data.DataConnectionCreator, oadd.org.apache.drill.exec.rpc.control.WorkEventBus, oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider)
{
oadd.org.apache.drill.exec.server.BootStrapContext v;
oadd.org.apache.drill.exec.rpc.control.Controller v;
oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider v;
oadd.org.apache.drill.exec.rpc.control.WorkEventBus v;
oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint v;
oadd.org.apache.drill.exec.rpc.data.DataConnectionCreator v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
oadd.org.apache.drill.exec.coord.ClusterCoordinator v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v := @parameter: oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint;
v := @parameter: oadd.org.apache.drill.exec.server.BootStrapContext;
v := @parameter: oadd.org.apache.drill.exec.coord.ClusterCoordinator;
v := @parameter: oadd.org.apache.drill.exec.rpc.control.Controller;
v := @parameter: oadd.org.apache.drill.exec.rpc.data.DataConnectionCreator;
v := @parameter: oadd.org.apache.drill.exec.rpc.control.WorkEventBus;
v := @parameter: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider;
specialinvoke v.<oadd.org.apache.drill.exec.server.DrillbitContext: void <init>(oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint,oadd.org.apache.drill.exec.server.BootStrapContext,oadd.org.apache.drill.exec.coord.ClusterCoordinator,oadd.org.apache.drill.exec.rpc.control.Controller,oadd.org.apache.drill.exec.rpc.data.DataConnectionCreator,oadd.org.apache.drill.exec.rpc.control.WorkEventBus,oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider,oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider)>(v, v, v, v, v, v, v, v);
return;
}
public void <init>(oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint, oadd.org.apache.drill.exec.server.BootStrapContext, oadd.org.apache.drill.exec.coord.ClusterCoordinator, oadd.org.apache.drill.exec.rpc.control.Controller, oadd.org.apache.drill.exec.rpc.data.DataConnectionCreator, oadd.org.apache.drill.exec.rpc.control.WorkEventBus, oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider, oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider)
{
org.apache.drill.metastore.MetastoreRegistry v;
oadd.org.apache.drill.exec.store.StoragePluginRegistry v;
oadd.org.apache.drill.exec.rpc.control.Controller v;
oadd.org.apache.drill.exec.metrics.DrillCounters v;
oadd.org.apache.drill.exec.server.BootStrapContext v;
oadd.org.apache.drill.common.scanner.persistence.ScanResult v, v, v, v, v;
oadd.org.apache.drill.exec.oauth.OAuthTokenProvider v;
oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider v, v;
oadd.org.apache.drill.exec.rpc.control.WorkEventBus v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
oadd.org.apache.drill.exec.coord.ClusterCoordinator v;
oadd.org.apache.drill.exec.planner.sql.DrillOperatorTable v;
java.lang.Object[] v;
oadd.org.apache.drill.common.map.CaseInsensitiveMap v;
oadd.org.apache.drill.common.config.LogicalPlanPersistence v, v, v;
oadd.org.apache.drill.common.config.DrillConfig v;
oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint v;
oadd.org.apache.drill.exec.expr.fn.FunctionImplementationRegistry v, v;
oadd.org.apache.drill.exec.physical.impl.OperatorCreatorRegistry v;
oadd.org.apache.drill.exec.server.options.SystemOptionManager v, v, v, v;
oadd.org.apache.drill.exec.planner.PhysicalPlanReader v;
oadd.org.apache.drill.exec.rpc.data.DataConnectionCreator v;
oadd.org.apache.drill.exec.server.QueryProfileStoreContext v;
oadd.org.apache.drill.exec.alias.AliasRegistryProvider v;
java.lang.Object v, v, v, v, v;
oadd.org.apache.drill.exec.compile.CodeCompiler v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v := @parameter: oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint;
v := @parameter: oadd.org.apache.drill.exec.server.BootStrapContext;
v := @parameter: oadd.org.apache.drill.exec.coord.ClusterCoordinator;
v := @parameter: oadd.org.apache.drill.exec.rpc.control.Controller;
v := @parameter: oadd.org.apache.drill.exec.rpc.data.DataConnectionCreator;
v := @parameter: oadd.org.apache.drill.exec.rpc.control.WorkEventBus;
v := @parameter: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider;
v := @parameter: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider;
specialinvoke v.<java.lang.Object: void <init>()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.BootStrapContext: oadd.org.apache.drill.common.scanner.persistence.ScanResult getClasspathScan()>();
v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.common.scanner.persistence.ScanResult classpathScan> = v;
v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.rpc.control.WorkEventBus workBus> = v;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object)>(v);
v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.rpc.control.Controller controller> = v;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object)>(v);
v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.server.BootStrapContext context> = v;
v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.coord.ClusterCoordinator coord> = v;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object)>(v);
v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.rpc.data.DataConnectionCreator connectionsPool> = v;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object)>(v);
v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint endpoint> = v;
v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider provider> = v;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.BootStrapContext: oadd.org.apache.drill.common.config.DrillConfig getConfig()>();
v = new oadd.org.apache.drill.common.config.LogicalPlanPersistence;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.common.scanner.persistence.ScanResult classpathScan>;
specialinvoke v.<oadd.org.apache.drill.common.config.LogicalPlanPersistence: void <init>(oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.drill.common.scanner.persistence.ScanResult)>(v, v);
v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.common.config.LogicalPlanPersistence lpPersistence> = v;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = virtualinvoke v.<oadd.org.apache.drill.common.config.DrillConfig: java.lang.Object getInstance(java.lang.String,java.lang.Class,java.lang.Object[])>("drill.exec.storage.registry", class "Loadd/org/apache/drill/exec/store/StoragePluginRegistry;", v);
v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.store.StoragePluginRegistry storagePlugins> = v;
v = new oadd.org.apache.drill.exec.planner.PhysicalPlanReader;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.common.scanner.persistence.ScanResult classpathScan>;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.common.config.LogicalPlanPersistence lpPersistence>;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.store.StoragePluginRegistry storagePlugins>;
specialinvoke v.<oadd.org.apache.drill.exec.planner.PhysicalPlanReader: void <init>(oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.drill.common.scanner.persistence.ScanResult,oadd.org.apache.drill.common.config.LogicalPlanPersistence,oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint,oadd.org.apache.drill.exec.store.StoragePluginRegistry)>(v, v, v, v, v);
v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.planner.PhysicalPlanReader reader> = v;
v = new oadd.org.apache.drill.exec.physical.impl.OperatorCreatorRegistry;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.common.scanner.persistence.ScanResult classpathScan>;
specialinvoke v.<oadd.org.apache.drill.exec.physical.impl.OperatorCreatorRegistry: void <init>(oadd.org.apache.drill.common.scanner.persistence.ScanResult)>(v);
v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.physical.impl.OperatorCreatorRegistry operatorCreatorRegistry> = v;
v = new oadd.org.apache.drill.exec.server.options.SystemOptionManager;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.common.config.LogicalPlanPersistence lpPersistence>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.BootStrapContext: oadd.org.apache.drill.common.map.CaseInsensitiveMap getDefinitions()>();
specialinvoke v.<oadd.org.apache.drill.exec.server.options.SystemOptionManager: void <init>(oadd.org.apache.drill.common.config.LogicalPlanPersistence,oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider,oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.drill.common.map.CaseInsensitiveMap)>(v, v, v, v);
v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.server.options.SystemOptionManager systemOptions> = v;
v = new oadd.org.apache.drill.exec.expr.fn.FunctionImplementationRegistry;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.common.scanner.persistence.ScanResult classpathScan>;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.server.options.SystemOptionManager systemOptions>;
specialinvoke v.<oadd.org.apache.drill.exec.expr.fn.FunctionImplementationRegistry: void <init>(oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.drill.common.scanner.persistence.ScanResult,oadd.org.apache.drill.exec.server.options.OptionManager)>(v, v, v);
v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.expr.fn.FunctionImplementationRegistry functionRegistry> = v;
v = new oadd.org.apache.drill.exec.compile.CodeCompiler;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.server.options.SystemOptionManager systemOptions>;
specialinvoke v.<oadd.org.apache.drill.exec.compile.CodeCompiler: void <init>(oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.drill.exec.server.options.OptionSet)>(v, v);
v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.compile.CodeCompiler compiler> = v;
v = new oadd.org.apache.drill.exec.planner.sql.DrillOperatorTable;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.expr.fn.FunctionImplementationRegistry functionRegistry>;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.server.options.SystemOptionManager systemOptions>;
specialinvoke v.<oadd.org.apache.drill.exec.planner.sql.DrillOperatorTable: void <init>(oadd.org.apache.drill.exec.expr.fn.FunctionImplementationRegistry,oadd.org.apache.drill.exec.server.options.OptionManager)>(v, v);
v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.planner.sql.DrillOperatorTable table> = v;
v = new oadd.org.apache.drill.exec.server.QueryProfileStoreContext;
specialinvoke v.<oadd.org.apache.drill.exec.server.QueryProfileStoreContext: void <init>(oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider,oadd.org.apache.drill.exec.coord.ClusterCoordinator)>(v, v, v);
v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.server.QueryProfileStoreContext profileStoreContext> = v;
v = new org.apache.drill.metastore.MetastoreRegistry;
specialinvoke v.<org.apache.drill.metastore.MetastoreRegistry: void <init>(oadd.org.apache.drill.common.config.DrillConfig)>(v);
v.<oadd.org.apache.drill.exec.server.DrillbitContext: org.apache.drill.metastore.MetastoreRegistry metastoreRegistry> = v;
v = new oadd.org.apache.drill.exec.alias.AliasRegistryProvider;
specialinvoke v.<oadd.org.apache.drill.exec.alias.AliasRegistryProvider: void <init>(oadd.org.apache.drill.exec.server.DrillbitContext)>(v);
v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.alias.AliasRegistryProvider aliasRegistryProvider> = v;
v = new oadd.org.apache.drill.exec.oauth.OAuthTokenProvider;
specialinvoke v.<oadd.org.apache.drill.exec.oauth.OAuthTokenProvider: void <init>(oadd.org.apache.drill.exec.server.DrillbitContext)>(v);
v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.oauth.OAuthTokenProvider oAuthTokenProvider> = v;
v = staticinvoke <oadd.org.apache.drill.exec.metrics.DrillCounters: oadd.org.apache.drill.exec.metrics.DrillCounters getInstance()>();
v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.metrics.DrillCounters counters> = v;
return;
}
public oadd.org.apache.drill.exec.server.QueryProfileStoreContext getProfileStoreContext()
{
oadd.org.apache.drill.exec.server.QueryProfileStoreContext v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.server.QueryProfileStoreContext profileStoreContext>;
return v;
}
public void startRM()
{
oadd.org.apache.drill.exec.work.foreman.rm.ResourceManagerBuilder v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
oadd.org.apache.drill.exec.work.foreman.rm.ResourceManager v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = new oadd.org.apache.drill.exec.work.foreman.rm.ResourceManagerBuilder;
specialinvoke v.<oadd.org.apache.drill.exec.work.foreman.rm.ResourceManagerBuilder: void <init>(oadd.org.apache.drill.exec.server.DrillbitContext)>(v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.work.foreman.rm.ResourceManagerBuilder: oadd.org.apache.drill.exec.work.foreman.rm.ResourceManager build()>();
v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.work.foreman.rm.ResourceManager resourceManager> = v;
return;
}
public oadd.org.apache.drill.exec.expr.fn.FunctionImplementationRegistry getFunctionImplementationRegistry()
{
oadd.org.apache.drill.exec.expr.fn.FunctionImplementationRegistry v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.expr.fn.FunctionImplementationRegistry functionRegistry>;
return v;
}
public oadd.org.apache.drill.exec.rpc.control.WorkEventBus getWorkBus()
{
oadd.org.apache.drill.exec.rpc.control.WorkEventBus v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.rpc.control.WorkEventBus workBus>;
return v;
}
public oadd.org.apache.drill.exec.server.options.SystemOptionManager getOptionManager()
{
oadd.org.apache.drill.exec.server.options.SystemOptionManager v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.server.options.SystemOptionManager systemOptions>;
return v;
}
public oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint getEndpoint()
{
oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint endpoint>;
return v;
}
public oadd.org.apache.drill.common.config.DrillConfig getConfig()
{
oadd.org.apache.drill.common.config.DrillConfig v;
oadd.org.apache.drill.exec.server.BootStrapContext v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.server.BootStrapContext context>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.BootStrapContext: oadd.org.apache.drill.common.config.DrillConfig getConfig()>();
return v;
}
public java.util.Collection getAvailableBits()
{
oadd.org.apache.drill.exec.coord.ClusterCoordinator v;
java.util.Collection v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.coord.ClusterCoordinator coord>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.coord.ClusterCoordinator: java.util.Collection getAvailableEndpoints()>();
return v;
}
public java.util.Collection getBits()
{
oadd.org.apache.drill.exec.coord.ClusterCoordinator v;
java.util.Collection v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.coord.ClusterCoordinator coord>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.coord.ClusterCoordinator: java.util.Collection getOnlineEndPoints()>();
return v;
}
public boolean isOnline(oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint)
{
oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$State v, v;
boolean v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v := @parameter: oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint: oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$State getState()>();
v = <oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$State: oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$State ONLINE>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint$State: boolean equals(java.lang.Object)>(v);
return v;
}
public boolean isForeman(oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint)
{
oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint v, v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
int v, v;
java.lang.String v, v;
boolean v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v := @parameter: oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint getEndpoint()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint: java.lang.String getAddress()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint: java.lang.String getAddress()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint: int getUserPort()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint: int getUserPort()>();
if v != v goto label;
return 1;
label:
return 0;
}
public boolean isForemanOnline()
{
java.util.Iterator v;
java.util.Collection v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
java.lang.Object v;
boolean v, v, v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitContext: java.util.Collection getAvailableBits()>();
v = interfaceinvoke v.<java.util.Collection: 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()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitContext: boolean isForeman(oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint)>(v);
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitContext: boolean isOnline(oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint)>(v);
if v == 0 goto label;
return 1;
label:
return 0;
}
public oadd.org.apache.drill.exec.memory.BufferAllocator getAllocator()
{
oadd.org.apache.drill.exec.memory.BufferAllocator v;
oadd.org.apache.drill.exec.server.BootStrapContext v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.server.BootStrapContext context>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.BootStrapContext: oadd.org.apache.drill.exec.memory.BufferAllocator getAllocator()>();
return v;
}
public oadd.org.apache.drill.exec.physical.impl.OperatorCreatorRegistry getOperatorCreatorRegistry()
{
oadd.org.apache.drill.exec.physical.impl.OperatorCreatorRegistry v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.physical.impl.OperatorCreatorRegistry operatorCreatorRegistry>;
return v;
}
public oadd.org.apache.drill.exec.store.StoragePluginRegistry getStorage()
{
oadd.org.apache.drill.exec.store.StoragePluginRegistry v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.store.StoragePluginRegistry storagePlugins>;
return v;
}
public oadd.org.apache.drill.exec.alias.AliasRegistryProvider getAliasRegistryProvider()
{
oadd.org.apache.drill.exec.alias.AliasRegistryProvider v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.alias.AliasRegistryProvider aliasRegistryProvider>;
return v;
}
public oadd.org.apache.drill.exec.oauth.OAuthTokenProvider getOauthTokenProvider()
{
oadd.org.apache.drill.exec.oauth.OAuthTokenProvider v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.oauth.OAuthTokenProvider oAuthTokenProvider>;
return v;
}
public oadd.io.netty.channel.EventLoopGroup getBitLoopGroup()
{
oadd.io.netty.channel.EventLoopGroup v;
oadd.org.apache.drill.exec.server.BootStrapContext v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.server.BootStrapContext context>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.BootStrapContext: oadd.io.netty.channel.EventLoopGroup getControlLoopGroup()>();
return v;
}
public oadd.org.apache.drill.exec.rpc.data.DataConnectionCreator getDataConnectionsPool()
{
oadd.org.apache.drill.exec.rpc.data.DataConnectionCreator v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.rpc.data.DataConnectionCreator connectionsPool>;
return v;
}
public oadd.org.apache.drill.exec.rpc.control.Controller getController()
{
oadd.org.apache.drill.exec.rpc.control.Controller v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.rpc.control.Controller controller>;
return v;
}
public oadd.com.codahale.metrics.MetricRegistry getMetrics()
{
oadd.com.codahale.metrics.MetricRegistry v;
oadd.org.apache.drill.exec.server.BootStrapContext v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.server.BootStrapContext context>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.BootStrapContext: oadd.com.codahale.metrics.MetricRegistry getMetrics()>();
return v;
}
public oadd.org.apache.drill.exec.planner.PhysicalPlanReader getPlanReader()
{
oadd.org.apache.drill.exec.planner.PhysicalPlanReader v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.planner.PhysicalPlanReader reader>;
return v;
}
public oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider getStoreProvider()
{
oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider provider>;
return v;
}
public oadd.org.apache.drill.exec.store.SchemaFactory getSchemaFactory()
{
oadd.org.apache.drill.exec.store.StoragePluginRegistry v;
oadd.org.apache.drill.exec.store.SchemaFactory v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.store.StoragePluginRegistry storagePlugins>;
v = interfaceinvoke v.<oadd.org.apache.drill.exec.store.StoragePluginRegistry: oadd.org.apache.drill.exec.store.SchemaFactory getSchemaFactory()>();
return v;
}
public oadd.org.apache.drill.exec.coord.ClusterCoordinator getClusterCoordinator()
{
oadd.org.apache.drill.exec.coord.ClusterCoordinator v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.coord.ClusterCoordinator coord>;
return v;
}
public oadd.org.apache.drill.exec.compile.CodeCompiler getCompiler()
{
oadd.org.apache.drill.exec.compile.CodeCompiler v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.compile.CodeCompiler compiler>;
return v;
}
public java.util.concurrent.ExecutorService getExecutor()
{
java.util.concurrent.ExecutorService v;
oadd.org.apache.drill.exec.server.BootStrapContext v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.server.BootStrapContext context>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.BootStrapContext: java.util.concurrent.ExecutorService getExecutor()>();
return v;
}
public java.util.concurrent.ExecutorService getScanExecutor()
{
java.util.concurrent.ExecutorService v;
oadd.org.apache.drill.exec.server.BootStrapContext v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.server.BootStrapContext context>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.BootStrapContext: java.util.concurrent.ExecutorService getScanExecutor()>();
return v;
}
public java.util.concurrent.ExecutorService getScanDecodeExecutor()
{
java.util.concurrent.ExecutorService v;
oadd.org.apache.drill.exec.server.BootStrapContext v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.server.BootStrapContext context>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.BootStrapContext: java.util.concurrent.ExecutorService getScanDecodeExecutor()>();
return v;
}
public oadd.org.apache.drill.common.config.LogicalPlanPersistence getLpPersistence()
{
oadd.org.apache.drill.common.config.LogicalPlanPersistence v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.common.config.LogicalPlanPersistence lpPersistence>;
return v;
}
public oadd.org.apache.drill.common.scanner.persistence.ScanResult getClasspathScan()
{
oadd.org.apache.drill.common.scanner.persistence.ScanResult v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.common.scanner.persistence.ScanResult classpathScan>;
return v;
}
public oadd.org.apache.drill.exec.expr.fn.registry.RemoteFunctionRegistry getRemoteFunctionRegistry()
{
oadd.org.apache.drill.exec.expr.fn.FunctionImplementationRegistry v;
oadd.org.apache.drill.exec.expr.fn.registry.RemoteFunctionRegistry v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.expr.fn.FunctionImplementationRegistry functionRegistry>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.expr.fn.FunctionImplementationRegistry: oadd.org.apache.drill.exec.expr.fn.registry.RemoteFunctionRegistry getRemoteFunctionRegistry()>();
return v;
}
public oadd.org.apache.drill.exec.planner.sql.DrillOperatorTable getOperatorTable()
{
oadd.org.apache.drill.exec.planner.sql.DrillOperatorTable v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.planner.sql.DrillOperatorTable table>;
return v;
}
public oadd.org.apache.drill.exec.rpc.security.AuthenticatorProvider getAuthProvider()
{
oadd.org.apache.drill.exec.rpc.security.AuthenticatorProvider v;
oadd.org.apache.drill.exec.server.BootStrapContext v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.server.BootStrapContext context>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.BootStrapContext: oadd.org.apache.drill.exec.rpc.security.AuthenticatorProvider getAuthProvider()>();
return v;
}
public java.util.Set getUserConnections()
{
java.util.Set v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = staticinvoke <oadd.org.apache.drill.exec.rpc.user.UserServer: java.util.Set getUserConnections()>();
return v;
}
public void close() throws java.lang.Exception
{
org.apache.drill.metastore.MetastoreRegistry v;
oadd.org.apache.drill.exec.oauth.OAuthTokenProvider v;
oadd.org.apache.drill.exec.server.options.SystemOptionManager v;
oadd.org.apache.drill.exec.expr.fn.FunctionImplementationRegistry v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
oadd.org.apache.drill.exec.alias.AliasRegistryProvider v;
oadd.org.apache.drill.exec.expr.fn.registry.RemoteFunctionRegistry v;
oadd.org.apache.drill.exec.compile.CodeCompiler v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.server.options.SystemOptionManager getOptionManager()>();
virtualinvoke v.<oadd.org.apache.drill.exec.server.options.SystemOptionManager: void close()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.expr.fn.FunctionImplementationRegistry getFunctionImplementationRegistry()>();
virtualinvoke v.<oadd.org.apache.drill.exec.expr.fn.FunctionImplementationRegistry: void close()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.expr.fn.registry.RemoteFunctionRegistry getRemoteFunctionRegistry()>();
virtualinvoke v.<oadd.org.apache.drill.exec.expr.fn.registry.RemoteFunctionRegistry: void close()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.compile.CodeCompiler getCompiler()>();
virtualinvoke v.<oadd.org.apache.drill.exec.compile.CodeCompiler: void close()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitContext: org.apache.drill.metastore.MetastoreRegistry getMetastoreRegistry()>();
virtualinvoke v.<org.apache.drill.metastore.MetastoreRegistry: void close()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.alias.AliasRegistryProvider getAliasRegistryProvider()>();
virtualinvoke v.<oadd.org.apache.drill.exec.alias.AliasRegistryProvider: void close()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.oauth.OAuthTokenProvider getOauthTokenProvider()>();
virtualinvoke v.<oadd.org.apache.drill.exec.oauth.OAuthTokenProvider: void close()>();
return;
}
public oadd.org.apache.drill.exec.work.foreman.rm.ResourceManager getResourceManager()
{
oadd.org.apache.drill.exec.server.DrillbitContext v;
oadd.org.apache.drill.exec.work.foreman.rm.ResourceManager v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.work.foreman.rm.ResourceManager resourceManager>;
return v;
}
public org.apache.drill.metastore.MetastoreRegistry getMetastoreRegistry()
{
org.apache.drill.metastore.MetastoreRegistry v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: org.apache.drill.metastore.MetastoreRegistry metastoreRegistry>;
return v;
}
public oadd.org.apache.drill.exec.metrics.DrillCounters getCounters()
{
oadd.org.apache.drill.exec.metrics.DrillCounters v;
oadd.org.apache.drill.exec.server.DrillbitContext v;
v := @this: oadd.org.apache.drill.exec.server.DrillbitContext;
v = v.<oadd.org.apache.drill.exec.server.DrillbitContext: oadd.org.apache.drill.exec.metrics.DrillCounters counters>;
return v;
}
}