public class oadd.org.apache.drill.exec.server.QueryProfileStoreContext extends java.lang.Object
{
private static final java.lang.String PROFILES;
private static final java.lang.String RUNNING;
private final oadd.org.apache.drill.exec.store.sys.PersistentStore completedProfiles;
private final oadd.org.apache.drill.exec.coord.store.TransientStore runningProfiles;
private final oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig profileStoreConfig;
public void <init>(oadd.org.apache.drill.common.config.DrillConfig, oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider, oadd.org.apache.drill.exec.coord.ClusterCoordinator)
{
oadd.org.apache.drill.common.config.DrillConfig v;
oadd.org.apache.drill.exec.proto.SchemaUserBitShared$QueryProfile$MessageSchema v;
oadd.org.apache.drill.exec.coord.store.TransientStoreConfigBuilder v, v;
oadd.org.apache.drill.exec.proto.SchemaUserBitShared$QueryInfo$BuilderSchema v;
oadd.org.apache.drill.common.exceptions.DrillRuntimeException v;
oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider v;
oadd.org.apache.drill.exec.coord.store.TransientStore v;
java.lang.Exception v;
oadd.org.apache.drill.exec.proto.SchemaUserBitShared$QueryInfo$MessageSchema v;
oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig v, v;
oadd.org.apache.drill.exec.server.QueryProfileStoreContext v;
oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig$StoreConfigBuilder v, v, v;
oadd.org.apache.drill.exec.coord.store.TransientStoreConfig v;
oadd.org.apache.drill.exec.coord.ClusterCoordinator v;
oadd.org.apache.drill.exec.proto.SchemaUserBitShared$QueryProfile$BuilderSchema v;
oadd.org.apache.drill.exec.store.sys.PersistentStore v;
v := @this: oadd.org.apache.drill.exec.server.QueryProfileStoreContext;
v := @parameter: oadd.org.apache.drill.common.config.DrillConfig;
v := @parameter: oadd.org.apache.drill.exec.store.sys.PersistentStoreProvider;
v := @parameter: oadd.org.apache.drill.exec.coord.ClusterCoordinator;
specialinvoke v.<java.lang.Object: void <init>()>();
v = <oadd.org.apache.drill.exec.proto.SchemaUserBitShared$QueryProfile: oadd.org.apache.drill.exec.proto.SchemaUserBitShared$QueryProfile$MessageSchema WRITE>;
v = <oadd.org.apache.drill.exec.proto.SchemaUserBitShared$QueryProfile: oadd.org.apache.drill.exec.proto.SchemaUserBitShared$QueryProfile$BuilderSchema MERGE>;
v = staticinvoke <oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig: oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig$StoreConfigBuilder newProtoBuilder(oadd.io.protostuff.Schema,oadd.io.protostuff.Schema)>(v, v);
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)>("profiles");
v = virtualinvoke v.<oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig$StoreConfigBuilder: oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig$StoreConfigBuilder blob()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig$StoreConfigBuilder: oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig build()>();
v.<oadd.org.apache.drill.exec.server.QueryProfileStoreContext: oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig profileStoreConfig> = v;
label:
v = v.<oadd.org.apache.drill.exec.server.QueryProfileStoreContext: oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig profileStoreConfig>;
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.server.QueryProfileStoreContext: oadd.org.apache.drill.exec.store.sys.PersistentStore completedProfiles> = 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.Throwable)>(v);
throw v;
label:
v = <oadd.org.apache.drill.exec.proto.SchemaUserBitShared$QueryInfo: oadd.org.apache.drill.exec.proto.SchemaUserBitShared$QueryInfo$MessageSchema WRITE>;
v = <oadd.org.apache.drill.exec.proto.SchemaUserBitShared$QueryInfo: oadd.org.apache.drill.exec.proto.SchemaUserBitShared$QueryInfo$BuilderSchema MERGE>;
v = staticinvoke <oadd.org.apache.drill.exec.coord.store.TransientStoreConfig: oadd.org.apache.drill.exec.coord.store.TransientStoreConfigBuilder newProtoBuilder(oadd.io.protostuff.Schema,oadd.io.protostuff.Schema)>(v, v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.coord.store.TransientStoreConfigBuilder: oadd.org.apache.drill.exec.coord.store.TransientStoreConfigBuilder name(java.lang.String)>("running");
v = virtualinvoke v.<oadd.org.apache.drill.exec.coord.store.TransientStoreConfigBuilder: oadd.org.apache.drill.exec.coord.store.TransientStoreConfig build()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.coord.ClusterCoordinator: oadd.org.apache.drill.exec.coord.store.TransientStore getOrCreateTransientStore(oadd.org.apache.drill.exec.coord.store.TransientStoreConfig)>(v);
v.<oadd.org.apache.drill.exec.server.QueryProfileStoreContext: oadd.org.apache.drill.exec.coord.store.TransientStore runningProfiles> = v;
return;
catch java.lang.Exception from label to label with label;
}
public oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig getProfileStoreConfig()
{
oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig v;
oadd.org.apache.drill.exec.server.QueryProfileStoreContext v;
v := @this: oadd.org.apache.drill.exec.server.QueryProfileStoreContext;
v = v.<oadd.org.apache.drill.exec.server.QueryProfileStoreContext: oadd.org.apache.drill.exec.store.sys.PersistentStoreConfig profileStoreConfig>;
return v;
}
public oadd.org.apache.drill.exec.store.sys.PersistentStore getCompletedProfileStore()
{
oadd.org.apache.drill.exec.server.QueryProfileStoreContext v;
oadd.org.apache.drill.exec.store.sys.PersistentStore v;
v := @this: oadd.org.apache.drill.exec.server.QueryProfileStoreContext;
v = v.<oadd.org.apache.drill.exec.server.QueryProfileStoreContext: oadd.org.apache.drill.exec.store.sys.PersistentStore completedProfiles>;
return v;
}
public oadd.org.apache.drill.exec.coord.store.TransientStore getRunningProfileStore()
{
oadd.org.apache.drill.exec.coord.store.TransientStore v;
oadd.org.apache.drill.exec.server.QueryProfileStoreContext v;
v := @this: oadd.org.apache.drill.exec.server.QueryProfileStoreContext;
v = v.<oadd.org.apache.drill.exec.server.QueryProfileStoreContext: oadd.org.apache.drill.exec.coord.store.TransientStore runningProfiles>;
return v;
}
}