public abstract class org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor extends java.lang.Object implements org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunner
{
private static final boolean DEFAULT_ALLOW_JAVA_COMPILATION;
private final java.lang.String servicePath;
private final org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan plan;
private final org.finos.legend.engine.plan.execution.PlanExecutor executor;
protected void <init>(java.lang.String, org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan, org.finos.legend.engine.plan.execution.PlanExecutor)
{
org.finos.legend.engine.plan.execution.PlanExecutor v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan v;
java.lang.String v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: java.lang.String;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan;
v := @parameter: org.finos.legend.engine.plan.execution.PlanExecutor;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: java.lang.String servicePath> = v;
v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan plan> = v;
v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.plan.execution.PlanExecutor executor> = v;
return;
}
protected void <init>(java.lang.String, java.lang.String, org.finos.legend.engine.plan.execution.PlanExecutor)
{
org.finos.legend.engine.plan.execution.PlanExecutor v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan v;
java.lang.Class v;
java.lang.ClassLoader v;
java.lang.String v, v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.finos.legend.engine.plan.execution.PlanExecutor;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: java.lang.String servicePath> = v;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.ClassLoader getClassLoader()>();
v = staticinvoke <org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan readPlanFromResource(java.lang.ClassLoader,java.lang.String)>(v, v);
v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan plan> = v;
v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.plan.execution.PlanExecutor executor> = v;
return;
}
protected transient void <init>(java.lang.String, java.lang.String, org.finos.legend.engine.plan.execution.stores.StoreExecutorConfiguration[])
{
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
org.finos.legend.engine.plan.execution.PlanExecutor v;
org.finos.legend.engine.plan.execution.stores.StoreExecutorConfiguration[] v;
org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan v;
java.lang.Class v;
java.lang.ClassLoader v;
java.lang.String v, v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.finos.legend.engine.plan.execution.stores.StoreExecutorConfiguration[];
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: java.lang.String servicePath> = v;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.ClassLoader getClassLoader()>();
v = staticinvoke <org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan readPlanFromResource(java.lang.ClassLoader,java.lang.String)>(v, v);
v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan plan> = v;
v = staticinvoke <org.finos.legend.engine.plan.execution.PlanExecutor: org.finos.legend.engine.plan.execution.PlanExecutor newPlanExecutorWithConfigurations(org.finos.legend.engine.plan.execution.stores.StoreExecutorConfiguration[])>(v);
v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.plan.execution.PlanExecutor executor> = v;
return;
}
protected void <init>(java.lang.String, org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan, boolean)
{
org.finos.legend.engine.plan.execution.PlanExecutor v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan v;
java.lang.String v;
boolean v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: java.lang.String;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan;
v := @parameter: boolean;
v = staticinvoke <org.finos.legend.engine.plan.execution.PlanExecutor: org.finos.legend.engine.plan.execution.PlanExecutor newPlanExecutorWithAvailableStoreExecutors(boolean)>(v);
specialinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: void <init>(java.lang.String,org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan,org.finos.legend.engine.plan.execution.PlanExecutor)>(v, v, v);
return;
}
protected void <init>(java.lang.String, java.lang.String, boolean)
{
org.finos.legend.engine.plan.execution.PlanExecutor v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
java.lang.String v, v;
boolean v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v = staticinvoke <org.finos.legend.engine.plan.execution.PlanExecutor: org.finos.legend.engine.plan.execution.PlanExecutor newPlanExecutorWithAvailableStoreExecutors(boolean)>(v);
specialinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: void <init>(java.lang.String,java.lang.String,org.finos.legend.engine.plan.execution.PlanExecutor)>(v, v, v);
return;
}
protected void <init>(java.lang.String, org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan, boolean, long)
{
org.finos.legend.engine.plan.execution.PlanExecutor v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan v;
long v;
java.lang.String v;
boolean v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: java.lang.String;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan;
v := @parameter: boolean;
v := @parameter: long;
v = staticinvoke <org.finos.legend.engine.plan.execution.PlanExecutor: org.finos.legend.engine.plan.execution.PlanExecutor newPlanExecutorWithAvailableStoreExecutors(boolean,long)>(v, v);
specialinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: void <init>(java.lang.String,org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan,org.finos.legend.engine.plan.execution.PlanExecutor)>(v, v, v);
return;
}
protected void <init>(java.lang.String, java.lang.String, boolean, long)
{
org.finos.legend.engine.plan.execution.PlanExecutor v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
long v;
java.lang.String v, v;
boolean v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v := @parameter: long;
v = staticinvoke <org.finos.legend.engine.plan.execution.PlanExecutor: org.finos.legend.engine.plan.execution.PlanExecutor newPlanExecutorWithAvailableStoreExecutors(boolean,long)>(v, v);
specialinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: void <init>(java.lang.String,java.lang.String,org.finos.legend.engine.plan.execution.PlanExecutor)>(v, v, v);
return;
}
protected void <init>(java.lang.String, org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan, boolean, org.finos.legend.engine.plan.execution.graphFetch.GraphFetchExecutionConfiguration)
{
org.finos.legend.engine.plan.execution.PlanExecutor v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
org.finos.legend.engine.plan.execution.graphFetch.GraphFetchExecutionConfiguration v;
org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan v;
java.lang.String v;
boolean v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: java.lang.String;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan;
v := @parameter: boolean;
v := @parameter: org.finos.legend.engine.plan.execution.graphFetch.GraphFetchExecutionConfiguration;
v = staticinvoke <org.finos.legend.engine.plan.execution.PlanExecutor: org.finos.legend.engine.plan.execution.PlanExecutor newPlanExecutorWithAvailableStoreExecutors(boolean,org.finos.legend.engine.plan.execution.graphFetch.GraphFetchExecutionConfiguration)>(v, v);
specialinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: void <init>(java.lang.String,org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan,org.finos.legend.engine.plan.execution.PlanExecutor)>(v, v, v);
return;
}
protected void <init>(java.lang.String, java.lang.String, boolean, org.finos.legend.engine.plan.execution.graphFetch.GraphFetchExecutionConfiguration)
{
org.finos.legend.engine.plan.execution.PlanExecutor v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
org.finos.legend.engine.plan.execution.graphFetch.GraphFetchExecutionConfiguration v;
java.lang.String v, v;
boolean v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v := @parameter: org.finos.legend.engine.plan.execution.graphFetch.GraphFetchExecutionConfiguration;
v = staticinvoke <org.finos.legend.engine.plan.execution.PlanExecutor: org.finos.legend.engine.plan.execution.PlanExecutor newPlanExecutorWithAvailableStoreExecutors(boolean,org.finos.legend.engine.plan.execution.graphFetch.GraphFetchExecutionConfiguration)>(v, v);
specialinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: void <init>(java.lang.String,java.lang.String,org.finos.legend.engine.plan.execution.PlanExecutor)>(v, v, v);
return;
}
protected transient void <init>(java.lang.String, org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan, boolean, org.finos.legend.engine.plan.execution.stores.StoreExecutor[])
{
org.finos.legend.engine.plan.execution.PlanExecutor v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan v;
java.lang.String v;
boolean v;
org.finos.legend.engine.plan.execution.stores.StoreExecutor[] v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: java.lang.String;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan;
v := @parameter: boolean;
v := @parameter: org.finos.legend.engine.plan.execution.stores.StoreExecutor[];
v = staticinvoke <org.finos.legend.engine.plan.execution.PlanExecutor: org.finos.legend.engine.plan.execution.PlanExecutor newPlanExecutor(boolean,org.finos.legend.engine.plan.execution.stores.StoreExecutor[])>(v, v);
specialinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: void <init>(java.lang.String,org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan,org.finos.legend.engine.plan.execution.PlanExecutor)>(v, v, v);
return;
}
protected transient void <init>(java.lang.String, java.lang.String, boolean, org.finos.legend.engine.plan.execution.stores.StoreExecutor[])
{
org.finos.legend.engine.plan.execution.PlanExecutor v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
java.lang.String v, v;
boolean v;
org.finos.legend.engine.plan.execution.stores.StoreExecutor[] v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v := @parameter: org.finos.legend.engine.plan.execution.stores.StoreExecutor[];
v = staticinvoke <org.finos.legend.engine.plan.execution.PlanExecutor: org.finos.legend.engine.plan.execution.PlanExecutor newPlanExecutor(boolean,org.finos.legend.engine.plan.execution.stores.StoreExecutor[])>(v, v);
specialinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: void <init>(java.lang.String,java.lang.String,org.finos.legend.engine.plan.execution.PlanExecutor)>(v, v, v);
return;
}
protected void <init>(java.lang.String, org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan)
{
org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan v;
java.lang.String v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: java.lang.String;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan;
specialinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: void <init>(java.lang.String,org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan,boolean)>(v, v, 0);
return;
}
protected void <init>(java.lang.String, java.lang.String)
{
java.lang.String v, v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
specialinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: void <init>(java.lang.String,java.lang.String,boolean)>(v, v, 0);
return;
}
protected transient void <init>(java.lang.String, org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan, org.finos.legend.engine.plan.execution.stores.StoreExecutor[])
{
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan v;
java.lang.String v;
org.finos.legend.engine.plan.execution.stores.StoreExecutor[] v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: java.lang.String;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan;
v := @parameter: org.finos.legend.engine.plan.execution.stores.StoreExecutor[];
specialinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: void <init>(java.lang.String,org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan,boolean,org.finos.legend.engine.plan.execution.stores.StoreExecutor[])>(v, v, 0, v);
return;
}
protected transient void <init>(java.lang.String, java.lang.String, org.finos.legend.engine.plan.execution.stores.StoreExecutor[])
{
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
java.lang.String v, v;
org.finos.legend.engine.plan.execution.stores.StoreExecutor[] v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.finos.legend.engine.plan.execution.stores.StoreExecutor[];
specialinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: void <init>(java.lang.String,java.lang.String,boolean,org.finos.legend.engine.plan.execution.stores.StoreExecutor[])>(v, v, 0, v);
return;
}
public java.lang.String getServicePath()
{
java.lang.String v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v = v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: java.lang.String servicePath>;
return v;
}
public org.finos.legend.engine.plan.execution.PlanExecutorInfo getPlanExecutorInfo()
{
org.finos.legend.engine.plan.execution.PlanExecutorInfo v;
org.finos.legend.engine.plan.execution.PlanExecutor v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v = v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.plan.execution.PlanExecutor executor>;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.PlanExecutor: org.finos.legend.engine.plan.execution.PlanExecutorInfo getPlanExecutorInfo()>();
return v;
}
private org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder newExecutionBuilder(org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput, org.finos.legend.engine.shared.core.url.StreamProvider)
{
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
org.finos.legend.engine.shared.core.url.StreamProvider v;
int v, v, v, v, v, v, v;
java.lang.String v, v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder v, v, v;
java.lang.IllegalArgumentException v;
java.util.List v, v;
org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput v;
java.lang.Object v, v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput;
v := @parameter: org.finos.legend.engine.shared.core.url.StreamProvider;
v = virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: java.util.List getServiceVariables()>();
v = virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput: java.util.List getArgs()>();
v = interfaceinvoke v.<java.util.List: int size()>();
v = interfaceinvoke v.<java.util.List: int size()>();
if v == v goto label;
v = new java.lang.IllegalArgumentException;
v = interfaceinvoke v.<java.util.List: int size()>();
v = interfaceinvoke v.<java.util.List: int size()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int)>(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[])>("Unexpected number of parameters. Expected parameter size: \u, Passed parameter size: \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<java.util.List: int size()>();
v = virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder newExecutionBuilder(int)>(v);
v = virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder withServiceRunnerInput(org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput)>(v);
v = virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder withStreamProvider(org.finos.legend.engine.shared.core.url.StreamProvider)>(v);
v = 0;
label:
v = interfaceinvoke v.<java.util.List: int size()>();
if v >= v goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
if v == null goto label;
v = virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.ServiceVariable: java.lang.String getName()>();
v = virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder withParameter(java.lang.String,java.lang.Object)>(v, v);
label:
v = v + 1;
goto label;
label:
return v;
}
public void run(org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput, java.io.OutputStream)
{
java.io.OutputStream v;
org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput;
v := @parameter: java.io.OutputStream;
virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: void run(org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput,org.finos.legend.engine.shared.core.url.StreamProvider,java.io.OutputStream)>(v, null, v);
return;
}
public void run(org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput, org.finos.legend.engine.shared.core.url.StreamProvider, java.io.OutputStream)
{
java.io.OutputStream v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder v;
org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
org.finos.legend.engine.shared.core.url.StreamProvider v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput;
v := @parameter: org.finos.legend.engine.shared.core.url.StreamProvider;
v := @parameter: java.io.OutputStream;
v = specialinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder newExecutionBuilder(org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput,org.finos.legend.engine.shared.core.url.StreamProvider)>(v, v);
virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder: void executeToStream(java.io.OutputStream)>(v);
return;
}
public org.finos.legend.engine.plan.execution.result.Result execute(org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput, org.finos.legend.engine.shared.core.url.StreamProvider)
{
org.finos.legend.engine.plan.execution.result.Result v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder v;
org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
org.finos.legend.engine.shared.core.url.StreamProvider v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput;
v := @parameter: org.finos.legend.engine.shared.core.url.StreamProvider;
v = specialinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder newExecutionBuilder(org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput,org.finos.legend.engine.shared.core.url.StreamProvider)>(v, v);
v = virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder: org.finos.legend.engine.plan.execution.result.Result execute()>();
return v;
}
public java.util.List getGraphFetchCrossAssociationKeys()
{
org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan v;
java.util.List v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v = v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan plan>;
v = staticinvoke <org.finos.legend.engine.plan.execution.cache.graphFetch.GraphFetchCrossAssociationKeys: java.util.List graphFetchCrossAssociationKeysForPlan(org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan)>(v);
return v;
}
public void setGraphFetchBatchMemoryLimit(long)
{
org.finos.legend.engine.plan.execution.PlanExecutor v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
org.finos.legend.engine.plan.execution.graphFetch.GraphFetchExecutionConfiguration v;
long v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: long;
v = v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.plan.execution.PlanExecutor executor>;
v = new org.finos.legend.engine.plan.execution.graphFetch.GraphFetchExecutionConfiguration;
specialinvoke v.<org.finos.legend.engine.plan.execution.graphFetch.GraphFetchExecutionConfiguration: void <init>(long)>(v);
virtualinvoke v.<org.finos.legend.engine.plan.execution.PlanExecutor: void setGraphFetchExecutionConfiguration(org.finos.legend.engine.plan.execution.graphFetch.GraphFetchExecutionConfiguration)>(v);
return;
}
public java.lang.String toString()
{
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
java.lang.Class v;
java.lang.String v, v, v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: java.lang.String getServicePath()>();
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[])>("<\u \u0001>");
return v;
}
protected org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder newExecutionBuilder(int)
{
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder v, v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$MultiParameterExecutionBuilder v;
int v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: int;
lookupswitch(v)
{
case 0: goto label;
case 1: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder newNoParameterExecutionBuilder()>();
return v;
label:
v = virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder newSingleParameterExecutionBuilder()>();
return v;
label:
v = new org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$MultiParameterExecutionBuilder;
specialinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$MultiParameterExecutionBuilder: void <init>(org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor,int)>(v, v);
return v;
}
protected org.finos.legend.engine.language.pure.dsl.service.execution.ServiceVariable newServiceVariable(java.lang.String, java.lang.Class, int, java.lang.Integer)
{
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
java.lang.Integer v;
org.finos.legend.engine.language.pure.dsl.service.execution.ServiceVariable v;
org.eclipse.collections.api.block.function.Function v;
int v;
java.lang.Class v;
java.lang.String v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.domain.Multiplicity v;
boolean v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Class;
v := @parameter: int;
v := @parameter: java.lang.Integer;
v = virtualinvoke v.<java.lang.Class: boolean isPrimitive()>();
v = staticinvoke <org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$lambda_newServiceVariable_10a198f4_1__2: org.eclipse.collections.api.block.function.Function bootstrap$()>();
staticinvoke <org.finos.legend.engine.shared.core.operational.Assert: void assertFalse(boolean,org.eclipse.collections.api.block.function.Function)>(v, v);
v = new org.finos.legend.engine.language.pure.dsl.service.execution.ServiceVariable;
v = new org.finos.legend.engine.protocol.pure.v.model.packageableElement.domain.Multiplicity;
specialinvoke v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.domain.Multiplicity: void <init>(int,java.lang.Integer)>(v, v);
specialinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.ServiceVariable: void <init>(java.lang.String,java.lang.Class,org.finos.legend.engine.protocol.pure.v.model.packageableElement.domain.Multiplicity)>(v, v, v);
return v;
}
protected org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder newNoParameterExecutionBuilder()
{
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$NoParameterExecutionBuilder v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v = new org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$NoParameterExecutionBuilder;
specialinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$NoParameterExecutionBuilder: void <init>(org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor)>(v);
return v;
}
protected org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder newSingleParameterExecutionBuilder()
{
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$SingleParameterExecutionBuilder v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v = new org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$SingleParameterExecutionBuilder;
specialinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$SingleParameterExecutionBuilder: void <init>(org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor)>(v);
return v;
}
protected org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder newSingleParameterExecutionBuilder(java.lang.String, java.lang.Object)
{
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder v, v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
java.lang.Object v;
java.lang.String v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object;
v = virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder newSingleParameterExecutionBuilder()>();
v = virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder withParameter(java.lang.String,java.lang.Object)>(v, v);
return v;
}
protected org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$ExecutionBuilder newExecutionBuilder()
{
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$MultiParameterExecutionBuilder v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v = new org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$MultiParameterExecutionBuilder;
specialinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$MultiParameterExecutionBuilder: void <init>(org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor)>(v);
return v;
}
protected org.finos.legend.engine.plan.execution.result.Result execute(java.util.Map, org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput, org.finos.legend.engine.shared.core.url.StreamProvider)
{
org.finos.legend.engine.shared.core.identity.Identity v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
org.finos.legend.engine.shared.core.url.StreamProvider v;
java.util.function.Function v;
org.finos.legend.engine.plan.execution.PlanExecutor v;
java.util.Map v, v, v;
java.util.stream.Collector v;
org.finos.legend.engine.plan.execution.result.Result v;
java.util.Set v;
org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput v;
java.util.stream.Stream v, v;
org.finos.legend.engine.plan.execution.PlanExecutionContext v, v;
org.finos.legend.engine.language.pure.dsl.service.execution.OperationalContext v, v, v;
org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan v;
java.lang.Object v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: java.util.Map;
v := @parameter: org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput;
v := @parameter: org.finos.legend.engine.shared.core.url.StreamProvider;
v = null;
v = staticinvoke <org.finos.legend.engine.shared.core.identity.Identity: org.finos.legend.engine.shared.core.identity.Identity getAnonymousIdentity()>();
if v == null goto label;
v = virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput: org.finos.legend.engine.shared.core.identity.Identity getIdentity()>();
v = virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput: org.finos.legend.engine.language.pure.dsl.service.execution.OperationalContext getOperationalContext()>();
if v == null goto label;
v = virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput: org.finos.legend.engine.language.pure.dsl.service.execution.OperationalContext getOperationalContext()>();
v = virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.OperationalContext: java.util.Map getGraphFetchCrossAssociationKeysCacheConfig()>();
if v == null goto label;
v = virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput: org.finos.legend.engine.language.pure.dsl.service.execution.OperationalContext getOperationalContext()>();
v = virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.OperationalContext: java.util.Map getGraphFetchCrossAssociationKeysCacheConfig()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.stream.Stream stream()>();
v = staticinvoke <org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$lambda_execute_0__3: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v = new org.finos.legend.engine.plan.execution.PlanExecutionContext;
specialinvoke v.<org.finos.legend.engine.plan.execution.PlanExecutionContext: void <init>(java.util.List)>(v);
v = v;
label:
v = v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.plan.execution.PlanExecutor executor>;
v = v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan plan>;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.PlanExecutor: org.finos.legend.engine.plan.execution.result.Result execute(org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan,java.util.Map,org.finos.legend.engine.shared.core.url.StreamProvider,org.finos.legend.engine.shared.core.identity.Identity,org.finos.legend.engine.plan.execution.PlanExecutionContext)>(v, v, v, v, v);
return v;
}
protected void executeToStream(java.util.Map, org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput, org.finos.legend.engine.shared.core.url.StreamProvider, java.io.OutputStream)
{
java.io.OutputStream v;
org.finos.legend.engine.plan.execution.result.Result v;
org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
java.util.Map v;
org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat v;
org.finos.legend.engine.shared.core.url.StreamProvider v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: java.util.Map;
v := @parameter: org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput;
v := @parameter: org.finos.legend.engine.shared.core.url.StreamProvider;
v := @parameter: java.io.OutputStream;
v = virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.plan.execution.result.Result execute(java.util.Map,org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput,org.finos.legend.engine.shared.core.url.StreamProvider)>(v, v, v);
v = virtualinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.ServiceRunnerInput: org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat getSerializationFormat()>();
specialinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: void serializeResultToStream(org.finos.legend.engine.plan.execution.result.Result,org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat,java.io.OutputStream)>(v, v, v);
return;
}
private void serializeResultToStream(org.finos.legend.engine.plan.execution.result.Result, org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat, java.io.OutputStream)
{
java.lang.Throwable v;
byte[] v;
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor v;
org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat v;
java.lang.String v, v, v, v, v;
boolean v, v, v, v;
java.io.OutputStream v;
org.finos.legend.engine.plan.execution.result.Result v;
com.fasterxml.jackson.databind.ObjectMapper v;
java.io.IOException v;
java.lang.RuntimeException v, v, v;
java.lang.Class v;
java.lang.Object v;
v := @this: org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor;
v := @parameter: org.finos.legend.engine.plan.execution.result.Result;
v := @parameter: org.finos.legend.engine.plan.execution.result.serialization.SerializationFormat;
v := @parameter: java.io.OutputStream;
label:
v = v instanceof org.finos.legend.engine.plan.execution.result.ErrorResult;
if v == 0 goto label;
v = new java.lang.RuntimeException;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.result.ErrorResult: java.lang.String getMessage()>();
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[])>("Error: \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v instanceof org.finos.legend.engine.plan.execution.result.ConstantResult;
if v != 0 goto label;
v = v instanceof org.finos.legend.engine.plan.execution.result.StreamingResult;
if v == 0 goto label;
label:
v = v instanceof org.finos.legend.engine.plan.execution.result.ConstantResult;
if v == 0 goto label;
v = staticinvoke <org.finos.legend.engine.shared.core.ObjectMapperFactory: com.fasterxml.jackson.databind.ObjectMapper getNewStandardObjectMapper()>();
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.result.ConstantResult: java.lang.Object getValue()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.String writeValueAsString(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
virtualinvoke v.<java.io.OutputStream: void write(byte[])>(v);
goto label;
label:
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);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String,java.lang.Throwable)>("Error serializing result", v);
throw v;
label:
v = new java.lang.RuntimeException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getCanonicalName()>();
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[])>("Unknown result type: \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
virtualinvoke v.<org.finos.legend.engine.plan.execution.result.Result: void close()>();
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.finos.legend.engine.plan.execution.result.Result: void close()>();
throw v;
label:
return;
catch java.io.IOException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public static org.finos.legend.engine.shared.core.url.StreamProvider newStreamProvider(java.io.InputStream)
{
org.finos.legend.engine.shared.core.url.StreamProvider v;
java.io.InputStream v;
v := @parameter: java.io.InputStream;
v = staticinvoke <org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.shared.core.url.StreamProvider newStreamProvider(java.lang.String,java.io.InputStream)>("default", v);
return v;
}
public static org.finos.legend.engine.shared.core.url.StreamProvider newStreamProvider(byte[])
{
byte[] v;
org.finos.legend.engine.shared.core.url.StreamProvider v;
v := @parameter: byte[];
v = staticinvoke <org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.shared.core.url.StreamProvider newStreamProvider(java.lang.String,byte[])>("default", v);
return v;
}
public static org.finos.legend.engine.shared.core.url.StreamProvider newStreamProvider(java.lang.String)
{
java.lang.String v;
org.finos.legend.engine.shared.core.url.StreamProvider v;
v := @parameter: java.lang.String;
v = staticinvoke <org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.shared.core.url.StreamProvider newStreamProvider(java.lang.String,java.lang.String)>("default", v);
return v;
}
public static org.finos.legend.engine.shared.core.url.StreamProvider newStreamProvider(java.lang.String, java.io.InputStream)
{
java.lang.String v;
org.finos.legend.engine.shared.core.url.StreamProvider v;
java.io.InputStream v;
v := @parameter: java.lang.String;
v := @parameter: java.io.InputStream;
staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object,java.lang.String)>(v, "Stream id may not be null");
staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object,java.lang.String)>(v, "Stream may not be null");
v = staticinvoke <org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$lambda_newStreamProvider_1__4: org.finos.legend.engine.shared.core.url.StreamProvider bootstrap$(java.lang.String,java.io.InputStream)>(v, v);
return v;
}
public static org.finos.legend.engine.shared.core.url.StreamProvider newStreamProvider(java.lang.String, byte[])
{
byte[] v;
java.io.ByteArrayInputStream v;
java.lang.String v;
org.finos.legend.engine.shared.core.url.StreamProvider v;
v := @parameter: java.lang.String;
v := @parameter: byte[];
v = new java.io.ByteArrayInputStream;
specialinvoke v.<java.io.ByteArrayInputStream: void <init>(byte[])>(v);
v = staticinvoke <org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.shared.core.url.StreamProvider newStreamProvider(java.lang.String,java.io.InputStream)>(v, v);
return v;
}
public static org.finos.legend.engine.shared.core.url.StreamProvider newStreamProvider(java.lang.String, java.lang.String)
{
byte[] v;
java.nio.charset.Charset v;
java.lang.String v, v;
org.finos.legend.engine.shared.core.url.StreamProvider v;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = staticinvoke <org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.shared.core.url.StreamProvider newStreamProvider(java.lang.String,byte[])>(v, v);
return v;
}
public static org.finos.legend.engine.shared.core.url.StreamProvider newStreamProvider(java.util.Map)
{
org.finos.legend.engine.shared.core.url.StreamProvider v;
java.util.Map v;
v := @parameter: java.util.Map;
v = staticinvoke <org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$lambda_newStreamProvider_2__5: org.finos.legend.engine.shared.core.url.StreamProvider bootstrap$(java.util.Map)>(v);
return v;
}
public static org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$StreamProviderBuilder newStreamProviderBuilder()
{
org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$StreamProviderBuilder v;
v = new org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$StreamProviderBuilder;
specialinvoke v.<org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor$StreamProviderBuilder: void <init>()>();
return v;
}
private static java.io.InputStream checkStream(java.lang.String, java.io.InputStream)
{
java.lang.String v, v;
java.lang.IllegalArgumentException v;
java.io.InputStream v;
v := @parameter: java.lang.String;
v := @parameter: java.io.InputStream;
if v != null goto label;
v = new java.lang.IllegalArgumentException;
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[])>("Unknown stream: \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
protected static org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan readPlanFromResource(java.lang.String)
{
org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan v;
java.lang.String v;
v := @parameter: java.lang.String;
v = staticinvoke <org.finos.legend.engine.language.pure.dsl.service.execution.AbstractServicePlanExecutor: org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan readPlanFromResource(java.lang.ClassLoader,java.lang.String)>(null, v);
return v;
}
protected static org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan readPlanFromResource(java.lang.ClassLoader, java.lang.String)
{
java.lang.Throwable v;
java.net.URL v;
java.nio.charset.Charset v;
java.lang.Thread v;
java.lang.String v, v, v;
java.io.IOException v;
java.lang.RuntimeException v, v;
java.io.InputStreamReader v;
org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan v;
java.io.BufferedReader v;
java.lang.ClassLoader v, v;
java.io.InputStream v;
v := @parameter: java.lang.ClassLoader;
v := @parameter: java.lang.String;
if v != null goto label;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
v = virtualinvoke v.<java.lang.Thread: java.lang.ClassLoader getContextClassLoader()>();
goto label;
label:
v = v;
label:
v = virtualinvoke v.<java.lang.ClassLoader: java.net.URL getResource(java.lang.String)>(v);
if v != null goto label;
v = new java.lang.RuntimeException;
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[])>("Could not find execution plan: \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
v = new java.io.BufferedReader;
v = new java.io.InputStreamReader;
v = virtualinvoke v.<java.net.URL: java.io.InputStream openStream()>();
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
specialinvoke v.<java.io.InputStreamReader: void <init>(java.io.InputStream,java.nio.charset.Charset)>(v, v);
specialinvoke v.<java.io.BufferedReader: void <init>(java.io.Reader)>(v);
label:
v = staticinvoke <org.finos.legend.engine.plan.execution.PlanExecutor: org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan readExecutionPlan(java.io.Reader)>(v);
label:
virtualinvoke v.<java.io.Reader: void close()>();
label:
return v;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
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[])>("Error loading execution plan from resource: \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.Throwable from label to label with label;
catch java.io.IOException from label to label with label;
}
protected static org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan readPlanFromFile(java.nio.file.Path)
{
java.lang.Throwable v;
java.io.IOException v;
java.lang.RuntimeException v;
java.nio.charset.Charset v;
org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan v;
java.io.BufferedReader v;
java.lang.String v;
java.nio.file.Path v;
v := @parameter: java.nio.file.Path;
label:
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = staticinvoke <java.nio.file.Files: java.io.BufferedReader newBufferedReader(java.nio.file.Path,java.nio.charset.Charset)>(v, v);
label:
v = staticinvoke <org.finos.legend.engine.plan.execution.PlanExecutor: org.finos.legend.engine.protocol.pure.v.model.executionPlan.ExecutionPlan readExecutionPlan(java.io.Reader)>(v);
label:
if v == null goto label;
virtualinvoke v.<java.io.Reader: void close()>();
label:
return v;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.nio.file.Path)>(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[])>("Error loading execution plan from file: \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
catch java.lang.Throwable from label to label with label;
catch java.io.IOException from label to label with label;
}
}