public class org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper extends java.lang.Object
{
public static final java.lang.String DIGEST_FIELD_DEFAULT;
public static final java.lang.String BATCH_ID_FIELD_DEFAULT;
public static final org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimensionVisitor EXTRACT_TX_DATE_TIME_FIELDS;
public static final org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimensionVisitor TRANSACTION_MILESTONING_TIME_BASED;
public static final org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.auditing.AuditingVisitor EXTRACT_AUDIT_FIELD;
public void <init>()
{
org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper v;
v := @this: org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static org.finos.legend.engine.persistence.components.ingestmode.IngestMode 'from'(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget) throws java.lang.Exception
{
org.finos.legend.engine.persistence.components.ingestmode.AppendOnly v;
org.finos.legend.engine.persistence.components.ingestmode.NontemporalSnapshot v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality v;
int[] v;
int v, v;
org.finos.legend.engine.persistence.components.ingestmode.BitemporalSnapshot v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.DatasetType v;
boolean v, v, v, v;
org.finos.legend.engine.persistence.components.ingestmode.UnitemporalDelta v;
org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.updatesHandling.UpdatesHandling v;
java.lang.Exception v;
org.finos.legend.engine.testable.persistence.mapper.v.TemporalityType v;
org.finos.legend.engine.persistence.components.ingestmode.NontemporalDelta v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget v;
org.finos.legend.engine.persistence.components.ingestmode.BitemporalDelta v;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget;
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality getTemporality(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget)>(v);
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.DatasetType getDatasetType(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget)>(v);
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.testable.persistence.mapper.v.TemporalityType getTemporalityType(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality)>(v);
v = <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper$4: int[] $SwitchMap$org$finos$legend$engine$testable$persistence$mapper$v$TemporalityType>;
v = virtualinvoke v.<org.finos.legend.engine.testable.persistence.mapper.v.TemporalityType: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
default: goto label;
};
label:
v = v instanceof org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.Snapshot;
if v == 0 goto label;
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.NontemporalSnapshotMapper: org.finos.legend.engine.persistence.components.ingestmode.NontemporalSnapshot 'from'(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Nontemporal,org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.DatasetType)>(v, v);
return v;
label:
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Nontemporal: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.updatesHandling.UpdatesHandling updatesHandling>;
v = v instanceof org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.updatesHandling.Overwrite;
if v == 0 goto label;
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.NontemporalDeltaMapper: org.finos.legend.engine.persistence.components.ingestmode.NontemporalDelta 'from'(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Nontemporal,org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.DatasetType)>(v, v);
return v;
label:
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.AppendOnlyMapper: org.finos.legend.engine.persistence.components.ingestmode.AppendOnly 'from'(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Nontemporal,org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.DatasetType)>(v, v);
return v;
label:
v = v instanceof org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.Snapshot;
if v == 0 goto label;
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.UnitemporalSnapshotMapper: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot 'from'(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Unitemporal,org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.DatasetType)>(v, v);
return v;
label:
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.UnitemporalDeltaMapper: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalDelta 'from'(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Unitemporal,org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.DatasetType)>(v, v);
return v;
label:
v = v instanceof org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.Snapshot;
if v == 0 goto label;
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.BitemporalSnapshotMapper: org.finos.legend.engine.persistence.components.ingestmode.BitemporalSnapshot 'from'(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Bitemporal,org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.DatasetType)>(v, v);
return v;
label:
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.BitemporalDeltaMapper: org.finos.legend.engine.persistence.components.ingestmode.BitemporalDelta 'from'(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Bitemporal,org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.DatasetType)>(v, v);
return v;
label:
v = new java.lang.Exception;
specialinvoke v.<java.lang.Exception: void <init>(java.lang.String)>("Unsupported Temporality");
throw v;
}
public static org.finos.legend.engine.persistence.components.common.Datasets deriveDatasets(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget, org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, java.lang.String) throws java.lang.Exception
{
org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition v, v, v, v, v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.DatasetType v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.updatesHandling.UpdatesHandling v;
java.lang.Exception v;
org.finos.legend.engine.testable.persistence.mapper.v.MappingVisitors$DeriveStagingSchemaWithActionIndicatorStrategy v, v, v;
java.util.ArrayList v, v;
java.lang.String v, v, v, v, v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder v, v, v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder v, v, v, v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition v, v, v, v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget v;
org.finos.legend.engine.persistence.components.common.Datasets v, v, v, v, v;
int[] v;
boolean v, v, v, v, v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.sourcederived.SourceDerivedDimension v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder v, v, v, v, v, v;
java.util.List v, v, v;
java.util.Optional v, v, v, v, v, v, v, v, v, v, v, v, v;
org.finos.legend.engine.testable.persistence.mapper.v.MappingVisitors$DeriveStagingSchemaWithProcessingDimension v, v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimension v, v;
java.util.HashSet v, v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference v, v, v, v, v, v, v, v, v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality v;
int v, v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v, v, v, v, v;
org.finos.legend.engine.testable.persistence.mapper.v.MappingVisitors$DeriveStagingSchemaWithSourceDimension v;
org.finos.legend.engine.testable.persistence.mapper.v.TemporalityType v;
java.lang.Object v, v, v, v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.actionindicator.ActionIndicatorFields v, v, v;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget;
v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset;
v := @parameter: java.lang.String;
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality getTemporality(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget)>(v);
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.DatasetType getDatasetType(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget)>(v);
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.testable.persistence.mapper.v.TemporalityType getTemporalityType(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality)>(v);
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition schema()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder builder()>();
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference datasetReference()>();
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference: java.util.Optional name()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder name(java.lang.String)>(v);
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference datasetReference()>();
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference: java.util.Optional database()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder database(java.util.Optional)>(v);
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference datasetReference()>();
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference: java.util.Optional group()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder group(java.util.Optional)>(v);
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference datasetReference()>();
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference: java.util.Optional alias()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object orElse(java.lang.Object)>(null);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder alias(java.lang.String)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition: java.util.List fields()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder addAllFields(java.lang.Iterable)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition: java.util.List indexes()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder addAllIndexes(java.lang.Iterable)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition: java.util.Optional shardSpecification()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder shardSpecification(java.util.Optional)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition: java.util.Optional columnStoreSpecification()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder columnStoreSpecification(java.util.Optional)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference: org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder builder()>();
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference datasetReference()>();
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference: java.util.Optional name()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = <org.finos.legend.engine.testable.persistence.mapper.v.DatasetMapper: java.lang.String STAGING_SUFFIX>;
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[])>("\u0001\u0001");
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder name(java.lang.String)>(v);
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference datasetReference()>();
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference: java.util.Optional database()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder database(java.util.Optional)>(v);
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference datasetReference()>();
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference: java.util.Optional group()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder group(java.util.Optional)>(v);
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference datasetReference()>();
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference: java.util.Optional alias()>();
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v == 0 goto label;
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference datasetReference()>();
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference: java.util.Optional alias()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = <org.finos.legend.engine.testable.persistence.mapper.v.DatasetMapper: java.lang.String STAGING_SUFFIX>;
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[])>("\u0001\u0001");
goto label;
label:
v = null;
label:
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder alias(java.lang.String)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder data(java.lang.String)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition: java.util.List indexes()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder addAllIndexes(java.lang.Iterable)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition: java.util.Optional shardSpecification()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder shardSpecification(java.util.Optional)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition: java.util.Optional columnStoreSpecification()>();
virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder columnStoreSpecification(java.util.Optional)>(v);
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper$4: int[] $SwitchMap$org$finos$legend$engine$testable$persistence$mapper$v$TemporalityType>;
v = virtualinvoke v.<org.finos.legend.engine.testable.persistence.mapper.v.TemporalityType: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
default: goto label;
};
label:
v = v instanceof org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.Snapshot;
if v == 0 goto label;
staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: void ignoreAuditField(java.util.Set,org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Nontemporal)>(v, v);
staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: void ignoreBatchIdField(java.util.Set)>(v);
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset getStagingDataset(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition,org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder,java.util.Set,java.util.Set)>(v, v, v, v);
v = staticinvoke <org.finos.legend.engine.persistence.components.common.Datasets: org.finos.legend.engine.persistence.components.common.Datasets of(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset,org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset)>(v, v);
return v;
label:
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Nontemporal: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.updatesHandling.UpdatesHandling updatesHandling>;
v = v instanceof org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.updatesHandling.Overwrite;
if v == 0 goto label;
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.Delta: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.actionindicator.ActionIndicatorFields actionIndicator>;
v = new org.finos.legend.engine.testable.persistence.mapper.v.MappingVisitors$DeriveStagingSchemaWithActionIndicatorStrategy;
specialinvoke v.<org.finos.legend.engine.testable.persistence.mapper.v.MappingVisitors$DeriveStagingSchemaWithActionIndicatorStrategy: void <init>(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition,java.util.Set)>(v, v);
virtualinvoke v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.actionindicator.ActionIndicatorFields: java.lang.Object accept(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.actionindicator.ActionIndicatorFieldsVisitor)>(v);
staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: void ignoreAuditField(java.util.Set,org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Nontemporal)>(v, v);
staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: void ignoreBatchIdField(java.util.Set)>(v);
staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: void enrichMainSchemaWithDigest(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition,org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder)>(v, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder schema(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition build()>();
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset getStagingDataset(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition,org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder,java.util.Set,java.util.Set)>(v, v, v, v);
v = staticinvoke <org.finos.legend.engine.persistence.components.common.Datasets: org.finos.legend.engine.persistence.components.common.Datasets of(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset,org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset)>(v, v);
return v;
label:
staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: void ignoreAuditField(java.util.Set,org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Nontemporal)>(v, v);
staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: void ignoreBatchIdField(java.util.Set)>(v);
staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: void enrichMainSchemaWithDigest(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition,org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder)>(v, v);
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset getStagingDataset(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition,org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder,java.util.Set,java.util.Set)>(v, v, v, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder schema(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition build()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.common.Datasets: org.finos.legend.engine.persistence.components.common.Datasets of(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset,org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset)>(v, v);
return v;
label:
v = v instanceof org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.Delta;
if v == 0 goto label;
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.Delta: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.actionindicator.ActionIndicatorFields actionIndicator>;
v = new org.finos.legend.engine.testable.persistence.mapper.v.MappingVisitors$DeriveStagingSchemaWithActionIndicatorStrategy;
specialinvoke v.<org.finos.legend.engine.testable.persistence.mapper.v.MappingVisitors$DeriveStagingSchemaWithActionIndicatorStrategy: void <init>(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition,java.util.Set)>(v, v);
virtualinvoke v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.actionindicator.ActionIndicatorFields: java.lang.Object accept(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.actionindicator.ActionIndicatorFieldsVisitor)>(v);
label:
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Unitemporal: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimension processingDimension>;
v = new org.finos.legend.engine.testable.persistence.mapper.v.MappingVisitors$DeriveStagingSchemaWithProcessingDimension;
specialinvoke v.<org.finos.legend.engine.testable.persistence.mapper.v.MappingVisitors$DeriveStagingSchemaWithProcessingDimension: void <init>(java.util.Set)>(v);
virtualinvoke v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimension: java.lang.Object accept(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimensionVisitor)>(v);
staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: void enrichMainSchemaWithDigest(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition,org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder)>(v, v);
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset getStagingDataset(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition,org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder,java.util.Set,java.util.Set)>(v, v, v, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder schema(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition build()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.common.Datasets: org.finos.legend.engine.persistence.components.common.Datasets of(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset,org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset)>(v, v);
return v;
label:
v = v instanceof org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.Delta;
if v == 0 goto label;
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.Delta: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.actionindicator.ActionIndicatorFields actionIndicator>;
v = new org.finos.legend.engine.testable.persistence.mapper.v.MappingVisitors$DeriveStagingSchemaWithActionIndicatorStrategy;
specialinvoke v.<org.finos.legend.engine.testable.persistence.mapper.v.MappingVisitors$DeriveStagingSchemaWithActionIndicatorStrategy: void <init>(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition,java.util.Set)>(v, v);
virtualinvoke v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.actionindicator.ActionIndicatorFields: java.lang.Object accept(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.actionindicator.ActionIndicatorFieldsVisitor)>(v);
label:
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Bitemporal: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimension processingDimension>;
v = new org.finos.legend.engine.testable.persistence.mapper.v.MappingVisitors$DeriveStagingSchemaWithProcessingDimension;
specialinvoke v.<org.finos.legend.engine.testable.persistence.mapper.v.MappingVisitors$DeriveStagingSchemaWithProcessingDimension: void <init>(java.util.Set)>(v);
virtualinvoke v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimension: java.lang.Object accept(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimensionVisitor)>(v);
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Bitemporal: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.sourcederived.SourceDerivedDimension sourceDerivedDimension>;
v = new org.finos.legend.engine.testable.persistence.mapper.v.MappingVisitors$DeriveStagingSchemaWithSourceDimension;
specialinvoke v.<org.finos.legend.engine.testable.persistence.mapper.v.MappingVisitors$DeriveStagingSchemaWithSourceDimension: void <init>(java.util.Set,java.util.Set,org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition)>(v, v, v);
virtualinvoke v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.sourcederived.SourceDerivedDimension: java.lang.Object accept(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.sourcederived.SourceDerivedDimensionVisitor)>(v);
staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: void enrichMainSchemaWithDigest(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition,org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder)>(v, v);
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset getStagingDataset(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition,org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder,java.util.Set,java.util.Set)>(v, v, v, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder schema(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition build()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.common.Datasets: org.finos.legend.engine.persistence.components.common.Datasets of(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset,org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset)>(v, v);
return v;
label:
v = new java.lang.Exception;
specialinvoke v.<java.lang.Exception: void <init>(java.lang.String)>("Unsupported Temporality");
throw v;
}
private static org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset getStagingDataset(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition, org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder, java.util.Set, java.util.Set)
{
java.util.Set v, v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder v, v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition v, v;
java.util.List v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder v, v;
v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition;
v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder;
v := @parameter: java.util.Set;
v := @parameter: java.util.Set;
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: java.util.List getFilteredStagingFields(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition,java.util.Set,java.util.Set)>(v, v, v);
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder addAllFields(java.lang.Iterable)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder schema(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.JsonExternalDatasetReference build()>();
return v;
}
private static java.util.List getFilteredStagingFields(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition, java.util.Set, java.util.Set)
{
java.util.function.Predicate v;
java.util.Set v, v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition v;
java.util.List v;
java.util.stream.Stream v, v;
java.lang.Object v;
java.util.stream.Collector v;
v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition;
v := @parameter: java.util.Set;
v := @parameter: java.util.Set;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition: java.util.List fields()>();
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper$lambda_getFilteredStagingFields_0__41: java.util.function.Predicate bootstrap$(java.util.Set)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(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);
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
return v;
}
private static void enrichMainSchemaWithDigest(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition, org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder)
{
org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Field$Builder v, v, v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Field v;
java.util.Optional v, v;
boolean v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder v;
v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition;
v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder;
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.DatasetMapper: boolean isFieldNamePresent(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition,java.lang.String)>(v, "DIGEST");
if v != 0 goto label;
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.datasets.Field: org.finos.legend.engine.persistence.components.logicalplan.datasets.Field$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Field$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.Field$Builder name(java.lang.String)>("DIGEST");
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType STRING>;
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType: org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType of(org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType,java.util.Optional,java.util.Optional)>(v, v, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Field$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.Field$Builder type(org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Field$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.Field build()>();
virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition$Builder addFields(org.finos.legend.engine.persistence.components.logicalplan.datasets.Field)>(v);
label:
return;
}
public static java.util.Set getFieldsToIgnoreForComparison(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget) throws java.lang.Exception
{
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutput v;
java.util.Set v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.DatasetType v;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget;
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutput serviceOutput>;
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutput: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.DatasetType datasetType>;
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality getTemporality(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget)>(v);
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: java.util.Set extractFieldsToExclude(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.DatasetType,org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality)>(v, v);
return v;
}
private static java.util.Set extractFieldsToExclude(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.DatasetType, org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality) throws java.lang.Exception
{
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimensionVisitor v, v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimension v, v;
java.lang.Exception v;
java.util.HashSet v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality v;
int[] v;
org.finos.legend.engine.testable.persistence.mapper.v.TemporalityType v;
int v, v;
java.lang.Object v, v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.DatasetType v;
boolean v;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.DatasetType;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality;
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.testable.persistence.mapper.v.TemporalityType getTemporalityType(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality)>(v);
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper$4: int[] $SwitchMap$org$finos$legend$engine$testable$persistence$mapper$v$TemporalityType>;
v = virtualinvoke v.<org.finos.legend.engine.testable.persistence.mapper.v.TemporalityType: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
default: goto label;
};
label:
v = v instanceof org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.Snapshot;
if v == 0 goto label;
staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: void ignoreAuditField(java.util.Set,org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Nontemporal)>(v, v);
return v;
label:
staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: void ignoreAuditField(java.util.Set,org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Nontemporal)>(v, v);
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>("DIGEST");
return v;
label:
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Unitemporal: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimension processingDimension>;
v = <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimensionVisitor EXTRACT_TX_DATE_TIME_FIELDS>;
v = virtualinvoke v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimension: java.lang.Object accept(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimensionVisitor)>(v);
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>("DIGEST");
return v;
label:
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Bitemporal: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimension processingDimension>;
v = <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimensionVisitor EXTRACT_TX_DATE_TIME_FIELDS>;
v = virtualinvoke v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimension: java.lang.Object accept(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimensionVisitor)>(v);
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>("DIGEST");
return v;
label:
v = new java.lang.Exception;
specialinvoke v.<java.lang.Exception: void <init>(java.lang.String)>("Unsupported temporality");
throw v;
}
private static void ignoreAuditField(java.util.Set, org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Nontemporal)
{
java.util.Set v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.auditing.AuditingVisitor v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Nontemporal v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.auditing.Auditing v, v;
java.lang.Object v, v;
boolean v;
v := @parameter: java.util.Set;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Nontemporal;
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Nontemporal: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.auditing.Auditing auditing>;
if v == null goto label;
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Nontemporal: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.auditing.Auditing auditing>;
v = <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.auditing.AuditingVisitor EXTRACT_AUDIT_FIELD>;
v = virtualinvoke v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.auditing.Auditing: java.lang.Object accept(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.auditing.AuditingVisitor)>(v);
goto label;
label:
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
label:
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v == 0 goto label;
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
return;
}
private static void ignoreBatchIdField(java.util.Set)
{
java.util.Set v;
v := @parameter: java.util.Set;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>("BATCH_ID");
return;
}
public static boolean isTransactionMilestoningTimeBased(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget) throws java.lang.Exception
{
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget v;
boolean v;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget;
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality getTemporality(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget)>(v);
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: boolean isTransactionMilestoningTimeBased(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality)>(v);
return v;
}
private static boolean isTransactionMilestoningTimeBased(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality) throws java.lang.Exception
{
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimensionVisitor v, v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimension v, v;
java.lang.Exception v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality v;
int[] v;
org.finos.legend.engine.testable.persistence.mapper.v.TemporalityType v;
int v, v;
java.lang.Object v, v;
boolean v, v;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality;
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.testable.persistence.mapper.v.TemporalityType getTemporalityType(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality)>(v);
v = <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper$4: int[] $SwitchMap$org$finos$legend$engine$testable$persistence$mapper$v$TemporalityType>;
v = virtualinvoke v.<org.finos.legend.engine.testable.persistence.mapper.v.TemporalityType: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
default: goto label;
};
label:
return 0;
label:
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Unitemporal: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimension processingDimension>;
v = <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimensionVisitor TRANSACTION_MILESTONING_TIME_BASED>;
v = virtualinvoke v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimension: java.lang.Object accept(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimensionVisitor)>(v);
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
return v;
label:
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Bitemporal: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimension processingDimension>;
v = <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimensionVisitor TRANSACTION_MILESTONING_TIME_BASED>;
v = virtualinvoke v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimension: java.lang.Object accept(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimensionVisitor)>(v);
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
return v;
label:
v = new java.lang.Exception;
specialinvoke v.<java.lang.Exception: void <init>(java.lang.String)>("Unsupported temporality");
throw v;
}
public static org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.DatasetType getDatasetType(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget)
{
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutput v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.DatasetType v;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget;
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutput serviceOutput>;
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutput: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.dataset.DatasetType datasetType>;
return v;
}
public static org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality getTemporality(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget) throws java.lang.Exception
{
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.sink.PersistenceTarget v, v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget v;
java.lang.Exception v;
boolean v;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget;
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.sink.PersistenceTarget persistenceTarget>;
v = v instanceof org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.sink.RelationalPersistenceTarget;
if v == 0 goto label;
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.sink.PersistenceTarget persistenceTarget>;
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.sink.RelationalPersistenceTarget: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality temporality>;
return v;
label:
v = new java.lang.Exception;
specialinvoke v.<java.lang.Exception: void <init>(java.lang.String)>("Test Runner only accepts Relational Target");
throw v;
}
public static org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget getServiceOutputTarget(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.Persistence, org.finos.legend.engine.protocol.pure.v.model.valueSpecification.raw.classInstance.path.Path) throws java.lang.Exception
{
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutput v;
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.Persistence v;
int v;
java.lang.String v, v, v, v;
boolean v, v, v;
java.util.Iterator v;
java.lang.Exception v, v;
org.finos.legend.engine.protocol.pure.v.model.valueSpecification.raw.classInstance.path.Path v, v;
java.util.List v, v, v;
java.lang.Object v, v;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.Persistence;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.valueSpecification.raw.classInstance.path.Path;
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.Persistence: java.util.List serviceOutputTargets>;
v = interfaceinvoke v.<java.util.List: int size()>();
if v != 1 goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
return v;
label:
if v != null goto label;
v = new java.lang.Exception;
specialinvoke v.<java.lang.Exception: void <init>(java.lang.String)>("Graph fetch service-outputs require path parameter within tests");
throw v;
label:
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: java.util.List getPropertyList(org.finos.legend.engine.protocol.pure.v.model.valueSpecification.raw.classInstance.path.Path)>(v);
v = interfaceinvoke v.<java.util.List: 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 = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutputTarget: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.ServiceOutput serviceOutput>;
v = v.<org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.service.output.GraphFetchServiceOutput: org.finos.legend.engine.protocol.pure.v.model.valueSpecification.raw.classInstance.path.Path path>;
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: java.util.List getPropertyList(org.finos.legend.engine.protocol.pure.v.model.valueSpecification.raw.classInstance.path.Path)>(v);
v = v.<org.finos.legend.engine.protocol.pure.v.model.valueSpecification.raw.classInstance.path.Path: java.lang.String name>;
v = v.<org.finos.legend.engine.protocol.pure.v.model.valueSpecification.raw.classInstance.path.Path: java.lang.String name>;
if v != v goto label;
v = v.<org.finos.legend.engine.protocol.pure.v.model.valueSpecification.raw.classInstance.path.Path: java.lang.String startType>;
v = v.<org.finos.legend.engine.protocol.pure.v.model.valueSpecification.raw.classInstance.path.Path: java.lang.String startType>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<java.util.List: boolean containsAll(java.util.Collection)>(v);
if v == 0 goto label;
return v;
label:
v = new java.lang.Exception;
specialinvoke v.<java.lang.Exception: void <init>(java.lang.String)>("Exception : Cannot find a serviceOutputTarget with the matching path");
throw v;
}
public static java.util.List getPropertyList(org.finos.legend.engine.protocol.pure.v.model.valueSpecification.raw.classInstance.path.Path)
{
java.util.function.Consumer v;
org.finos.legend.engine.protocol.pure.v.model.valueSpecification.raw.classInstance.path.Path v;
java.util.List v;
java.util.ArrayList v;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.valueSpecification.raw.classInstance.path.Path;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = v.<org.finos.legend.engine.protocol.pure.v.model.valueSpecification.raw.classInstance.path.Path: java.util.List path>;
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper$lambda_getPropertyList_1__42: java.util.function.Consumer bootstrap$(java.util.List)>(v);
interfaceinvoke v.<java.util.List: void forEach(java.util.function.Consumer)>(v);
return v;
}
public static org.finos.legend.engine.testable.persistence.mapper.v.TemporalityType getTemporalityType(org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality)
{
org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality v;
org.finos.legend.engine.testable.persistence.mapper.v.TemporalityType v;
java.lang.Class v;
java.lang.String v;
v := @parameter: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.Temporality;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v = staticinvoke <org.finos.legend.engine.testable.persistence.mapper.v.TemporalityType: org.finos.legend.engine.testable.persistence.mapper.v.TemporalityType valueOf(java.lang.String)>(v);
return v;
}
static void <clinit>()
{
org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper$1 v;
org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper$2 v;
org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper$3 v;
v = new org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper$1;
specialinvoke v.<org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper$1: void <init>()>();
<org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimensionVisitor EXTRACT_TX_DATE_TIME_FIELDS> = v;
v = new org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper$2;
specialinvoke v.<org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper$2: void <init>()>();
<org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.processing.ProcessingDimensionVisitor TRANSACTION_MILESTONING_TIME_BASED> = v;
v = new org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper$3;
specialinvoke v.<org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper$3: void <init>()>();
<org.finos.legend.engine.testable.persistence.mapper.v.IngestModeMapper: org.finos.legend.engine.protocol.pure.v.model.packageableElement.persistence.relational.temporality.auditing.AuditingVisitor EXTRACT_AUDIT_FIELD> = v;
return;
}
}