public class org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7ExecutionNodeExecutor extends java.lang.Object implements org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNodeVisitor
{
private final org.finos.legend.engine.shared.core.identity.Identity identity;
private final org.finos.legend.engine.plan.execution.nodes.state.ExecutionState executionState;
private final org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7StoreState state;
public void <init>(org.finos.legend.engine.shared.core.identity.Identity, org.finos.legend.engine.plan.execution.nodes.state.ExecutionState, org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7StoreState)
{
org.finos.legend.engine.shared.core.identity.Identity v;
org.finos.legend.engine.plan.execution.nodes.state.ExecutionState v;
org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7ExecutionNodeExecutor v;
org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7StoreState v;
v := @this: org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7ExecutionNodeExecutor;
v := @parameter: org.finos.legend.engine.shared.core.identity.Identity;
v := @parameter: org.finos.legend.engine.plan.execution.nodes.state.ExecutionState;
v := @parameter: org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7StoreState;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7ExecutionNodeExecutor: org.finos.legend.engine.shared.core.identity.Identity identity> = v;
v.<org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7ExecutionNodeExecutor: org.finos.legend.engine.plan.execution.nodes.state.ExecutionState executionState> = v;
v.<org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7ExecutionNodeExecutor: org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7StoreState state> = v;
return;
}
public org.finos.legend.engine.plan.execution.result.Result visit(org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode)
{
org.finos.legend.engine.plan.execution.stores.StoreType v;
java.lang.IllegalStateException v, v;
org.finos.legend.engine.protocol.store.elasticsearch.v.metamodel.runtime.Elasticsearch7StoreURLSourceSpecification v;
org.finos.legend.engine.shared.core.identity.Identity v;
org.finos.legend.engine.plan.execution.nodes.state.ExecutionState v, v;
org.apache.http.client.protocol.HttpClientContext v;
org.finos.legend.engine.plan.execution.stores.StoreExecutionState v;
org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7ExecutionNodeExecutor v;
org.finos.legend.engine.protocol.store.elasticsearch.v.specification.types.RequestBase v;
org.apache.http.client.HttpClient v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.authentication.specification.AuthenticationSpecification v;
java.lang.String v;
java.net.URI v;
org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode v;
boolean v;
org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7StoreExecutorConfiguration v;
org.finos.legend.engine.protocol.store.elasticsearch.v.metamodel.runtime.Elasticsearch7StoreConnection v;
org.finos.legend.engine.plan.execution.stores.elasticsearch.v.result.ExecutionRequestVisitor v;
com.fasterxml.jackson.databind.ObjectMapper v;
java.io.IOException v;
org.finos.legend.authentication.credentialprovider.CredentialProviderProvider v;
org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7StoreState v, v;
java.util.List v;
java.lang.Object v, v;
v := @this: org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7ExecutionNodeExecutor;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.executionPlan.nodes.ExecutionNode;
v = v instanceof org.finos.legend.engine.protocol.store.elasticsearch.v.metamodel.executionPlan.Elasticsearch7RequestExecutionNode;
if v == 0 goto label;
v = v.<org.finos.legend.engine.protocol.store.elasticsearch.v.metamodel.executionPlan.Elasticsearch7RequestExecutionNode: org.finos.legend.engine.protocol.store.elasticsearch.v.metamodel.runtime.Elasticsearch7StoreConnection connection>;
v = v.<org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7ExecutionNodeExecutor: org.finos.legend.engine.shared.core.identity.Identity identity>;
v = v.<org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7ExecutionNodeExecutor: org.finos.legend.engine.plan.execution.nodes.state.ExecutionState executionState>;
v = <org.finos.legend.engine.plan.execution.stores.StoreType: org.finos.legend.engine.plan.execution.stores.StoreType ESv7>;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.nodes.state.ExecutionState: org.finos.legend.engine.plan.execution.stores.StoreExecutionState getStoreExecutionState(org.finos.legend.engine.plan.execution.stores.StoreType)>(v);
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7StoreExecutionState: org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7StoreExecutorConfiguration getStoreExecutionConfiguration()>();
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7StoreExecutorConfiguration: org.finos.legend.authentication.credentialprovider.CredentialProviderProvider getCredentialProviderProvider()>();
v = v.<org.finos.legend.engine.protocol.store.elasticsearch.v.metamodel.runtime.Elasticsearch7StoreConnection: org.finos.legend.engine.protocol.pure.v.model.packageableElement.authentication.specification.AuthenticationSpecification authSpec>;
v = v.<org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7ExecutionNodeExecutor: org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7StoreState state>;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7StoreState: java.util.List getProviders()>();
v = staticinvoke <org.finos.legend.engine.plan.execution.stores.elasticsearch.v.connection.ElasticsearchHttpContextUtil: org.apache.http.client.protocol.HttpClientContext authToHttpContext(org.finos.legend.engine.shared.core.identity.Identity,org.finos.legend.authentication.credentialprovider.CredentialProviderProvider,org.finos.legend.engine.protocol.pure.v.model.packageableElement.authentication.specification.AuthenticationSpecification,java.util.List)>(v, v, v, v);
label:
v = staticinvoke <org.finos.legend.engine.shared.core.ObjectMapperFactory: com.fasterxml.jackson.databind.ObjectMapper getNewStandardObjectMapperWithPureProtocolExtensionSupports()>();
v = v.<org.finos.legend.engine.protocol.store.elasticsearch.v.metamodel.executionPlan.Elasticsearch7RequestExecutionNode: org.finos.legend.engine.protocol.store.elasticsearch.v.specification.types.RequestBase request>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.String writeValueAsString(java.lang.Object)>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(java.lang.String,java.lang.Class)>(v, class "Lorg/finos/legend/engine/protocol/store/elasticsearch/v7/specification/types/RequestBase;");
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("RequestBase failed to initialize due to issues in deep-copy");
throw v;
label:
v = new org.finos.legend.engine.plan.execution.stores.elasticsearch.v.result.ExecutionRequestVisitor;
v = v.<org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7ExecutionNodeExecutor: org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7StoreState state>;
v = virtualinvoke v.<org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7StoreState: org.apache.http.client.HttpClient getClient()>();
v = v.<org.finos.legend.engine.protocol.store.elasticsearch.v.metamodel.runtime.Elasticsearch7StoreConnection: org.finos.legend.engine.protocol.store.elasticsearch.v.metamodel.runtime.Elasticsearch7StoreURLSourceSpecification sourceSpec>;
v = v.<org.finos.legend.engine.protocol.store.elasticsearch.v.metamodel.runtime.Elasticsearch7StoreURLSourceSpecification: java.net.URI url>;
v = v.<org.finos.legend.engine.plan.execution.stores.elasticsearch.v.plugin.ElasticsearchV7ExecutionNodeExecutor: org.finos.legend.engine.plan.execution.nodes.state.ExecutionState executionState>;
specialinvoke v.<org.finos.legend.engine.plan.execution.stores.elasticsearch.v.result.ExecutionRequestVisitor: void <init>(org.apache.http.client.HttpClient,org.apache.http.client.protocol.HttpClientContext,java.net.URI,org.finos.legend.engine.protocol.store.elasticsearch.v.metamodel.executionPlan.Elasticsearch7RequestExecutionNode,org.finos.legend.engine.plan.execution.nodes.state.ExecutionState)>(v, v, v, v, v);
v = virtualinvoke v.<org.finos.legend.engine.protocol.store.elasticsearch.v.specification.types.RequestBase: java.lang.Object accept(org.finos.legend.engine.protocol.store.elasticsearch.v.specification.types.RequestBaseVisitor)>(v);
return v;
label:
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("should not get here");
throw v;
catch java.io.IOException from label to label with label;
}
}