public abstract class org.finos.legend.engine.persistence.components.planner.Planner extends java.lang.Object { private final org.finos.legend.engine.persistence.components.common.Datasets datasets; private final org.finos.legend.engine.persistence.components.ingestmode.IngestMode ingestMode; protected final org.finos.legend.engine.persistence.components.util.MetadataUtils metadataUtils; private final org.finos.legend.engine.persistence.components.planner.PlannerOptions plannerOptions; protected final java.util.Set capabilities; protected final java.util.List primaryKeys; protected final org.finos.legend.engine.persistence.components.logicalplan.values.StringValue mainTableName; protected final org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp batchStartTimestamp; protected final org.finos.legend.engine.persistence.components.logicalplan.values.BatchEndTimestamp batchEndTimestamp; private final java.util.Optional tempStagingDataset; private final java.util.Optional tempStagingDatasetWithoutPks; private final org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset effectiveStagingDataset; protected final boolean isTempTableNeededForStaging; protected static final org.finos.legend.engine.persistence.components.planner.Planner$AuditEnabled AUDIT_ENABLED; void (org.finos.legend.engine.persistence.components.common.Datasets, org.finos.legend.engine.persistence.components.ingestmode.IngestMode, org.finos.legend.engine.persistence.components.planner.PlannerOptions, java.util.Set) { org.finos.legend.engine.persistence.components.ingestmode.IngestMode v, v; org.finos.legend.engine.persistence.components.common.Datasets v, v; org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp v; org.finos.legend.engine.persistence.components.util.MetadataUtils v; org.finos.legend.engine.persistence.components.ingestmode.deduplication.DeduplicationStrategy v; boolean v, v, v; org.finos.legend.engine.persistence.components.util.MetadataDataset v; org.finos.legend.engine.persistence.components.ingestmode.versioning.VersioningStrategy v, v, v; java.util.Set v; java.util.List v, v; java.util.Optional v, v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.values.StringValue v; org.finos.legend.engine.persistence.components.ingestmode.versioning.VersioningVisitors$ValidateDedupAndVersioningCombination v; java.util.function.Supplier v, v; org.finos.legend.engine.persistence.components.logicalplan.values.BatchEndTimestamp v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference v; org.finos.legend.engine.persistence.components.planner.PlannerOptions$Builder v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v, v, v; org.finos.legend.engine.persistence.components.planner.PlannerOptions v, v; org.finos.legend.engine.persistence.components.planner.Planner v; org.finos.legend.engine.persistence.components.planner.Planner$ValidatePrimaryKeysForVersioningStrategy v; java.util.function.Consumer v; org.finos.legend.engine.persistence.components.util.MetadataDataset$Builder v; java.lang.Object v, v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v := @parameter: org.finos.legend.engine.persistence.components.common.Datasets; v := @parameter: org.finos.legend.engine.persistence.components.ingestmode.IngestMode; v := @parameter: org.finos.legend.engine.persistence.components.planner.PlannerOptions; v := @parameter: java.util.Set; specialinvoke v.()>(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v; goto label; label: v = staticinvoke (); v = virtualinvoke v.(); v = virtualinvoke v.(v); label: v. = v; v. = v; v = new org.finos.legend.engine.persistence.components.util.MetadataUtils; v = virtualinvoke v.(); v = staticinvoke (); v = virtualinvoke v.(v); specialinvoke v.(org.finos.legend.engine.persistence.components.util.MetadataDataset)>(v); v. = v; if v != null goto label; v = staticinvoke (); v = virtualinvoke v.(); goto label; label: v = v; label: v. = v; v = staticinvoke (v); v. = v; v = specialinvoke v.(); v. = v; v = specialinvoke v.(); v. = v; v = v.; if v == 0 goto label; v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); label: v. = v; v. = v; v = specialinvoke v.(); v. = v; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = virtualinvoke v.(v); v = staticinvoke (v); v. = v; v = ; v. = v; v = ; v. = v; v = interfaceinvoke v.(); v = new org.finos.legend.engine.persistence.components.ingestmode.versioning.VersioningVisitors$ValidateDedupAndVersioningCombination; v = interfaceinvoke v.(); specialinvoke v.(org.finos.legend.engine.persistence.components.ingestmode.deduplication.DeduplicationStrategy)>(v); interfaceinvoke v.(v); v = interfaceinvoke v.(); v = new org.finos.legend.engine.persistence.components.planner.Planner$ValidatePrimaryKeysForVersioningStrategy; v = v.; v = staticinvoke (v); specialinvoke v.(java.util.List,java.util.function.Consumer)>(v, v); interfaceinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v); v = virtualinvoke v.(); virtualinvoke v.(v, v); return; } private java.util.Optional getTempStagingDataset() { org.finos.legend.engine.persistence.components.ingestmode.IngestMode v; org.finos.legend.engine.persistence.components.planner.Planner v; java.util.Optional v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v; java.lang.String v; org.finos.legend.engine.persistence.components.planner.PlannerOptions v; boolean v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v = staticinvoke (); v = v.; if v == 0 goto label; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v, v); v = staticinvoke (v); label: return v; } private java.util.Optional getTempStagingDatasetWithoutPks() { org.finos.legend.engine.persistence.components.planner.Planner v; java.util.Optional v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v; boolean v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v = staticinvoke (); v = v.; if v == 0 goto label; v = virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (v); label: return v; } private java.util.List findCommonPrimaryKeysBetweenMainAndStaging() { java.util.function.Function v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v; java.util.stream.Collector v, v; org.finos.legend.engine.persistence.components.planner.Planner v; java.util.function.Predicate v, v; java.util.List v, v; java.util.stream.Stream v, v, v, v, v, v; java.lang.Object v, v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); return v; } protected org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset mainDataset() { org.finos.legend.engine.persistence.components.common.Datasets v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; org.finos.legend.engine.persistence.components.planner.Planner v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v = v.; v = virtualinvoke v.(); return v; } public org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset stagingDataset() { org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; org.finos.legend.engine.persistence.components.planner.Planner v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v = v.; return v; } protected org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset originalStagingDataset() { org.finos.legend.engine.persistence.components.common.Datasets v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; org.finos.legend.engine.persistence.components.planner.Planner v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v = v.; v = virtualinvoke v.(); return v; } protected org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset tempStagingDataset() { org.finos.legend.engine.persistence.components.planner.Planner v; java.util.Optional v; java.lang.Object v; java.util.function.Supplier v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v = v.; v = staticinvoke (); v = virtualinvoke v.(v); return v; } protected org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset tempStagingDatasetWithoutPks() { org.finos.legend.engine.persistence.components.planner.Planner v; java.util.Optional v; java.lang.Object v; java.util.function.Supplier v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v = v.; v = staticinvoke (); v = virtualinvoke v.(v); return v; } protected org.eclipse.collections.api.tuple.Pair getDataFieldsWithTypes() { org.finos.legend.engine.persistence.components.ingestmode.IngestMode v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition v; org.finos.legend.engine.persistence.components.ingestmode.deduplication.DeduplicationStrategy v; boolean v, v, v, v; org.finos.legend.engine.persistence.components.ingestmode.deduplication.DeduplicationStrategyVisitor v; java.util.List v, v, v; java.util.Optional v; org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType v; java.util.ArrayList v, v; int v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaReference v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v, v; java.lang.String v, v; org.eclipse.collections.api.tuple.Pair v; org.finos.legend.engine.persistence.components.planner.Planner v; java.lang.Object v, v, v, v, v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v = new java.util.ArrayList; specialinvoke v.()>(); v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); v = 0; label: v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); if v >= v goto label; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; label: interfaceinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = v + 1; goto label; label: v = staticinvoke (v, v); return v; } protected java.util.List getDataFields() { org.finos.legend.engine.persistence.components.ingestmode.IngestMode v, v, v; java.util.ArrayList v; org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaReference v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; org.finos.legend.engine.persistence.components.ingestmode.deduplication.DeduplicationStrategy v; boolean v, v; org.finos.legend.engine.persistence.components.planner.Planner v; org.finos.legend.engine.persistence.components.ingestmode.deduplication.DeduplicationStrategyVisitor v; java.util.List v; java.util.Optional v, v; java.lang.Object v, v, v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v = new java.util.ArrayList; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.util.Collection)>(v); v = v.; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); staticinvoke (v, v); label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); staticinvoke (v, v); label: return v; } protected java.util.Optional metadataDataset() { java.util.Optional v; org.finos.legend.engine.persistence.components.common.Datasets v; org.finos.legend.engine.persistence.components.planner.Planner v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v = v.; v = virtualinvoke v.(); return v; } protected java.util.Optional lockInfoDataset() { java.util.Optional v; org.finos.legend.engine.persistence.components.common.Datasets v; org.finos.legend.engine.persistence.components.planner.Planner v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v = v.; v = virtualinvoke v.(); return v; } protected org.finos.legend.engine.persistence.components.ingestmode.IngestMode ingestMode() { org.finos.legend.engine.persistence.components.ingestmode.IngestMode v; org.finos.legend.engine.persistence.components.planner.Planner v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v = v.; return v; } protected org.finos.legend.engine.persistence.components.planner.PlannerOptions options() { org.finos.legend.engine.persistence.components.planner.Planner v; org.finos.legend.engine.persistence.components.planner.PlannerOptions v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v = v.; return v; } public abstract org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan buildLogicalPlanForIngest(org.finos.legend.engine.persistence.components.common.Resources); public org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan buildLogicalPlanForDryRun(org.finos.legend.engine.persistence.components.common.Resources) { org.finos.legend.engine.persistence.components.planner.Planner v; org.finos.legend.engine.persistence.components.common.Resources v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v := @parameter: org.finos.legend.engine.persistence.components.common.Resources; return null; } public java.util.Map buildLogicalPlanForDryRunValidation(org.finos.legend.engine.persistence.components.common.Resources) { org.finos.legend.engine.persistence.components.planner.Planner v; java.util.Map v; org.finos.legend.engine.persistence.components.common.Resources v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v := @parameter: org.finos.legend.engine.persistence.components.common.Resources; v = staticinvoke (); return v; } public org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan buildLogicalPlanForDryRunPreActions(org.finos.legend.engine.persistence.components.common.Resources) { org.finos.legend.engine.persistence.components.planner.Planner v; org.finos.legend.engine.persistence.components.common.Resources v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v := @parameter: org.finos.legend.engine.persistence.components.common.Resources; return null; } public org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan buildLogicalPlanForDryRunPostCleanup(org.finos.legend.engine.persistence.components.common.Resources) { org.finos.legend.engine.persistence.components.planner.Planner v; org.finos.legend.engine.persistence.components.common.Resources v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v := @parameter: org.finos.legend.engine.persistence.components.common.Resources; return null; } public org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan buildLogicalPlanForMetadataIngest(org.finos.legend.engine.persistence.components.common.Resources) { java.util.HashMap v; org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp v; org.finos.legend.engine.persistence.components.logicalplan.values.BatchEndTimestamp v; org.finos.legend.engine.persistence.components.util.MetadataUtils v; java.util.Map v, v; org.finos.legend.engine.persistence.components.common.Resources v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v; java.lang.String v; org.finos.legend.engine.persistence.components.planner.PlannerOptions v, v, v, v; boolean v, v; org.finos.legend.engine.persistence.components.planner.Planner v; org.finos.legend.engine.persistence.components.logicalplan.operations.Insert v; org.finos.legend.engine.persistence.components.logicalplan.operations.Operation[] v; org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v; java.util.List v, v; java.util.Optional v, v, v; org.finos.legend.engine.persistence.components.logicalplan.values.StringValue v, v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v := @parameter: org.finos.legend.engine.persistence.components.common.Resources; v = new java.util.HashMap; specialinvoke v.()>(); v = v; v = virtualinvoke v.(); v = v instanceof org.finos.legend.engine.persistence.components.logicalplan.datasets.DerivedDataset; if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); label: v = staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = newarray (org.finos.legend.engine.persistence.components.logicalplan.operations.Operation)[1]; v = v.; v = v.; v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v, v, v, v, v, v, v); v[0] = v; v = staticinvoke (v); v = staticinvoke (v); return v; } public org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan buildLogicalPlanForInitializeLock(org.finos.legend.engine.persistence.components.common.Resources) { org.finos.legend.engine.persistence.components.planner.Planner v; org.finos.legend.engine.persistence.components.logicalplan.operations.Insert v; org.finos.legend.engine.persistence.components.util.LockInfoUtils v; java.util.Set v; org.finos.legend.engine.persistence.components.common.Datasets v; java.util.function.Supplier v; org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp v; org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v; org.finos.legend.engine.persistence.components.common.Resources v; java.util.Optional v; java.lang.Object v; org.finos.legend.engine.persistence.components.planner.PlannerOptions v; boolean v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v := @parameter: org.finos.legend.engine.persistence.components.common.Resources; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = new org.finos.legend.engine.persistence.components.util.LockInfoUtils; v = v.; v = virtualinvoke v.(); v = staticinvoke (); v = virtualinvoke v.(v); specialinvoke v.(org.finos.legend.engine.persistence.components.util.LockInfoDataset)>(v); v = ; v = virtualinvoke v.(v); v = staticinvoke (v); v = staticinvoke (v); return v; label: return null; } public org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan buildLogicalPlanForAcquireLock(org.finos.legend.engine.persistence.components.common.Resources) { org.finos.legend.engine.persistence.components.planner.Planner v; org.finos.legend.engine.persistence.components.logicalplan.operations.Update v; org.finos.legend.engine.persistence.components.util.LockInfoUtils v; java.util.Set v; org.finos.legend.engine.persistence.components.common.Datasets v; java.util.function.Supplier v; org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp v; org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v; org.finos.legend.engine.persistence.components.common.Resources v; java.util.Optional v; java.lang.Object v; org.finos.legend.engine.persistence.components.planner.PlannerOptions v; boolean v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v := @parameter: org.finos.legend.engine.persistence.components.common.Resources; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = new org.finos.legend.engine.persistence.components.util.LockInfoUtils; v = v.; v = virtualinvoke v.(); v = staticinvoke (); v = virtualinvoke v.(v); specialinvoke v.(org.finos.legend.engine.persistence.components.util.LockInfoDataset)>(v); v = ; v = virtualinvoke v.(v); v = staticinvoke (v); v = staticinvoke (v); return v; label: return null; } public org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan buildLogicalPlanForPreActions() { java.util.function.Supplier v, v; java.util.ArrayList v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v, v, v; org.finos.legend.engine.persistence.components.planner.PlannerOptions v, v; boolean v, v, v; org.finos.legend.engine.persistence.components.planner.Planner v; org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v; org.finos.legend.engine.persistence.components.logicalplan.operations.Create v, v, v, v; java.util.Optional v, v; java.lang.Object v, v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v = new java.util.ArrayList; specialinvoke v.()>(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); v = staticinvoke (1, v); interfaceinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (1, v); interfaceinvoke v.(v); label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (1, v); interfaceinvoke v.(v); label: v = v.; if v == 0 goto label; v = virtualinvoke v.(); v = staticinvoke (1, v); interfaceinvoke v.(v); label: v = staticinvoke (v); return v; } public org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan buildLogicalPlanForDeduplicationAndVersioning(org.finos.legend.engine.persistence.components.common.Resources) { org.finos.legend.engine.persistence.components.ingestmode.IngestMode v, v; java.util.ArrayList v, v; org.finos.legend.engine.persistence.components.logicalplan.operations.Delete$Builder v, v; org.finos.legend.engine.persistence.components.common.Resources v; org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaReference v; org.finos.legend.engine.persistence.components.logicalplan.operations.Delete v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v, v, v; org.finos.legend.engine.persistence.components.ingestmode.deduplication.DeduplicationStrategy v; boolean v; org.finos.legend.engine.persistence.components.planner.Planner v; org.finos.legend.engine.persistence.components.logicalplan.operations.Insert v; org.finos.legend.engine.persistence.components.ingestmode.versioning.VersioningStrategy v; org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v; java.util.List v, v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v := @parameter: org.finos.legend.engine.persistence.components.common.Resources; v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; if v == 0 goto label; v = staticinvoke (); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v.; v = staticinvoke (v, v, v, v); v = new java.util.ArrayList; v = interfaceinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.util.Collection)>(v); v = virtualinvoke v.(); v = staticinvoke (v, v, v); interfaceinvoke v.(v); label: v = staticinvoke (v); return v; } public org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan buildLogicalPlanForPostActions(org.finos.legend.engine.persistence.components.common.Resources) { org.finos.legend.engine.persistence.components.planner.Planner v; org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v; java.util.ArrayList v; org.finos.legend.engine.persistence.components.logicalplan.operations.Delete$Builder v, v; org.finos.legend.engine.persistence.components.common.Resources v; org.finos.legend.engine.persistence.components.logicalplan.operations.Delete v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; org.finos.legend.engine.persistence.components.planner.PlannerOptions v; boolean v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v := @parameter: org.finos.legend.engine.persistence.components.common.Resources; v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = staticinvoke (); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = staticinvoke (v); return v; } public org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan buildLogicalPlanForPostCleanup(org.finos.legend.engine.persistence.components.common.Resources) { org.finos.legend.engine.persistence.components.planner.Planner v; org.finos.legend.engine.persistence.components.logicalplan.operations.Drop v, v; org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v; java.util.ArrayList v; org.finos.legend.engine.persistence.components.common.Resources v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v; boolean v, v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v := @parameter: org.finos.legend.engine.persistence.components.common.Resources; v = new java.util.ArrayList; specialinvoke v.()>(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = staticinvoke (1, v, 1); interfaceinvoke v.(v); label: v = v.; if v == 0 goto label; v = virtualinvoke v.(); v = staticinvoke (1, v, 1); interfaceinvoke v.(v); label: v = staticinvoke (v); return v; } public java.util.Map buildLogicalPlanForPreRunStatistics(org.finos.legend.engine.persistence.components.common.Resources) { org.finos.legend.engine.persistence.components.planner.Planner v; java.util.Map v; org.finos.legend.engine.persistence.components.common.Resources v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v := @parameter: org.finos.legend.engine.persistence.components.common.Resources; v = staticinvoke (); return v; } public java.util.Map buildLogicalPlanForPostRunStatistics(org.finos.legend.engine.persistence.components.common.Resources) { org.finos.legend.engine.persistence.components.planner.Planner v; org.finos.legend.engine.persistence.components.common.Resources v; java.util.HashMap v; org.finos.legend.engine.persistence.components.planner.PlannerOptions v; boolean v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v := @parameter: org.finos.legend.engine.persistence.components.common.Resources; v = new java.util.HashMap; specialinvoke v.()>(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); label: return v; } public java.util.Map buildLogicalPlanForDeduplicationAndVersioningErrorChecks(org.finos.legend.engine.persistence.components.common.Resources) { org.finos.legend.engine.persistence.components.planner.Planner v; java.util.HashMap v; org.finos.legend.engine.persistence.components.common.Resources v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v := @parameter: org.finos.legend.engine.persistence.components.common.Resources; v = new java.util.HashMap; specialinvoke v.()>(); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v); return v; } protected void addMaxDuplicatesErrorCheck(java.util.Map) { org.finos.legend.engine.persistence.components.ingestmode.IngestMode v; org.finos.legend.engine.persistence.components.logicalplan.conditions.GreaterThan v; java.lang.Integer v, v; org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue$Builder v, v, v, v, v; java.util.Map v; java.util.stream.Collector v; org.finos.legend.engine.persistence.components.ingestmode.deduplication.DeduplicationStrategy v; boolean v; org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v, v; org.finos.legend.engine.persistence.components.logicalplan.values.FunctionName v; java.util.List v; java.util.stream.Stream v, v; org.finos.legend.engine.persistence.components.logicalplan.values.ObjectValue v; org.finos.legend.engine.persistence.components.common.DedupAndVersionErrorSqlType v, v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder v, v, v, v, v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.values.FunctionImpl$Builder v, v, v, v; java.util.function.Function v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference v; org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder v, v, v, v; int v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v, v; java.lang.String v; org.finos.legend.engine.persistence.components.planner.PlannerOptions v; org.finos.legend.engine.persistence.components.logicalplan.values.FunctionImpl v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection v, v; org.finos.legend.engine.persistence.components.planner.Planner v; org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue v, v; java.lang.Object v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v := @parameter: java.util.Map; v = v.; v = interfaceinvoke v.(); v = v instanceof org.finos.legend.engine.persistence.components.ingestmode.deduplication.FailOnDuplicates; if v == 0 goto label; v = staticinvoke (); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.("legend_persistence_count"); v = virtualinvoke v.(); v = staticinvoke (); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = ; interfaceinvoke v.(v, v); v = v.; v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v <= 0 goto label; v = staticinvoke (); v = virtualinvoke v.("legend_persistence_count"); v = virtualinvoke v.(); interfaceinvoke v.(v); v = staticinvoke (); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = staticinvoke (1); v = staticinvoke (v); v = staticinvoke (v, v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = ; interfaceinvoke v.(v, v); label: return; } protected void addMaxPkDuplicatesErrorCheck(java.util.Map) { org.finos.legend.engine.persistence.components.ingestmode.IngestMode v, v, v; org.finos.legend.engine.persistence.components.ingestmode.versioning.DeriveMaxDuplicatePkCountLogicalPlan v; org.finos.legend.engine.persistence.components.util.Capability v; org.finos.legend.engine.persistence.components.ingestmode.versioning.VersioningStrategyVisitor v; java.util.Map v; int v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v; org.finos.legend.engine.persistence.components.planner.PlannerOptions v; boolean v, v; org.finos.legend.engine.persistence.components.ingestmode.versioning.DeriveDuplicatePkRowsLogicalPlan v; org.finos.legend.engine.persistence.components.planner.Planner v; org.finos.legend.engine.persistence.components.ingestmode.versioning.VersioningStrategy v, v, v; java.util.Set v; java.util.List v, v; java.lang.Object v, v, v; org.finos.legend.engine.persistence.components.common.DedupAndVersionErrorSqlType v, v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v := @parameter: java.util.Map; v = v.; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = new org.finos.legend.engine.persistence.components.ingestmode.versioning.DeriveMaxDuplicatePkCountLogicalPlan; v = v.; v = virtualinvoke v.(); specialinvoke v.(java.util.List,org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset)>(v, v); v = interfaceinvoke v.(v); if v == null goto label; v = ; interfaceinvoke v.(v, v); label: v = v.; v = interfaceinvoke v.(); v = new org.finos.legend.engine.persistence.components.ingestmode.versioning.DeriveDuplicatePkRowsLogicalPlan; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = ; v = interfaceinvoke v.(v); specialinvoke v.(java.util.List,org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset,int,boolean)>(v, v, v, v); v = interfaceinvoke v.(v); if v == null goto label; v = ; interfaceinvoke v.(v, v); label: return; } protected void addDataErrorCheck(java.util.Map) { org.finos.legend.engine.persistence.components.ingestmode.IngestMode v, v, v; org.finos.legend.engine.persistence.components.util.Capability v; org.finos.legend.engine.persistence.components.ingestmode.versioning.DeriveMaxDataErrorLogicalPlan v; org.finos.legend.engine.persistence.components.ingestmode.versioning.VersioningStrategyVisitor v; org.finos.legend.engine.persistence.components.ingestmode.versioning.DeriveDataErrorRowsLogicalPlan v; java.util.Map v; int v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v; org.finos.legend.engine.persistence.components.planner.PlannerOptions v; boolean v, v; org.finos.legend.engine.persistence.components.planner.Planner v; org.finos.legend.engine.persistence.components.ingestmode.versioning.VersioningStrategy v, v, v; java.util.Set v; java.util.List v, v, v; java.lang.Object v, v, v; org.finos.legend.engine.persistence.components.common.DedupAndVersionErrorSqlType v, v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v := @parameter: java.util.Map; v = virtualinvoke v.(); v = v.; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = new org.finos.legend.engine.persistence.components.ingestmode.versioning.DeriveMaxDataErrorLogicalPlan; v = v.; v = virtualinvoke v.(); specialinvoke v.(java.util.List,java.util.List,org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset)>(v, v, v); v = interfaceinvoke v.(v); if v == null goto label; v = ; interfaceinvoke v.(v, v); label: v = v.; v = interfaceinvoke v.(); v = new org.finos.legend.engine.persistence.components.ingestmode.versioning.DeriveDataErrorRowsLogicalPlan; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = ; v = interfaceinvoke v.(v); specialinvoke v.(java.util.List,java.util.List,org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset,int,boolean)>(v, v, v, v, v); v = interfaceinvoke v.(v); if v == null goto label; v = ; interfaceinvoke v.(v, v); label: return; } abstract java.util.List getDigestOrRemainingColumns(); protected void validatePrimaryKeysNotEmpty(java.util.List) { java.lang.IllegalStateException v; org.finos.legend.engine.persistence.components.planner.Planner v; java.util.List v; boolean v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v := @parameter: java.util.List; v = interfaceinvoke v.(); if v == 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Primary key list must not be empty"); throw v; label: return; } protected void validatePrimaryKeysIsEmpty(java.util.List) { java.lang.IllegalStateException v; org.finos.legend.engine.persistence.components.planner.Planner v; java.util.List v; boolean v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v := @parameter: java.util.List; v = interfaceinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Primary key list must be empty"); throw v; label: return; } public boolean dataSplitExecutionSupported() { org.finos.legend.engine.persistence.components.planner.Planner v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; return 1; } public java.util.Optional getDataSplitInRangeConditionForStatistics() { java.util.Optional v; org.finos.legend.engine.persistence.components.planner.Planner v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v = staticinvoke (); return v; } protected void addPreRunStatsForRowsDeleted(java.util.Map) { org.finos.legend.engine.persistence.components.planner.Planner v; org.finos.legend.engine.persistence.components.common.StatisticName v, v; java.lang.Long v; java.util.Map v; java.lang.String v; org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v := @parameter: java.util.Map; v = ; v = virtualinvoke v.(); v = staticinvoke (0L); v = staticinvoke (v, v); v = ; interfaceinvoke v.(v, v); return; } protected void addPostRunStatsForIncomingRecords(java.util.Map) { org.finos.legend.engine.persistence.components.ingestmode.IngestMode v, v; org.finos.legend.engine.persistence.components.common.StatisticName v, v, v; java.lang.Integer v; org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue$Builder v, v, v; java.util.Map v; org.finos.legend.engine.persistence.components.ingestmode.deduplication.DeduplicationStrategy v; boolean v, v; org.finos.legend.engine.persistence.components.ingestmode.deduplication.DeduplicationStrategyVisitor v; org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v; org.finos.legend.engine.persistence.components.logicalplan.values.FunctionName v, v, v; org.finos.legend.engine.persistence.components.logicalplan.values.ObjectValue v; java.util.Optional v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.values.FunctionImpl$Builder v, v, v, v, v, v, v, v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference v; org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; java.lang.String v, v; org.finos.legend.engine.persistence.components.logicalplan.values.FunctionImpl v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection v; org.finos.legend.engine.persistence.components.planner.Planner v; org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue v; org.finos.legend.engine.persistence.components.logicalplan.values.All v; java.lang.Object v, v; org.finos.legend.engine.persistence.components.logicalplan.values.Value[] v; v := @this: org.finos.legend.engine.persistence.components.planner.Planner; v := @parameter: java.util.Map; v = staticinvoke (); v = staticinvoke