public abstract class org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases extends org.finos.legend.engine.persistence.components.BaseTest
{
org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios scenarios;
public void <init>()
{
org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases;
specialinvoke v.<org.finos.legend.engine.persistence.components.BaseTest: void <init>()>();
v = new org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios;
specialinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios: void <init>()>();
v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios scenarios> = v;
return;
}
void testUnitemporalSnapshotWithoutPartitionNoDedupNoVersion()
{
org.finos.legend.engine.persistence.components.ingestmode.IngestMode v;
org.finos.legend.engine.persistence.components.common.Datasets v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder v, v, v, v, v, v, v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__WITHOUT_PARTITIONS__NO_DEDUP__NO_VERSION()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.ingestmode.IngestMode getIngestMode()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder ingestMode(org.finos.legend.engine.persistence.components.ingestmode.IngestMode)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.relational.RelationalSink getRelationalSink()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder relationalSink(org.finos.legend.engine.persistence.components.relational.RelationalSink)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.time.Clock fixedClock_2000_01_01>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder executionTimestampClock(java.time.Clock)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder collectStatistics(boolean)>(1);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder skipMainAndMetadataDatasetCreation(boolean)>(1);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder enableConcurrentSafety(boolean)>(1);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.common.Datasets getDatasets()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult generateOperations(org.finos.legend.engine.persistence.components.common.Datasets)>(v);
virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: void verifyUnitemporalSnapshotWithoutPartitionNoDedupNoVersion(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalSnapshotWithoutPartitionNoDedupNoVersion(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalSnapshotWithoutPartitionFailOnDupsNoVersion()
{
org.finos.legend.engine.persistence.components.ingestmode.IngestMode v;
org.finos.legend.engine.persistence.components.common.Datasets v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
java.lang.String v;
org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder v, v, v, v, v, v, v, v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__WITHOUT_PARTITIONS__FAIL_ON_DUPS__NO_VERSION()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.ingestmode.IngestMode getIngestMode()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder ingestMode(org.finos.legend.engine.persistence.components.ingestmode.IngestMode)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.relational.RelationalSink getRelationalSink()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder relationalSink(org.finos.legend.engine.persistence.components.relational.RelationalSink)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.time.Clock fixedClock_2000_01_01>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder executionTimestampClock(java.time.Clock)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder collectStatistics(boolean)>(1);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder skipMainAndMetadataDatasetCreation(boolean)>(1);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder enableConcurrentSafety(boolean)>(1);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String ingestRunId>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder ingestRunId(java.lang.String)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.common.Datasets getDatasets()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult generateOperations(org.finos.legend.engine.persistence.components.common.Datasets)>(v);
virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: void verifyUnitemporalSnapshotWithoutPartitionFailOnDupsNoVersion(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalSnapshotWithoutPartitionFailOnDupsNoVersion(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalSnapshotWithoutPartitionWithNoOpEmptyBatchHandling()
{
org.finos.legend.engine.persistence.components.ingestmode.IngestMode v;
org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v;
org.finos.legend.engine.persistence.components.common.Datasets v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder v, v, v, v, v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__WITHOUT_PARTITIONS__NO_DEDUP__NO_VERSION()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.ingestmode.IngestMode getIngestMode()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder ingestMode(org.finos.legend.engine.persistence.components.ingestmode.IngestMode)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.relational.RelationalSink getRelationalSink()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder relationalSink(org.finos.legend.engine.persistence.components.relational.RelationalSink)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.time.Clock fixedClock_2000_01_01>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder executionTimestampClock(java.time.Clock)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder collectStatistics(boolean)>(1);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.common.Datasets getDatasets()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult generateOperationsForEmptyBatch(org.finos.legend.engine.persistence.components.common.Datasets)>(v);
virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: void verifyUnitemporalSnapshotWithoutPartitionWithNoOpEmptyBatchHandling(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalSnapshotWithoutPartitionWithNoOpEmptyBatchHandling(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalSnapshotWithoutPartitionWithUpperCaseOptimizer()
{
org.finos.legend.engine.persistence.components.ingestmode.IngestMode v;
org.finos.legend.engine.persistence.components.common.Datasets v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator v;
org.finos.legend.engine.persistence.components.relational.CaseConversion v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder v, v, v, v, v, v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__WITHOUT_PARTITIONS__NO_DEDUP__NO_VERSION()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.ingestmode.IngestMode getIngestMode()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder ingestMode(org.finos.legend.engine.persistence.components.ingestmode.IngestMode)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.relational.RelationalSink getRelationalSink()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder relationalSink(org.finos.legend.engine.persistence.components.relational.RelationalSink)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.time.Clock fixedClock_2000_01_01>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder executionTimestampClock(java.time.Clock)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder collectStatistics(boolean)>(1);
v = <org.finos.legend.engine.persistence.components.relational.CaseConversion: org.finos.legend.engine.persistence.components.relational.CaseConversion TO_UPPER>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder caseConversion(org.finos.legend.engine.persistence.components.relational.CaseConversion)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.common.Datasets getDatasets()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult generateOperations(org.finos.legend.engine.persistence.components.common.Datasets)>(v);
virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: void verifyUnitemporalSnapshotWithoutPartitionWithUpperCaseOptimizer(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalSnapshotWithoutPartitionWithUpperCaseOptimizer(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalSnapshotWithPartitionNoDedupNoVersion()
{
org.finos.legend.engine.persistence.components.ingestmode.IngestMode v;
org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v;
org.finos.legend.engine.persistence.components.common.Datasets v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder v, v, v, v, v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__WITH_PARTITIONS__NO_DEDUP__NO_VERSION()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.ingestmode.IngestMode getIngestMode()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder ingestMode(org.finos.legend.engine.persistence.components.ingestmode.IngestMode)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.relational.RelationalSink getRelationalSink()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder relationalSink(org.finos.legend.engine.persistence.components.relational.RelationalSink)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.time.Clock fixedClock_2000_01_01>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder executionTimestampClock(java.time.Clock)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder collectStatistics(boolean)>(1);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.common.Datasets getDatasets()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult generateOperations(org.finos.legend.engine.persistence.components.common.Datasets)>(v);
virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: void verifyUnitemporalSnapshotWithPartitionNoDedupNoVersion(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalSnapshotWithPartitionNoDedupNoVersion(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalSnapshotWithPartitionFiltersNoDedupNoVersion()
{
org.finos.legend.engine.persistence.components.ingestmode.IngestMode v;
org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v;
org.finos.legend.engine.persistence.components.common.Datasets v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder v, v, v, v, v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__WITH_PARTITION_FILTER__NO_DEDUP__NO_VERSION()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.ingestmode.IngestMode getIngestMode()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder ingestMode(org.finos.legend.engine.persistence.components.ingestmode.IngestMode)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.relational.RelationalSink getRelationalSink()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder relationalSink(org.finos.legend.engine.persistence.components.relational.RelationalSink)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.time.Clock fixedClock_2000_01_01>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder executionTimestampClock(java.time.Clock)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder collectStatistics(boolean)>(1);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.common.Datasets getDatasets()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult generateOperations(org.finos.legend.engine.persistence.components.common.Datasets)>(v);
virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: void verifyUnitemporalSnapshotWithPartitionFiltersNoDedupNoVersion(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalSnapshotWithPartitionFiltersNoDedupNoVersion(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalSnapshotWithPartitionSpecListNoDedupNoVersion()
{
org.finos.legend.engine.persistence.components.ingestmode.IngestMode v;
org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v;
org.finos.legend.engine.persistence.components.common.Datasets v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder v, v, v, v, v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__WITH_PARTITION_SPEC_LIST__NO_DEDUP__NO_VERSION()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.ingestmode.IngestMode getIngestMode()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder ingestMode(org.finos.legend.engine.persistence.components.ingestmode.IngestMode)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.relational.RelationalSink getRelationalSink()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder relationalSink(org.finos.legend.engine.persistence.components.relational.RelationalSink)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.time.Clock fixedClock_2000_01_01>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder executionTimestampClock(java.time.Clock)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder collectStatistics(boolean)>(1);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.common.Datasets getDatasets()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult generateOperations(org.finos.legend.engine.persistence.components.common.Datasets)>(v);
virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: void verifyUnitemporalSnapshotWithPartitionSpecListNoDedupNoVersion(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalSnapshotWithPartitionSpecListNoDedupNoVersion(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalSnapshotWithPartitionSpecListNoDedupNoVersionInUpperCase()
{
org.finos.legend.engine.persistence.components.ingestmode.IngestMode v;
org.finos.legend.engine.persistence.components.common.Datasets v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator v;
org.finos.legend.engine.persistence.components.relational.CaseConversion v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder v, v, v, v, v, v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__WITH_PARTITION_SPEC_LIST__NO_DEDUP__NO_VERSION()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.ingestmode.IngestMode getIngestMode()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder ingestMode(org.finos.legend.engine.persistence.components.ingestmode.IngestMode)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.relational.RelationalSink getRelationalSink()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder relationalSink(org.finos.legend.engine.persistence.components.relational.RelationalSink)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.time.Clock fixedClock_2000_01_01>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder executionTimestampClock(java.time.Clock)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder collectStatistics(boolean)>(1);
v = <org.finos.legend.engine.persistence.components.relational.CaseConversion: org.finos.legend.engine.persistence.components.relational.CaseConversion TO_UPPER>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder caseConversion(org.finos.legend.engine.persistence.components.relational.CaseConversion)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.common.Datasets getDatasets()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult generateOperations(org.finos.legend.engine.persistence.components.common.Datasets)>(v);
virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: void verifyUnitemporalSnapshotWithPartitionSpecListNoDedupNoVersionInUpperCase(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalSnapshotWithPartitionSpecListNoDedupNoVersionInUpperCase(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalSnapshotWithPartitionSpecListWithEmptyBatchHandling()
{
org.finos.legend.engine.persistence.components.ingestmode.IngestMode v;
org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v;
org.finos.legend.engine.persistence.components.common.Datasets v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder v, v, v, v, v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__WITH_PARTITION_SPEC_LIST__NO_DEDUP__NO_VERSION()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.ingestmode.IngestMode getIngestMode()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder ingestMode(org.finos.legend.engine.persistence.components.ingestmode.IngestMode)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.relational.RelationalSink getRelationalSink()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder relationalSink(org.finos.legend.engine.persistence.components.relational.RelationalSink)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.time.Clock fixedClock_2000_01_01>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder executionTimestampClock(java.time.Clock)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder collectStatistics(boolean)>(1);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.common.Datasets getDatasets()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult generateOperationsForEmptyBatch(org.finos.legend.engine.persistence.components.common.Datasets)>(v);
virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: void verifyUnitemporalSnapshotWithPartitionSpecListWithEmptyBatchHandling(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalSnapshotWithPartitionSpecListWithEmptyBatchHandling(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalSnapshotWithCleanStagingData()
{
org.finos.legend.engine.persistence.components.ingestmode.IngestMode v;
org.finos.legend.engine.persistence.components.relational.api.GeneratorResult v;
org.finos.legend.engine.persistence.components.common.Datasets v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__WITHOUT_PARTITIONS__NO_DEDUP__NO_VERSION()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.ingestmode.IngestMode getIngestMode()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder ingestMode(org.finos.legend.engine.persistence.components.ingestmode.IngestMode)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.relational.RelationalSink getRelationalSink()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder relationalSink(org.finos.legend.engine.persistence.components.relational.RelationalSink)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.time.Clock fixedClock_2000_01_01>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder executionTimestampClock(java.time.Clock)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder cleanupStagingData(boolean)>(1);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder collectStatistics(boolean)>(1);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.common.Datasets getDatasets()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult generateOperations(org.finos.legend.engine.persistence.components.common.Datasets)>(v);
virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: void verifyUnitemporalSnapshotWithCleanStagingData(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalSnapshotWithCleanStagingData(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalSnasphotValidationBatchIdInMissing()
{
java.lang.String[] v;
org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases v;
java.util.Map v;
java.lang.String v, v, v;
org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder v, v, v, v, v;
org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder v, v;
java.lang.Exception v;
java.util.List v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases;
label:
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder builder()>();
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String digestField>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder digestField(java.lang.String)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder builder()>();
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String batchIdOutField>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder batchIdOutName(java.lang.String)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder transactionMilestoning(org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.TransactionMilestoning)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String[] partitionKeys>;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder addAllPartitionFields(java.lang.Iterable)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.util.Map partitionFilter>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder putAllPartitionValuesByField(java.util.Map)>(v);
virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot build()>();
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("Exception was not thrown");
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("Cannot build BatchId, some of required attributes are not set [batchIdInName]", v);
label:
return;
catch java.lang.Exception from label to label with label;
}
void testUnitemporalSnapshotValidationBatchIdInNotPrimaryKey()
{
org.finos.legend.engine.persistence.components.ingestmode.IngestMode v;
org.finos.legend.engine.persistence.components.common.Datasets v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v, v;
java.lang.String v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder v, v, v, v, v;
java.lang.Exception v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalSnapshotBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__WITHOUT_PARTITIONS__NO_DEDUP__NO_VERSION()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.ingestmode.IngestMode getIngestMode()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder ingestMode(org.finos.legend.engine.persistence.components.ingestmode.IngestMode)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.relational.RelationalSink getRelationalSink()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder relationalSink(org.finos.legend.engine.persistence.components.relational.RelationalSink)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.time.Clock fixedClock_2000_01_01>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder executionTimestampClock(java.time.Clock)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder collectStatistics(boolean)>(1);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset getMainTable()>();
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition mainTableBatchIdBasedSchemaWithBatchIdInNotPrimary>;
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset withSchema(org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaDefinition)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset getStagingTable()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.common.Datasets: org.finos.legend.engine.persistence.components.common.Datasets of(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset,org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset)>(v, v);
label:
virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: org.finos.legend.engine.persistence.components.relational.api.GeneratorResult generateOperations(org.finos.legend.engine.persistence.components.common.Datasets)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("Exception was not thrown");
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("Field \"batch_id_in\" must be a primary key", v);
label:
return;
catch java.lang.Exception from label to label with label;
}
void testUnitemporalSnapshotValidationMainDatasetMissing()
{
org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v;
java.lang.String v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases v;
java.lang.Exception v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases;
label:
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset stagingTableWithBaseSchemaAndDigest>;
staticinvoke <org.finos.legend.engine.persistence.components.common.Datasets: org.finos.legend.engine.persistence.components.common.Datasets of(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset,org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset)>(null, v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("Exception was not thrown");
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("mainDataset", v);
label:
return;
catch java.lang.Exception from label to label with label;
}
void testUnitemporalSnapshotAllVersionValidation()
{
org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases v;
org.finos.legend.engine.persistence.components.ingestmode.versioning.AllVersionsStrategy$Builder v, v;
java.lang.String v, v, v, v;
org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder v, v, v, v;
org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder v, v, v;
java.lang.Exception v;
org.finos.legend.engine.persistence.components.ingestmode.versioning.AllVersionsStrategy v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases;
label:
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder builder()>();
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String digestField>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder digestField(java.lang.String)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder builder()>();
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String batchIdInField>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder batchIdInName(java.lang.String)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String batchIdOutField>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder batchIdOutName(java.lang.String)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder transactionMilestoning(org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.TransactionMilestoning)>(v);
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)>("xyz");
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.versioning.AllVersionsStrategy$Builder: org.finos.legend.engine.persistence.components.ingestmode.versioning.AllVersionsStrategy build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder versioningStrategy(org.finos.legend.engine.persistence.components.ingestmode.versioning.VersioningStrategy)>(v);
virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot build()>();
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("Exception was not thrown");
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("Cannot build UnitemporalSnapshot, AllVersionsStrategy not supported", v);
label:
return;
catch java.lang.Exception from label to label with label;
}
void testUnitemporalSnapshotPartitionFilterWithMultiValuesForMultipleKeysValidation()
{
org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData v;
java.lang.String[] v;
org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases v;
java.util.Map v;
java.lang.String v, v, v, v;
org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData$Builder v;
org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder v, v, v;
java.lang.Exception v;
java.util.List v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases;
label:
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder builder()>();
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String digestField>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder digestField(java.lang.String)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder builder()>();
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String batchIdInField>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder batchIdInName(java.lang.String)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String batchIdOutField>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder batchIdOutName(java.lang.String)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder transactionMilestoning(org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.TransactionMilestoning)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String[] partitionKeysMulti>;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder addAllPartitionFields(java.lang.Iterable)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.util.Map partitionFilterWithMultiValuesForMultipleKeys>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder putAllPartitionValuesByField(java.util.Map)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData: org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData$Builder: org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder emptyDatasetHandling(org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.EmptyDatasetHandling)>(v);
virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot build()>();
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("Exception was not thrown");
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("Can not build UnitemporalSnapshot, in partitionValuesByField at most one of the partition keys can have more than one value, all other partition keys must have exactly one value", v);
label:
return;
catch java.lang.Exception from label to label with label;
}
void testUnitemporalSnapshotPartitionFilterWithMultiValuesForOneKeyValidation()
{
org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData v;
java.lang.String[] v;
org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases v;
java.util.Map v;
java.lang.String v, v, v;
org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData$Builder v;
org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder v, v, v;
java.lang.Exception v;
java.util.List v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases;
label:
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder builder()>();
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String digestField>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder digestField(java.lang.String)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder builder()>();
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String batchIdInField>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder batchIdInName(java.lang.String)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String batchIdOutField>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder batchIdOutName(java.lang.String)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder transactionMilestoning(org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.TransactionMilestoning)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String[] partitionKeysMulti>;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder addAllPartitionFields(java.lang.Iterable)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.util.Map partitionFilterWithMultiValuesForOneKey>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder putAllPartitionValuesByField(java.util.Map)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData: org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData$Builder: org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder emptyDatasetHandling(org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.EmptyDatasetHandling)>(v);
virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot build()>();
label:
goto label;
label:
v := @caughtexception;
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("No Exception expected for multi values for one key");
label:
return;
catch java.lang.Exception from label to label with label;
}
void testUnitemporalSnapshotBothPartitionFilterAndPartitionSpecListProvidedValidation()
{
org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData v;
java.lang.String[] v;
org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases v;
java.util.Map v;
java.lang.String v, v, v, v;
org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData$Builder v;
org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder v, v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder v, v, v;
java.lang.Exception v;
java.util.List v, v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases;
label:
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder builder()>();
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String digestField>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder digestField(java.lang.String)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder builder()>();
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String batchIdInField>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder batchIdInName(java.lang.String)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String batchIdOutField>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder batchIdOutName(java.lang.String)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder transactionMilestoning(org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.TransactionMilestoning)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String[] partitionKeysMulti>;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder addAllPartitionFields(java.lang.Iterable)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.util.Map partitionFilterWithMultiValuesForOneKey>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder putAllPartitionValuesByField(java.util.Map)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.util.List partitionSpecList()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder addAllPartitionSpecList(java.lang.Iterable)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData: org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData$Builder: org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder emptyDatasetHandling(org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.EmptyDatasetHandling)>(v);
virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot build()>();
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("Exception was not thrown");
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("Can not build UnitemporalSnapshot, Provide either partitionValuesByField or partitionSpecList, both not supported together", v);
label:
return;
catch java.lang.Exception from label to label with label;
}
void testUnitemporalSnapshotPartitionKeyMismatchValidation()
{
org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData v;
java.lang.String[] v;
org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases v;
java.lang.String v, v, v, v;
org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData$Builder v;
org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder v, v, v;
java.lang.Exception v;
java.util.List v, v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases;
label:
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder builder()>();
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String digestField>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder digestField(java.lang.String)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder builder()>();
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String batchIdInField>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder batchIdInName(java.lang.String)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String batchIdOutField>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder batchIdOutName(java.lang.String)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder transactionMilestoning(org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.TransactionMilestoning)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.lang.String[] partitionKeys>;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder addAllPartitionFields(java.lang.Iterable)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalSnapshotBatchIdBasedTestCases: java.util.List partitionSpecList()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder addAllPartitionSpecList(java.lang.Iterable)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData: org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData$Builder: org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.DeleteTargetData build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder emptyDatasetHandling(org.finos.legend.engine.persistence.components.ingestmode.emptyhandling.EmptyDatasetHandling)>(v);
virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalSnapshot build()>();
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object fail(java.lang.String)>("Exception was not thrown");
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("Can not build UnitemporalSnapshot, size of each partitionSpec must be same as size of partitionFields", v);
label:
return;
catch java.lang.Exception from label to label with label;
}
public abstract org.finos.legend.engine.persistence.components.relational.RelationalSink getRelationalSink();
}