class org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner extends org.finos.legend.engine.persistence.components.planner.BitemporalPlanner { private static final java.lang.String VALID_DATE_TIME_FROM_NAME; private static final java.lang.String VALID_DATE_TIME_THRU_NAME; private static final java.lang.String LEFT_DATASET_IN_JOIN_ALIAS; private static final java.lang.String RIGHT_DATASET_IN_JOIN_ALIAS; private static final java.lang.String STAGE_DATASET_WITHOUT_DUPLICATES_BASE_NAME; private final java.util.Optional deleteIndicatorField; private final java.util.List deleteIndicatorValues; private final java.util.Optional deleteIndicatorIsNotSetCondition; private final java.util.Optional deleteIndicatorIsSetCondition; private final java.util.Optional dataSplitInRangeCondition; private org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset stagingDataset; private org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset tempDataset; private org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset tempDatasetWithDeleteIndicator; private java.util.Optional stagingDatasetWithoutDuplicates; private org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue sourceValidDatetimeFrom; private org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue targetValidDatetimeFrom; private org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue targetValidDatetimeThru; private org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue digest; private org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue validDateTimeFrom; private org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue validDateTimeThru; private java.util.List primaryKeyFields; private java.util.List primaryKeyFieldsAndFromFieldFromStage; private java.util.List primaryKeyFieldsAndFromFieldFromMain; private java.util.List primaryKeyFieldsAndFromFieldForSelection; private java.util.List dataFields; void (org.finos.legend.engine.persistence.components.common.Datasets, org.finos.legend.engine.persistence.components.ingestmode.BitemporalDelta, org.finos.legend.engine.persistence.components.planner.PlannerOptions, java.util.Set) { org.finos.legend.engine.persistence.components.ingestmode.merge.MergeStrategyVisitor v, v; java.util.stream.Collector v; org.finos.legend.engine.persistence.components.ingestmode.validitymilestoning.derivation.ValidityDerivation v, v, v; java.util.Set v; org.finos.legend.engine.persistence.components.planner.BitemporalPlanner$ExtractSourceValidDateTimeFrom v; java.util.stream.Stream v, v; java.lang.Object[] v; java.util.ArrayList v, v, v, v; org.finos.legend.engine.persistence.components.ingestmode.validitymilestoning.ValidityMilestoning v, v, v, v, v; java.lang.String v; org.finos.legend.engine.persistence.components.planner.PlannerOptions v; org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue v, v, v, v, v, v, v, v, v, v; org.finos.legend.engine.persistence.components.ingestmode.BitemporalDelta v, v, v, v; org.finos.legend.engine.persistence.components.common.Datasets v; org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue$Builder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; boolean v, v, v, v, v, v, v; java.util.function.Predicate v, v, v, v, v, v; org.finos.legend.engine.persistence.components.planner.BitemporalPlanner$ExtractTargetValidDateTimeThru v; java.util.List v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.finos.legend.engine.persistence.components.ingestmode.merge.MergeStrategy v, v; java.util.Optional v, v, v, v, v, v, v, v, v, v, v; java.lang.String[] v; java.util.function.Function v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition v; org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaReference v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v, v, v, v, v, v, v; org.finos.legend.engine.persistence.components.planner.BitemporalPlanner$ExtractTargetValidDateTimeFrom v; java.util.Iterator v; java.lang.Object v, v, v, v, v, v, v, v; org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner v; v := @this: org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner; v := @parameter: org.finos.legend.engine.persistence.components.common.Datasets; v := @parameter: org.finos.legend.engine.persistence.components.ingestmode.BitemporalDelta; v := @parameter: org.finos.legend.engine.persistence.components.planner.PlannerOptions; v := @parameter: java.util.Set; specialinvoke v.(org.finos.legend.engine.persistence.components.common.Datasets,org.finos.legend.engine.persistence.components.ingestmode.BitemporalMilestoned,org.finos.legend.engine.persistence.components.planner.PlannerOptions,java.util.Set)>(v, v, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v instanceof org.finos.legend.engine.persistence.components.ingestmode.validitymilestoning.derivation.SourceSpecifiesFromDateTime; if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = specialinvoke v.(v); v. = v; v = v.; v = staticinvoke (v); v. = v; goto label; label: v = virtualinvoke v.(); v. = v; label: v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v. = v; v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v. = v; v = v.; v = staticinvoke (v); v = virtualinvoke v.(v); v. = v; v = v.; v = staticinvoke (v); v = virtualinvoke v.(v); v. = v; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v); v. = v; v = staticinvoke (); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.("legend_persistence_start_date"); v = virtualinvoke v.(); v. = v; v = staticinvoke (); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.("legend_persistence_start_date"); v = virtualinvoke v.(); v. = v; v = staticinvoke (); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.("legend_persistence_end_date"); v = virtualinvoke v.(); v. = v; v = staticinvoke (); v = virtualinvoke v.("legend_persistence_start_date"); v = virtualinvoke v.(); v. = v; v = staticinvoke (); v = virtualinvoke v.("legend_persistence_end_date"); v = virtualinvoke v.(); v. = v; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v. = v; v = v.; v = staticinvoke (v); interfaceinvoke v.(v); v = v.; v = staticinvoke (v); interfaceinvoke v.(v); v = v.; v = staticinvoke (v); interfaceinvoke v.(v); v = virtualinvoke v.(); v = v.; v = v.; v = newarray (java.lang.String)[0]; v = interfaceinvoke v.(v); v = staticinvoke (v, v, v); v. = v; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; v = staticinvoke (v); interfaceinvoke v.(v); goto label; label: v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v = v.; v = v.; interfaceinvoke v.(v); v = v.; v = v.; interfaceinvoke v.(v); v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v = v.; v = v.; interfaceinvoke v.(v); v = v.; v = v.; interfaceinvoke v.(v); v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v = v.; v = v.; interfaceinvoke v.(v); v = v.; v = v.; interfaceinvoke v.(v); v = staticinvoke (); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v. = v; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = staticinvoke (v); interfaceinvoke v.(v); label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = staticinvoke (v); interfaceinvoke v.(v); label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v instanceof org.finos.legend.engine.persistence.components.ingestmode.validitymilestoning.derivation.SourceSpecifiesFromDateTime; if v == 0 goto label; v = staticinvoke (v); v. = v; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v); v. = v; label: return; } private org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset getStagingDatasetWithoutDuplicates(org.finos.legend.engine.persistence.components.common.Datasets) { org.finos.legend.engine.persistence.components.common.Datasets v; java.util.function.Supplier v; org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference v, v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v, v, v; java.lang.String v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder v, v, v, v, v, v; java.util.Optional v, v, v, v; java.lang.Object v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition v; org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner v; v := @this: org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner; v := @parameter: org.finos.legend.engine.persistence.components.common.Datasets; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001_legend_persistence_stageWithoutDuplicates"); v = virtualinvoke v.(v); v = virtualinvoke v.("legend_persistence_stageWithoutDuplicates"); v = virtualinvoke v.(); v = virtualinvoke v.(v); return v; } protected org.finos.legend.engine.persistence.components.ingestmode.BitemporalDelta ingestMode() { org.finos.legend.engine.persistence.components.ingestmode.BitemporalMilestoned v; org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner v; v := @this: org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner; v = specialinvoke v.(); return v; } public org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan buildLogicalPlanForIngest(org.finos.legend.engine.persistence.components.common.Resources) { org.finos.legend.engine.persistence.components.logicalplan.operations.Delete$Builder v, v, v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.operations.Delete v, v, v; boolean v, v, v, v, v; org.finos.legend.engine.persistence.components.ingestmode.validitymilestoning.derivation.ValidityDerivation v; org.finos.legend.engine.persistence.components.logicalplan.operations.Insert v, v, v, v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.operations.Update v, v, v; org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v; java.util.Optional v, v; java.util.ArrayList v; org.finos.legend.engine.persistence.components.ingestmode.validitymilestoning.ValidityMilestoning v; org.finos.legend.engine.persistence.components.common.Resources v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v, v, v, v; org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner v; org.finos.legend.engine.persistence.components.ingestmode.BitemporalDelta v, v, v; v := @this: org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner; v := @parameter: org.finos.legend.engine.persistence.components.common.Resources; v = new java.util.ArrayList; specialinvoke v.()>(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v instanceof org.finos.legend.engine.persistence.components.ingestmode.validitymilestoning.derivation.SourceSpecifiesFromAndThruDateTime; if v == 0 goto label; v = specialinvoke v.(); interfaceinvoke v.(v); v = specialinvoke v.(); interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = specialinvoke v.(); interfaceinvoke v.(v); label: v = specialinvoke v.(); interfaceinvoke v.(v); v = specialinvoke v.(); interfaceinvoke v.(v); v = v.; v = specialinvoke v.(v); interfaceinvoke v.(v); v = specialinvoke v.(); interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = specialinvoke v.(); interfaceinvoke v.(v); v = v.; v = specialinvoke v.(v); interfaceinvoke v.(v); v = specialinvoke v.(); interfaceinvoke v.(v); label: v = staticinvoke (); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = staticinvoke (); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = staticinvoke (); v = 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 buildLogicalPlanForPreActions() { boolean v, v, v, v, v; org.finos.legend.engine.persistence.components.ingestmode.validitymilestoning.derivation.ValidityDerivation v; org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v; java.util.Optional v, v, v; java.util.function.Supplier v, v; java.util.ArrayList v; org.finos.legend.engine.persistence.components.ingestmode.validitymilestoning.ValidityMilestoning v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v, v, v, v, v; org.finos.legend.engine.persistence.components.planner.PlannerOptions v, v; org.finos.legend.engine.persistence.components.logicalplan.operations.Create v, v, v, v, v, v; java.lang.Object v, v; org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner v; org.finos.legend.engine.persistence.components.ingestmode.BitemporalDelta v, v; v := @this: org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner; 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.(); v = interfaceinvoke v.(); v = v instanceof org.finos.legend.engine.persistence.components.ingestmode.validitymilestoning.derivation.SourceSpecifiesFromDateTime; if v == 0 goto label; v = v.; v = staticinvoke (1, v); interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = staticinvoke (1, v); interfaceinvoke v.(v); label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = 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 = staticinvoke (v); return v; } protected void addPostRunStatsForRowsTerminated(java.util.Map) { org.finos.legend.engine.persistence.components.common.StatisticName v, v; org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v; java.lang.Long v; java.util.Map v; java.util.Optional v; java.lang.String v; org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner v; boolean v; v := @this: org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner; v := @parameter: java.util.Map; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = ; v = virtualinvoke v.(); v = staticinvoke (0L); v = staticinvoke (v, v); v = ; interfaceinvoke v.(v, v); goto label; label: specialinvoke v.(v); label: return; } protected void addPostRunStatsForRowsUpdated(java.util.Map) { org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection v; org.finos.legend.engine.persistence.components.common.StatisticName v, v; org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v; org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder v, v; java.util.Map v; java.util.Optional v; java.lang.String v; org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner v; boolean v; v := @this: org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner; v := @parameter: java.util.Map; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = staticinvoke (); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = ; interfaceinvoke v.(v, v); goto label; label: specialinvoke v.(v); label: return; } protected void addPostRunStatsForRowsInserted(java.util.Map) { org.finos.legend.engine.persistence.components.common.StatisticName v, v; org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder v, v; java.util.Map v; java.lang.String v; boolean v; org.finos.legend.engine.persistence.components.logicalplan.values.DiffBinaryValueOperator v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection v; org.finos.legend.engine.persistence.components.logicalplan.values.SelectValue v, v; org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v; java.util.Optional v; org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder v, v; v := @this: org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner; v := @parameter: java.util.Map; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = staticinvoke (); v = staticinvoke (); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = ; interfaceinvoke v.(v, v); goto label; label: specialinvoke v.(v); label: return; } protected org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection getRowsUpdated(java.lang.String) { org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection v; org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition v; java.lang.String v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition v; org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner v; v := @this: org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner; v := @parameter: java.lang.String; v = virtualinvoke v.("sink2"); v = specialinvoke v.(); v = virtualinvoke v.(v, v, v); return v; } public org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan buildLogicalPlanForPostCleanup(org.finos.legend.engine.persistence.components.common.Resources) { java.util.function.Supplier v; java.util.ArrayList v; org.finos.legend.engine.persistence.components.ingestmode.validitymilestoning.ValidityMilestoning 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; org.finos.legend.engine.persistence.components.ingestmode.validitymilestoning.derivation.ValidityDerivation v; org.finos.legend.engine.persistence.components.logicalplan.operations.Drop v, v, v; org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v; java.util.Optional v, v; java.lang.Object v; org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner v; org.finos.legend.engine.persistence.components.ingestmode.BitemporalDelta v, v; v := @this: org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner; v := @parameter: org.finos.legend.engine.persistence.components.common.Resources; v = new java.util.ArrayList; specialinvoke v.()>(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v instanceof org.finos.legend.engine.persistence.components.ingestmode.validitymilestoning.derivation.SourceSpecifiesFromDateTime; if v == 0 goto label; v = v.; v = staticinvoke (1, v, 1); interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = staticinvoke (1, v, 1); interfaceinvoke v.(v); label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = staticinvoke (); v = virtualinvoke v.(v); v = staticinvoke (1, v, 1); interfaceinvoke v.(v); label: v = staticinvoke (v); return v; } public java.util.Optional getDataSplitInRangeConditionForStatistics() { java.util.Optional v, v; org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner v; java.util.function.Function v; org.finos.legend.engine.persistence.components.ingestmode.BitemporalDelta v; v := @this: org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v); return v; } private org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition getPrimaryKeyFieldsAndFromFieldFromMain() { java.lang.Object[] v; java.lang.String[] v; java.util.function.Function v; java.util.List v; java.util.stream.Stream v, v; org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; java.lang.Object v; java.util.stream.Collector v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition v; org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner v; v := @this: org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner; v = specialinvoke v.("sink2"); v = virtualinvoke v.(); v = v.; v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = newarray (java.lang.String)[0]; v = interfaceinvoke v.(v); v = staticinvoke (v, v, v); return v; } private org.finos.legend.engine.persistence.components.logicalplan.operations.Insert getUpsertLogic() { org.finos.legend.engine.persistence.components.logicalplan.conditions.And$Builder v, v, v, v, v, v; org.finos.legend.engine.persistence.components.ingestmode.validitymilestoning.derivation.ValidityDerivation v; org.finos.legend.engine.persistence.components.logicalplan.operations.Insert v; org.finos.legend.engine.persistence.components.planner.BitemporalPlanner$ExtractSourceValidDateTimeFrom v; org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition[] 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.conditions.Not v; java.util.function.Supplier v, v; org.finos.legend.engine.persistence.components.ingestmode.validitymilestoning.ValidityMilestoning v, v; org.finos.legend.engine.persistence.components.logicalplan.conditions.And v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection v, v; org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue v, v; org.finos.legend.engine.persistence.components.logicalplan.conditions.Equals v; org.finos.legend.engine.persistence.components.logicalplan.conditions.Exists v; org.finos.legend.engine.persistence.components.ingestmode.BitemporalDelta v, v, v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue$Builder v, v, v, v, v, v; boolean v, v, v; java.util.List v, v, v; java.util.Optional v, v, v, v, v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference v, v; org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v, v, v, v; org.finos.legend.engine.persistence.components.planner.BitemporalPlanner$ExtractTargetValidDateTimeFrom v; java.util.function.Consumer v; java.lang.Object v, v, v, v, v, v; org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner v; v := @this: org.finos.legend.engine.persistence.components.planner.BitemporalDeltaPlanner; v = staticinvoke (); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v, v); v = staticinvoke (); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = staticinvoke (); v = newarray (org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition)[4]; v = v.; v[0] = v; v = v.; v[1] = v; v = v.; v[2] = v; v[3] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (v); v = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = staticinvoke (); v = newarray (org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition)[2]; v[0] = v; v = v.; v = staticinvoke (); v = virtualinvoke v.(v); v[1] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = staticinvoke (); v = newarray (org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition)[2]; v[0] = v; v = v.; v = staticinvoke (); v = virtualinvoke v.(v); v[1] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = staticinvoke (v, v); virtualinvoke v.(v); v = virtualinvoke v.