public class org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest extends org.finos.legend.engine.persistence.components.IngestModeTest
{
private final org.finos.legend.engine.persistence.components.transformer.TransformOptions transformOptions;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset stagingDataset;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset derivedStagingDataset;
java.util.List primaryKeys;
public void <init>()
{
java.lang.String[] v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.DerivedDataset$Builder v, v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition v, v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v;
org.finos.legend.engine.persistence.components.common.DatasetFilter v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions$Builder v;
org.finos.legend.engine.persistence.components.common.FilterType 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.DerivedDataset v;
java.util.List v;
org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition v;
v := @this: org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest;
specialinvoke v.<org.finos.legend.engine.persistence.components.IngestModeTest: void <init>()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.transformer.TransformOptions: org.finos.legend.engine.persistence.components.transformer.TransformOptions$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.transformer.TransformOptions$Builder: org.finos.legend.engine.persistence.components.transformer.TransformOptions build()>();
v.<org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest: org.finos.legend.engine.persistence.components.transformer.TransformOptions transformOptions> = v;
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder database(java.lang.String)>("my_db");
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder group(java.lang.String)>("my_schema");
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder name(java.lang.String)>("my_table");
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder alias(java.lang.String)>("stage");
v = v.<org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition baseTableSchemaWithVersion>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder schema(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition build()>();
v.<org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset stagingDataset> = v;
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.datasets.DerivedDataset: org.finos.legend.engine.persistence.components.logicalplan.datasets.DerivedDataset$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DerivedDataset$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DerivedDataset$Builder database(java.lang.String)>("my_db");
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DerivedDataset$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DerivedDataset$Builder group(java.lang.String)>("my_schema");
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DerivedDataset$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DerivedDataset$Builder name(java.lang.String)>("my_table");
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DerivedDataset$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DerivedDataset$Builder alias(java.lang.String)>("stage");
v = v.<org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition baseTableSchemaWithVersion>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DerivedDataset$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DerivedDataset$Builder schema(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition)>(v);
v = <org.finos.legend.engine.persistence.components.common.FilterType: org.finos.legend.engine.persistence.components.common.FilterType EQUAL_TO>;
v = staticinvoke <org.finos.legend.engine.persistence.components.common.DatasetFilter: org.finos.legend.engine.persistence.components.common.DatasetFilter of(java.lang.String,org.finos.legend.engine.persistence.components.common.FilterType,java.lang.Object)>("bizDate", v, "2020-01-01");
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DerivedDataset$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DerivedDataset$Builder addDatasetFilters(org.finos.legend.engine.persistence.components.common.DatasetFilter)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.DerivedDataset$Builder: org.finos.legend.engine.persistence.components.logicalplan.datasets.DerivedDataset build()>();
v.<org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset derivedStagingDataset> = v;
v = newarray (java.lang.String)[2];
v[0] = "id";
v[1] = "name";
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v.<org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest: java.util.List primaryKeys> = v;
return;
}
public void testVersioningHandlerNoVersioningStrategy()
{
org.finos.legend.engine.persistence.components.ingestmode.versioning.NoVersioningStrategy v;
java.util.List v;
org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v, v;
java.lang.Object v;
org.finos.legend.engine.persistence.components.ingestmode.versioning.NoVersioningStrategy$Builder v;
org.finos.legend.engine.persistence.components.ingestmode.versioning.DatasetVersioningHandler v;
boolean v;
v := @this: org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest;
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.versioning.NoVersioningStrategy: org.finos.legend.engine.persistence.components.ingestmode.versioning.NoVersioningStrategy$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.versioning.NoVersioningStrategy$Builder: org.finos.legend.engine.persistence.components.ingestmode.versioning.NoVersioningStrategy build()>();
v = new org.finos.legend.engine.persistence.components.ingestmode.versioning.DatasetVersioningHandler;
v = v.<org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset stagingDataset>;
v = v.<org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest: java.util.List primaryKeys>;
specialinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.versioning.DatasetVersioningHandler: void <init>(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset,java.util.List)>(v, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.versioning.NoVersioningStrategy: java.lang.Object accept(org.finos.legend.engine.persistence.components.ingestmode.versioning.VersioningStrategyVisitor)>(v);
v = v instanceof org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetDefinition;
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = v.<org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset stagingDataset>;
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public void testVersioningHandlerMaxVersionStrategy()
{
org.finos.legend.engine.persistence.components.relational.SqlPlan v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v;
org.finos.legend.engine.persistence.components.ingestmode.versioning.MaxVersionStrategy$Builder v, v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder v, v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v;
org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v;
java.util.List v, v;
org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest v;
java.lang.Object v;
org.finos.legend.engine.persistence.components.ingestmode.versioning.DatasetVersioningHandler v;
org.finos.legend.engine.persistence.components.ingestmode.versioning.MaxVersionStrategy v;
v := @this: org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest;
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.versioning.MaxVersionStrategy: org.finos.legend.engine.persistence.components.ingestmode.versioning.MaxVersionStrategy$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.versioning.MaxVersionStrategy$Builder: org.finos.legend.engine.persistence.components.ingestmode.versioning.MaxVersionStrategy$Builder versioningField(java.lang.String)>("version");
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.versioning.MaxVersionStrategy$Builder: org.finos.legend.engine.persistence.components.ingestmode.versioning.MaxVersionStrategy build()>();
v = new org.finos.legend.engine.persistence.components.ingestmode.versioning.DatasetVersioningHandler;
v = v.<org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset stagingDataset>;
v = v.<org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest: java.util.List primaryKeys>;
specialinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.versioning.DatasetVersioningHandler: void <init>(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset,java.util.List)>(v, v);
virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.versioning.MaxVersionStrategy: java.lang.Object accept(org.finos.legend.engine.persistence.components.ingestmode.versioning.VersioningStrategyVisitor)>(v);
v = new org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink get()>();
v = v.<org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest: org.finos.legend.engine.persistence.components.transformer.TransformOptions transformOptions>;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: void <init>(org.finos.legend.engine.persistence.components.relational.RelationalSink,org.finos.legend.engine.persistence.components.transformer.TransformOptions)>(v, v);
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder addOps(org.finos.legend.engine.persistence.components.logicalplan.operations.Operation)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: org.finos.legend.engine.persistence.components.relational.SqlPlan generatePhysicalPlan(org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.SqlPlan: java.util.List getSqlList()>();
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("SELECT stage.\"id\",stage.\"name\",stage.\"version\",stage.\"biz_date\" FROM (SELECT stage.\"id\",stage.\"name\",stage.\"version\",stage.\"biz_date\",DENSE_RANK() OVER (PARTITION BY stage.\"id\",stage.\"name\" ORDER BY stage.\"version\" DESC) as \"legend_persistence_rank\" FROM \"my_db\".\"my_schema\".\"my_table\" as stage) as stage WHERE stage.\"legend_persistence_rank\" = 1", v);
return;
}
public void testVersioningHandlerAllVersionsStrategy()
{
org.finos.legend.engine.persistence.components.relational.SqlPlan v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder v, v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.ingestmode.versioning.AllVersionsStrategy$Builder v, v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v;
org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v;
java.util.List v, v;
org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest v;
java.lang.Object v;
org.finos.legend.engine.persistence.components.ingestmode.versioning.AllVersionsStrategy v;
org.finos.legend.engine.persistence.components.ingestmode.versioning.DatasetVersioningHandler v;
v := @this: org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest;
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.versioning.AllVersionsStrategy: org.finos.legend.engine.persistence.components.ingestmode.versioning.AllVersionsStrategy$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.versioning.AllVersionsStrategy$Builder: org.finos.legend.engine.persistence.components.ingestmode.versioning.AllVersionsStrategy$Builder versioningField(java.lang.String)>("version");
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.versioning.AllVersionsStrategy$Builder: org.finos.legend.engine.persistence.components.ingestmode.versioning.AllVersionsStrategy build()>();
v = new org.finos.legend.engine.persistence.components.ingestmode.versioning.DatasetVersioningHandler;
v = v.<org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset stagingDataset>;
v = v.<org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest: java.util.List primaryKeys>;
specialinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.versioning.DatasetVersioningHandler: void <init>(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset,java.util.List)>(v, v);
virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.versioning.AllVersionsStrategy: java.lang.Object accept(org.finos.legend.engine.persistence.components.ingestmode.versioning.VersioningStrategyVisitor)>(v);
v = new org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink get()>();
v = v.<org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest: org.finos.legend.engine.persistence.components.transformer.TransformOptions transformOptions>;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: void <init>(org.finos.legend.engine.persistence.components.relational.RelationalSink,org.finos.legend.engine.persistence.components.transformer.TransformOptions)>(v, v);
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder addOps(org.finos.legend.engine.persistence.components.logicalplan.operations.Operation)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: org.finos.legend.engine.persistence.components.relational.SqlPlan generatePhysicalPlan(org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.SqlPlan: java.util.List getSqlList()>();
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("SELECT stage.\"id\",stage.\"name\",stage.\"version\",stage.\"biz_date\",DENSE_RANK() OVER (PARTITION BY stage.\"id\",stage.\"name\" ORDER BY stage.\"version\" ASC) as \"legend_persistence_data_split\" FROM \"my_db\".\"my_schema\".\"my_table\" as stage", v);
return;
}
public void testVersioningHandlerWithDeduplicationHandler()
{
org.finos.legend.engine.persistence.components.relational.SqlPlan v;
org.finos.legend.engine.persistence.components.transformer.TransformOptions v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder v, v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.ingestmode.versioning.AllVersionsStrategy$Builder v, v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v;
org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Selection v;
org.finos.legend.engine.persistence.components.ingestmode.deduplication.FailOnDuplicates v;
org.finos.legend.engine.persistence.components.ingestmode.deduplication.FailOnDuplicates$Builder v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v;
java.util.List v, v;
org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest v;
java.lang.Object v;
org.finos.legend.engine.persistence.components.ingestmode.versioning.AllVersionsStrategy v;
v := @this: org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest;
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.deduplication.FailOnDuplicates: org.finos.legend.engine.persistence.components.ingestmode.deduplication.FailOnDuplicates$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.deduplication.FailOnDuplicates$Builder: org.finos.legend.engine.persistence.components.ingestmode.deduplication.FailOnDuplicates build()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.versioning.AllVersionsStrategy: org.finos.legend.engine.persistence.components.ingestmode.versioning.AllVersionsStrategy$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.versioning.AllVersionsStrategy$Builder: org.finos.legend.engine.persistence.components.ingestmode.versioning.AllVersionsStrategy$Builder versioningField(java.lang.String)>("version");
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.versioning.AllVersionsStrategy$Builder: org.finos.legend.engine.persistence.components.ingestmode.versioning.AllVersionsStrategy build()>();
v = v.<org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset derivedStagingDataset>;
v = v.<org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest: java.util.List primaryKeys>;
staticinvoke <org.finos.legend.engine.persistence.components.util.LogicalPlanUtils: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset getDedupedAndVersionedDataset(org.finos.legend.engine.persistence.components.ingestmode.deduplication.DeduplicationStrategy,org.finos.legend.engine.persistence.components.ingestmode.versioning.VersioningStrategy,org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset,java.util.List)>(v, v, v, v);
v = new org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink get()>();
v = v.<org.finos.legend.engine.persistence.components.util.DatasetVersioningHandlerTest: org.finos.legend.engine.persistence.components.transformer.TransformOptions transformOptions>;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: void <init>(org.finos.legend.engine.persistence.components.relational.RelationalSink,org.finos.legend.engine.persistence.components.transformer.TransformOptions)>(v, v);
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder addOps(org.finos.legend.engine.persistence.components.logicalplan.operations.Operation)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan$Builder: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.transformer.RelationalTransformer: org.finos.legend.engine.persistence.components.relational.SqlPlan generatePhysicalPlan(org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.SqlPlan: java.util.List getSqlList()>();
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("SELECT stage.\"id\",stage.\"name\",stage.\"version\",stage.\"biz_date\",stage.\"legend_persistence_count\" as \"legend_persistence_count\",DENSE_RANK() OVER (PARTITION BY stage.\"id\",stage.\"name\" ORDER BY stage.\"version\" ASC) as \"legend_persistence_data_split\" FROM (SELECT stage.\"id\",stage.\"name\",stage.\"version\",stage.\"biz_date\",COUNT(*) as \"legend_persistence_count\" FROM \"my_db\".\"my_schema\".\"my_table\" as stage WHERE stage.\"bizDate\" = \'2020-01-01\' GROUP BY stage.\"id\", stage.\"name\", stage.\"version\", stage.\"biz_date\") as stage", v);
return;
}
}