public class org.finos.legend.engine.pure.runtime.execution.shared.LegendExecute extends java.lang.Object
{
private static final org.slf4j.Logger LOGGER;
public void <init>()
{
org.finos.legend.engine.pure.runtime.execution.shared.LegendExecute v;
v := @this: org.finos.legend.engine.pure.runtime.execution.shared.LegendExecute;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static java.lang.String doExecute(java.lang.String, java.util.Map)
{
org.finos.legend.engine.plan.execution.PlanExecutor$ExecuteArgs v;
org.finos.legend.engine.shared.core.identity.Identity v;
org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat v;
java.lang.AutoCloseable v;
org.eclipse.collections.api.list.MutableList v;
org.finos.legend.engine.plan.execution.PlanExecutor v;
java.util.Map v;
boolean v, v;
java.lang.Exception v;
java.util.List v;
org.finos.legend.engine.plan.execution.PlanExecutor$ExecuteArgsBuilder v, v, v, v, v;
java.lang.Throwable v;
org.finos.legend.pure.m.exception.PureExecutionException v;
java.io.ByteArrayOutputStream v;
org.finos.legend.engine.shared.core.identity.factory.IdentityFactory v;
java.lang.String v, v, v, v, v, v, v, v, v;
java.lang.UnsupportedOperationException v;
org.finos.legend.engine.plan.execution.result.Result v;
org.slf4j.Logger v;
javax.security.auth.Subject v;
java.lang.Class v, v;
java.lang.Object v;
v := @parameter: java.lang.String;
v := @parameter: java.util.Map;
v = staticinvoke <org.finos.legend.engine.plan.execution.PlanExecutor: org.finos.legend.engine.plan.execution.PlanExecutor newPlanExecutorWithAvailableStoreExecutors(boolean)>(1);
v = staticinvoke <org.finos.legend.engine.shared.core.identity.factory.IdentityFactoryProvider: org.finos.legend.engine.shared.core.identity.factory.IdentityFactory getInstance()>();
v = staticinvoke <org.finos.legend.engine.shared.core.kerberos.SubjectTools: javax.security.auth.Subject getCurrentSubject()>();
v = interfaceinvoke v.<org.finos.legend.engine.shared.core.identity.factory.IdentityFactory: org.finos.legend.engine.shared.core.identity.Identity makeIdentity(javax.security.auth.Subject)>(v);
v = interfaceinvoke v.<org.finos.legend.engine.shared.core.identity.factory.IdentityFactory: java.util.List adapt(org.finos.legend.engine.shared.core.identity.Identity)>(v);
v = staticinvoke <org.eclipse.collections.impl.list.mutable.ListAdapter: org.eclipse.collections.api.list.MutableList adapt(java.util.List)>(v);
v = staticinvoke <org.finos.legend.engine.plan.execution.PlanExecutor: org.finos.legend.engine.plan.execution.PlanExecutor$ExecuteArgsBuilder withArgs()>();
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.PlanExecutor$ExecuteArgsBuilder: org.finos.legend.engine.plan.execution.PlanExecutor$ExecuteArgsBuilder withParams(java.util.Map)>(v);
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.PlanExecutor$ExecuteArgsBuilder: org.finos.legend.engine.plan.execution.PlanExecutor$ExecuteArgsBuilder withPlanAsString(java.lang.String)>(v);
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.PlanExecutor$ExecuteArgsBuilder: org.finos.legend.engine.plan.execution.PlanExecutor$ExecuteArgsBuilder withProfiles(org.eclipse.collections.api.list.MutableList)>(v);
v = virtualinvoke v.<org.finos.legend.engine.shared.core.identity.Identity: java.lang.String getName()>();
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.PlanExecutor$ExecuteArgsBuilder: org.finos.legend.engine.plan.execution.PlanExecutor$ExecuteArgsBuilder withUser(java.lang.String)>(v);
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.PlanExecutor$ExecuteArgsBuilder: org.finos.legend.engine.plan.execution.PlanExecutor$ExecuteArgs build()>();
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.PlanExecutor: org.finos.legend.engine.plan.execution.result.Result executeWithArgs(org.finos.legend.engine.plan.execution.PlanExecutor$ExecuteArgs)>(v);
label:
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <org.finos.legend.engine.pure.runtime.execution.shared.LegendExecute$close__16: java.lang.AutoCloseable bootstrap$(org.finos.legend.engine.plan.execution.result.Result)>(v);
label:
v = v instanceof org.finos.legend.engine.plan.execution.result.StreamingResult;
if v == 0 goto label;
v = new java.io.ByteArrayOutputStream;
specialinvoke v.<java.io.ByteArrayOutputStream: void <init>()>();
v = <org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat: org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat defaultFormat>;
virtualinvoke v.<org.finos.legend.engine.plan.execution.result.StreamingResult: void stream(java.io.OutputStream,org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat)>(v, v);
v = virtualinvoke v.<java.io.ByteArrayOutputStream: java.lang.String toString()>();
label:
if v == null goto label;
interfaceinvoke v.<java.lang.AutoCloseable: void close()>();
label:
return v;
label:
v = v instanceof org.finos.legend.engine.plan.execution.result.ConstantResult;
if v == 0 goto label;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.result.ConstantResult: java.lang.Object stream()>();
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
label:
if v == null goto label;
interfaceinvoke v.<java.lang.AutoCloseable: void close()>();
label:
return v;
label:
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Result type not supported: \u0001");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
v = <org.finos.legend.engine.pure.runtime.execution.shared.LegendExecute: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Failed to execute plan", v);
v = new org.finos.legend.pure.m.exception.PureExecutionException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to execute plan - \u - \u0001");
specialinvoke v.<org.finos.legend.pure.m.exception.PureExecutionException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/finos/legend/engine/pure/runtime/execution/shared/LegendExecute;");
<org.finos.legend.engine.pure.runtime.execution.shared.LegendExecute: org.slf4j.Logger LOGGER> = v;
return;
}
}