public class org.finos.legend.engine.persistence.components.util.LogicalPlanUtils extends java.lang.Object { public static final java.lang.String INFINITE_BATCH_TIME; public static final java.lang.String DEFAULT_META_TABLE; public static final java.lang.String DEFAULT_SINK_CLEAN_UP_AUDIT_TABLE; public static final java.lang.String DATA_SPLIT_LOWER_BOUND_PLACEHOLDER; public static final java.lang.String DATA_SPLIT_UPPER_BOUND_PLACEHOLDER; public static final java.lang.String UNDERSCORE; public static final java.lang.String TEMP_DATASET_BASE_NAME; public static final java.lang.String TEMP_DATASET_WITH_DELETE_INDICATOR_BASE_NAME; public static java.util.Set SUPPORTED_DATA_TYPES_FOR_OPTIMIZATION_COLUMNS; public static java.util.Set SUPPORTED_DATA_TYPES_FOR_VERSIONING_COLUMNS; private void () { org.finos.legend.engine.persistence.components.util.LogicalPlanUtils v; v := @this: org.finos.legend.engine.persistence.components.util.LogicalPlanUtils; specialinvoke v.()>(); return; } public static org.finos.legend.engine.persistence.components.logicalplan.values.Value INFINITE_BATCH_ID() { org.finos.legend.engine.persistence.components.logicalplan.values.InfiniteBatchIdValue v; org.finos.legend.engine.persistence.components.logicalplan.values.InfiniteBatchIdValue$Builder v; v = staticinvoke (); v = virtualinvoke v.(); return v; } public static org.finos.legend.engine.persistence.components.logicalplan.values.DatetimeValue INFINITE_BATCH_TIME() { org.finos.legend.engine.persistence.components.logicalplan.values.DatetimeValue v; v = staticinvoke ("9999-12-31 23:59:59"); return v; } public static java.util.List ALL_COLUMNS() { java.util.List v; org.finos.legend.engine.persistence.components.logicalplan.values.All v; v = ; v = staticinvoke (v); return v; } public static org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition getDataSplitInRangeCondition(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, java.lang.String) { org.finos.legend.engine.persistence.components.logicalplan.conditions.GreaterThanEqualTo v; org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue v; org.finos.legend.engine.persistence.components.logicalplan.conditions.LessThanEqualTo v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference v; org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue$Builder v, v, v; org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition[] v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; org.finos.legend.engine.persistence.components.logicalplan.values.StringValue v, v; java.lang.String v; org.finos.legend.engine.persistence.components.logicalplan.conditions.And$Builder v, v; org.finos.legend.engine.persistence.components.logicalplan.conditions.And v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: java.lang.String; v = staticinvoke (); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (); v = newarray (org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition)[2]; v = staticinvoke ("{DATA_SPLIT_LOWER_BOUND_PLACEHOLDER}"); v = staticinvoke (v, v); v[0] = v; v = staticinvoke ("{DATA_SPLIT_UPPER_BOUND_PLACEHOLDER}"); v = staticinvoke (v, v); v[1] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public static org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition getPrimaryKeyMatchCondition(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, java.lang.String[]) { org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v; java.lang.String[] v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: java.lang.String[]; v = staticinvoke (v, v, v); return v; } public static org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition getPartitionColumnsMatchCondition(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, java.lang.String[]) { org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v; java.lang.String[] v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: java.lang.String[]; v = staticinvoke (v, v, v); return v; } public static org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition getPartitionColumnValueMatchInCondition(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, java.util.Map) { org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; java.util.Map v; org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: java.util.Map; v = staticinvoke (v, v); return v; } public static org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition getPartitionSpecMatchCondition(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, java.util.List) { org.finos.legend.engine.persistence.components.logicalplan.conditions.Or v; java.util.function.Function v; java.util.List v; java.util.stream.Stream v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; java.lang.Object v; java.util.stream.Collector v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: java.util.List; v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (v); return v; } private static org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition getColumnValueMatchInCondition(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, java.util.Map) { java.util.Set v; java.util.function.Function v; java.util.stream.Stream v, v; java.util.Map 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.conditions.And v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: java.util.Map; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (v); return v; } private static org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition getColumnsMatchCondition(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, java.lang.String[]) { java.lang.String[] v; java.util.function.Function v; java.util.stream.Stream v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v; java.lang.Object v; java.util.stream.Collector v; org.finos.legend.engine.persistence.components.logicalplan.conditions.And v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: java.lang.String[]; v = staticinvoke (v); v = staticinvoke (v, v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (v); return v; } private static org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition getColumnsDoNotMatchCondition(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, java.lang.String[]) { org.finos.legend.engine.persistence.components.logicalplan.conditions.Or v; java.lang.String[] v; java.util.function.Function v; java.util.stream.Stream v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v; java.lang.Object v; java.util.stream.Collector v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: java.lang.String[]; v = staticinvoke (v); v = staticinvoke (v, v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (v); return v; } public static org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition getDigestMatchCondition(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, java.lang.String) { 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.datasets.DatasetReference v, v; org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue$Builder v, v, v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v; java.lang.String v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: java.lang.String; v = staticinvoke (); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v, v); return v; } public static org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition getDigestDoesNotMatchCondition(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, java.lang.String) { org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue v, v; org.finos.legend.engine.persistence.components.logicalplan.conditions.NotEquals v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference v, v; org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue$Builder v, v, v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v; java.lang.String v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: java.lang.String; v = staticinvoke (); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v, v); return v; } public static org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition getDeleteIndicatorIsSetCondition(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, java.lang.String, java.util.List) { org.finos.legend.engine.persistence.components.logicalplan.conditions.In v; org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition v; org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue$Builder v, v, v, v, v, v; java.util.stream.Collector v; boolean v; org.finos.legend.engine.persistence.components.logicalplan.values.Array v; java.util.function.Predicate v; java.util.List v, v; java.util.stream.Stream v, v, v, v; java.util.Optional v; java.util.function.Function v; java.util.function.Supplier v; org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference v, v; int v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; java.lang.String v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType 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.values.Value v; java.lang.Object v, v, v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: java.lang.String; v := @parameter: java.util.List; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(); if v != 1 goto label; v = staticinvoke (); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(0); v = staticinvoke (v, v); v = staticinvoke (v, v); return v; label: v = staticinvoke (); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (v); v = staticinvoke (v, v); return v; } public static org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition getDeleteIndicatorIsNotSetCondition(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, java.lang.String, java.util.List) { org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition v; org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue$Builder v, v, v, v, v, v; java.util.stream.Collector v; boolean v; org.finos.legend.engine.persistence.components.logicalplan.values.Array v; java.util.function.Predicate v; java.util.List v, v; java.util.stream.Stream v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.conditions.NotIn v; java.util.Optional v; java.util.function.Function v; java.util.function.Supplier v; org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType v; org.finos.legend.engine.persistence.components.logicalplan.conditions.NotEquals v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference v, v; int v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; java.lang.String v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType v; org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue v, v; org.finos.legend.engine.persistence.components.logicalplan.values.Value v; java.lang.Object v, v, v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: java.lang.String; v := @parameter: java.util.List; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(); if v != 1 goto label; v = staticinvoke (); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(0); v = staticinvoke (v, v); v = staticinvoke (v, v); return v; label: v = staticinvoke (); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (v); v = staticinvoke (v, v); return v; } private static org.finos.legend.engine.persistence.components.logicalplan.values.Value getDeleteIndicatorValue(java.lang.Object, boolean) { org.finos.legend.engine.persistence.components.logicalplan.values.ObjectValue v; org.finos.legend.engine.persistence.components.logicalplan.values.StringValue v; java.lang.Object v; java.lang.String v; boolean v; v := @parameter: java.lang.Object; v := @parameter: boolean; if v == 0 goto label; v = virtualinvoke v.(); v = staticinvoke (v); return v; label: v = staticinvoke (v); return v; } public static void removeField(java.util.List, java.lang.String) { java.util.List v; java.lang.String v; java.util.function.Predicate v; v := @parameter: java.util.List; v := @parameter: java.lang.String; v = staticinvoke (v); interfaceinvoke v.(v); return; } public static void replaceField(java.util.List, java.lang.String, java.lang.String) { java.util.function.Consumer v; java.util.List v; java.lang.String v, v; v := @parameter: java.util.List; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = staticinvoke (v, v, v); interfaceinvoke v.(v); return; } public static org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition getDatasetFilterCondition(org.finos.legend.engine.persistence.components.logicalplan.datasets.DerivedDataset) { java.util.Iterator v; java.util.ArrayList v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DerivedDataset v; java.util.List v; org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition v; java.lang.Object v; boolean v; org.finos.legend.engine.persistence.components.logicalplan.conditions.And v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.DerivedDataset; v = virtualinvoke v.(); v = new java.util.ArrayList; specialinvoke v.()>(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); interfaceinvoke v.(v); goto label; label: v = staticinvoke (v); return v; } public static java.util.Map jsonifyStagingFilters(java.util.List) { java.util.Iterator v; java.util.HashMap v, v, v; java.util.List v; java.lang.Object v, v, v; java.lang.String v, v; boolean v; org.finos.legend.engine.persistence.components.common.FilterType v; v := @parameter: java.util.List; v = new java.util.HashMap; specialinvoke v.()>(); v = new java.util.HashMap; specialinvoke v.()>(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = new java.util.HashMap; specialinvoke v.()>(); v = interfaceinvoke v.(v, v); interfaceinvoke v.(v, v); interfaceinvoke v.(v, v); goto label; label: interfaceinvoke v.("staging_filters", v); return v; } public static java.util.Map jsonifyBulkLoadSourceInfo(org.finos.legend.engine.persistence.components.logicalplan.datasets.StagedFilesDatasetProperties) { java.util.List v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.StagedFilesDatasetProperties v; java.util.HashMap v; boolean v, v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.StagedFilesDatasetProperties; v = new java.util.HashMap; specialinvoke v.()>(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v == null goto label; v = interfaceinvoke v.(); if v != 0 goto label; interfaceinvoke v.("file_paths", v); label: if v == null goto label; v = interfaceinvoke v.(); if v != 0 goto label; interfaceinvoke v.("file_patterns", v); label: return v; } public static java.util.Optional getStringValueFromMap(java.util.Map) { java.lang.Throwable v; org.finos.legend.engine.persistence.components.exception.JsonReadOrWriteException v; com.fasterxml.jackson.databind.ObjectMapper v; java.util.Map v; java.util.Optional v, v; org.finos.legend.engine.persistence.components.logicalplan.values.StringValue v; java.lang.String v, v; boolean v; v := @parameter: java.util.Map; v = interfaceinvoke v.(); if v != 0 goto label; v = new com.fasterxml.jackson.databind.ObjectMapper; specialinvoke v.()>(); label: v = virtualinvoke v.(v); v = staticinvoke (v); v = staticinvoke (v); label: return v; label: v := @caughtexception; v = new org.finos.legend.engine.persistence.components.exception.JsonReadOrWriteException; v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: v = staticinvoke (); return v; catch com.fasterxml.jackson.core.JsonProcessingException from label to label with label; } public static org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition getBatchIdEqualsInfiniteCondition(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, java.lang.String) { org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue v; org.finos.legend.engine.persistence.components.logicalplan.conditions.Equals v; org.finos.legend.engine.persistence.components.logicalplan.values.Value v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference v; org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue$Builder v, v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; java.lang.String v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: java.lang.String; v = staticinvoke (); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (); v = staticinvoke (v, v); return v; } public static org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition getBatchTimeEqualsInfiniteCondition(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, java.lang.String) { org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue v; org.finos.legend.engine.persistence.components.logicalplan.conditions.Equals v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference v; org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue$Builder v, v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; java.lang.String v; org.finos.legend.engine.persistence.components.logicalplan.values.DatetimeValue v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: java.lang.String; v = staticinvoke (); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (); v = staticinvoke (v, v); return v; } public static org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection getRecordCount(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, java.lang.String) { org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection v; org.finos.legend.engine.persistence.components.logicalplan.values.FunctionImpl$Builder v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.values.FunctionName v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference v; org.finos.legend.engine.persistence.components.logicalplan.values.All v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; java.lang.String v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder v, v, v; org.finos.legend.engine.persistence.components.logicalplan.values.FunctionImpl v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: java.lang.String; v = staticinvoke (); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = staticinvoke (); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public static org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection getRecordCount(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, java.lang.String, java.util.Optional) { org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection v; org.finos.legend.engine.persistence.components.logicalplan.values.FunctionImpl$Builder v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.values.FunctionName v; org.finos.legend.engine.persistence.components.logicalplan.values.All v; java.util.Optional v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; java.lang.String v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection$Builder v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.values.FunctionImpl v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: java.lang.String; v := @parameter: java.util.Optional; v = staticinvoke (); v = virtualinvoke v.(v); v = staticinvoke (); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public static org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition getBatchIdEqualityCondition(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, org.finos.legend.engine.persistence.components.logicalplan.values.Value, java.lang.String) { org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue v; org.finos.legend.engine.persistence.components.logicalplan.conditions.Equals v; org.finos.legend.engine.persistence.components.logicalplan.values.Value v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference v; org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue$Builder v, v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; java.lang.String v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.values.Value; v := @parameter: java.lang.String; v = staticinvoke (); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v, v); return v; } public static org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition getBatchTimeEqualityCondition(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, org.finos.legend.engine.persistence.components.logicalplan.values.Value, java.lang.String) { org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue v; org.finos.legend.engine.persistence.components.logicalplan.conditions.Equals v; org.finos.legend.engine.persistence.components.logicalplan.values.Value v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference v; org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue$Builder v, v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; java.lang.String v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.values.Value; v := @parameter: java.lang.String; v = staticinvoke (); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v, v); return v; } public static java.util.List getOptimizationFilterConditions(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, java.util.List) { org.finos.legend.engine.persistence.components.logicalplan.conditions.GreaterThanEqualTo v; org.finos.legend.engine.persistence.components.logicalplan.conditions.LessThanEqualTo v; org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue$Builder v, v, v, v, v, v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.conditions.And$Builder v, v; org.finos.legend.engine.persistence.components.logicalplan.conditions.IsNull v; boolean v, v; java.util.List v; org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition[] v, v; org.finos.legend.engine.persistence.components.logicalplan.values.StringValue v, v; java.util.ArrayList v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference v, v, v; org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; java.lang.String v, v, v, v, v; java.util.Iterator v; org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue v, v, v; org.finos.legend.engine.persistence.components.logicalplan.conditions.Or$Builder v, v; java.lang.Object v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: java.util.List; v = new java.util.ArrayList; specialinvoke v.()>(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (v, v); v = staticinvoke (); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (v, v); v = staticinvoke (); v = newarray (org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition)[2]; v[0] = v; v[1] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = staticinvoke (); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (); v = newarray (org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition)[2]; v[0] = v; v[1] = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); label: interfaceinvoke v.(v); goto label; label: return v; } public static java.util.List findCommonPrimaryFieldsBetweenMainAndStaging(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset) { java.util.function.Function 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; java.util.function.Predicate v, v; java.util.List v, v; java.util.stream.Stream v, v, v, v, v; java.lang.Object v, v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; 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 = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); return v; } public static java.util.List extractStagedFilesFieldValues(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset) { org.finos.legend.engine.persistence.components.logicalplan.values.StagedFilesFieldValue v; org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType v; java.util.ArrayList v; org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition v, v; int v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; boolean v, v; java.util.Iterator v; java.util.function.Predicate v; java.util.List v, v; java.util.stream.Stream v; java.lang.Object v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v = new java.util.ArrayList; specialinvoke v.()>(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = 1; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v; v = v + 1; v = staticinvoke (v, v, v, v, v); interfaceinvoke v.(v); goto label; label: return v; } public static java.util.List extractStagedFilesFieldValuesWithVarCharType(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset) { org.finos.legend.engine.persistence.components.logicalplan.values.StagedFilesFieldValue v; org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType v; java.util.ArrayList v; org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition v, v; int v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; boolean v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType v; java.util.Iterator v; java.util.function.Predicate v; org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType$Builder v, v; java.util.List v, v; java.util.stream.Stream v; java.lang.Object v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v = new java.util.ArrayList; specialinvoke v.()>(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = 1; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = v; v = v + 1; v = staticinvoke (v, v, v, v, v); interfaceinvoke v.(v); goto label; label: return v; } public static org.finos.legend.engine.persistence.components.logicalplan.values.StagedFilesFieldValue getStagedFilesFieldValueWithType(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, org.finos.legend.engine.persistence.components.logicalplan.datasets.Field, org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType, boolean, int) { org.finos.legend.engine.persistence.components.logicalplan.values.StagedFilesFieldValue v; java.lang.Integer v; org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference v; int v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; java.lang.String v; boolean v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Field v; org.finos.legend.engine.persistence.components.logicalplan.values.StagedFilesFieldValue$Builder v, v, v, v, v, v, v; java.util.Optional v, v, v, v, v; java.lang.Object v, v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Field; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType; v := @parameter: boolean; v := @parameter: int; v = staticinvoke (); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); goto label; label: v = v; label: v = staticinvoke (v); v = virtualinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); label: v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public static org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset getTempDataset(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; 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_temp"); v = virtualinvoke v.(v); v = virtualinvoke v.("legend_persistence_temp"); v = virtualinvoke v.(); v = virtualinvoke v.(v); return v; } public static org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset getTempDatasetWithDeleteIndicator(org.finos.legend.engine.persistence.components.common.Datasets, java.lang.String) { org.finos.legend.engine.persistence.components.common.Datasets v; org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition v, v, v; boolean v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Field v; java.util.List v; java.util.Optional v, v, v, v, v, v, v; java.util.function.Supplier v; org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType v; java.util.ArrayList 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, v; java.lang.String v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder v, v, v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Field$Builder v, v, v; java.lang.Object v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition v; v := @parameter: org.finos.legend.engine.persistence.components.common.Datasets; v := @parameter: java.lang.String; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); return v; label: v = virtualinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = virtualinvoke v.(v); v = staticinvoke (); v = virtualinvoke v.(v); v = ; v = staticinvoke (); v = staticinvoke (); v = staticinvoke (v, v, v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new java.util.ArrayList; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.util.Collection)>(v); interfaceinvoke v.(v); v = staticinvoke (); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(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_tempWithDeleteIndicator"); v = virtualinvoke v.(v); v = virtualinvoke v.("legend_persistence_tempWithDeleteIndicator"); v = virtualinvoke v.(); return v; } public static org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset getTempStagingDatasetDefinition(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, org.finos.legend.engine.persistence.components.ingestmode.IngestMode, java.lang.String) { org.finos.legend.engine.persistence.components.ingestmode.IngestMode v; org.finos.legend.engine.persistence.components.ingestmode.versioning.DeriveTempStagingSchemaDefinition 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, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; java.lang.String v, v; org.finos.legend.engine.persistence.components.ingestmode.deduplication.DeduplicationStrategy v; org.finos.legend.engine.persistence.components.ingestmode.versioning.VersioningStrategy 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, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition v; v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset; v := @parameter: org.finos.legend.engine.persistence.components.ingestmode.IngestMode; v := @parameter: java.lang.String; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.("legend_persistence_temp_staging"); v = interfaceinvoke v.