public abstract class org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases extends org.finos.legend.engine.persistence.components.BaseTest
{
org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios scenarios;
public void <init>()
{
org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases;
specialinvoke v.<org.finos.legend.engine.persistence.components.BaseTest: void <init>()>();
v = new org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios;
specialinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios: void <init>()>();
v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios scenarios> = v;
return;
}
void testUnitemporalDeltaNoDeleteIndNoDedupNoVersion()
{
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.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases 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;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__NO_DEL_IND__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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: void verifyUnitemporalDeltaNoDeleteIndNoDedupNoVersion(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalDeltaNoDeleteIndNoDedupNoVersion(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalDeltaNoDeleteIndNoDedupAllVersionsWithoutPerform()
{
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.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder v, v, v, v, v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios v;
java.util.List v, v, v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__NO_DEL_IND__NO_DEDUP__ALL_VERSION_WITHOUT_PERFORM()>();
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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: 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 = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: java.util.List dataSplitRangesOneToTwo>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: java.util.List generateOperationsWithDataSplits(org.finos.legend.engine.persistence.components.common.Datasets,java.util.List)>(v, v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: java.util.List dataSplitRangesOneToTwo>;
virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: void verifyUnitemporalDeltaNoDeleteIndNoDedupAllVersionsWithoutPerform(java.util.List,java.util.List)>(v, v);
return;
}
public abstract void verifyUnitemporalDeltaNoDeleteIndNoDedupAllVersionsWithoutPerform(java.util.List, java.util.List);
void testUnitemporalDeltaWithDeleteIndFilterDupsNoVersion()
{
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.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
java.lang.String v, v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases 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;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__WITH_DEL_IND__FILTER_DUPS__NO_VERSIONING()>();
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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: 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 = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: 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 = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: java.lang.String ingestRequestId>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder ingestRequestId(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$Builder writeStatistics(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.UnitmemporalDeltaBatchIdBasedTestCases: void verifyUnitemporalDeltaWithDeleteIndFilterDupsNoVersion(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalDeltaWithDeleteIndFilterDupsNoVersion(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalDeltaWithDeleteIndNoDedupAllVersion()
{
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.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
java.lang.String v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios v;
java.util.List v, v, v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__WITH_DEL_IND__NO_DEDUP__ALL_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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: 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 = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: 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 = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: java.util.List dataSplitRangesOneToTwo>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator: java.util.List generateOperationsWithDataSplits(org.finos.legend.engine.persistence.components.common.Datasets,java.util.List)>(v, v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: java.util.List dataSplitRangesOneToTwo>;
virtualinvoke v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: void verifyUnitemporalDeltaWithDeleteIndNoDedupAllVersion(java.util.List,java.util.List)>(v, v);
return;
}
public abstract void verifyUnitemporalDeltaWithDeleteIndNoDedupAllVersion(java.util.List, java.util.List);
void testUnitemporalDeltaWithUpperCaseOptimizer()
{
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.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases 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;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__NO_DEL_IND__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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: 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 = <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$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 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.UnitmemporalDeltaBatchIdBasedTestCases: void verifyUnitemporalDeltaWithUpperCaseOptimizer(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalDeltaWithUpperCaseOptimizer(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalDeltaWithCleanStagingData()
{
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.relational.api.RelationalGenerator$Builder v, v, v, v, v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
java.time.Clock v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__NO_DEL_IND__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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: 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 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.UnitmemporalDeltaBatchIdBasedTestCases: void verifyUnitemporalDeltaWithCleanStagingData(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalDeltaWithCleanStagingData(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalDeltaNoDeleteIndWithOptimizationFilters()
{
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.relational.api.RelationalGenerator$Builder v, v, v, v, v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
java.time.Clock v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__NO_DEL_IND__WITH_OPTIMIZATION_FILTERS()>();
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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: void verifyUnitemporalDeltaNoDeleteIndWithOptimizationFilters(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalDeltaNoDeleteIndWithOptimizationFilters(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalDeltaNoDeleteIndWithOptimizationFiltersIncludesNullValues()
{
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.relational.api.RelationalGenerator$Builder v, v, v, v, v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
java.time.Clock v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__NO_DEL_IND__WITH_OPTIMIZATION_FILTERS__INCLUDES_NULL_VALUES()>();
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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: void verifyUnitemporalDeltaNoDeleteIndWithOptimizationFiltersIncludesNullValues(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalDeltaNoDeleteIndWithOptimizationFiltersIncludesNullValues(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalDeltaValidationBatchIdOutMissing()
{
java.lang.String[] v;
org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId v;
org.finos.legend.engine.persistence.components.ingestmode.UnitemporalDelta$Builder v, v, v, v;
java.lang.String v, v, v, v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases v;
org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchId$Builder v, v;
org.finos.legend.engine.persistence.components.ingestmode.merge.DeleteIndicatorMergeStrategy$Builder v, v, v;
java.lang.Exception v;
java.util.List v;
org.finos.legend.engine.persistence.components.ingestmode.merge.DeleteIndicatorMergeStrategy v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases;
label:
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.UnitemporalDelta: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalDelta$Builder builder()>();
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: java.lang.String digestField>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalDelta$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalDelta$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.UnitmemporalDeltaBatchIdBasedTestCases: 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 = 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.UnitemporalDelta$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalDelta$Builder transactionMilestoning(org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.TransactionMilestoning)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.merge.DeleteIndicatorMergeStrategy: org.finos.legend.engine.persistence.components.ingestmode.merge.DeleteIndicatorMergeStrategy$Builder builder()>();
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: java.lang.String deleteIndicatorField>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.merge.DeleteIndicatorMergeStrategy$Builder: org.finos.legend.engine.persistence.components.ingestmode.merge.DeleteIndicatorMergeStrategy$Builder deleteField(java.lang.String)>(v);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: java.lang.String[] deleteIndicatorValues>;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.merge.DeleteIndicatorMergeStrategy$Builder: org.finos.legend.engine.persistence.components.ingestmode.merge.DeleteIndicatorMergeStrategy$Builder addAllDeleteValues(java.lang.Iterable)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.merge.DeleteIndicatorMergeStrategy$Builder: org.finos.legend.engine.persistence.components.ingestmode.merge.DeleteIndicatorMergeStrategy build()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalDelta$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalDelta$Builder mergeStrategy(org.finos.legend.engine.persistence.components.ingestmode.merge.MergeStrategy)>(v);
virtualinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.UnitemporalDelta$Builder: org.finos.legend.engine.persistence.components.ingestmode.UnitemporalDelta 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 [batchIdOutName]", v);
label:
return;
catch java.lang.Exception from label to label with label;
}
void testUnitemporalDeltaValidationBatchIdInNotPrimaryKey()
{
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.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.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases v;
org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder v, v, v, v, v;
java.lang.Exception v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__NO_DEL_IND__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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: 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 testUnitemporalDeltaValidationOptimizationColumnsNotPresent()
{
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.api.RelationalGenerator$Builder v, v, v, v, v;
java.lang.Exception v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
java.time.Clock v;
java.lang.String v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__NO_DEL_IND__WITH_MISSING_OPTIMIZATION_FILTER()>();
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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: 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()>();
label:
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.common.Datasets getDatasets()>();
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)>("Optimization filter [unknown_column] not found in Staging Schema", v);
label:
return;
catch java.lang.Exception from label to label with label;
}
void testUnitemporalDeltaValidationOptimizationColumnUnsupportedDataType()
{
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.api.RelationalGenerator$Builder v, v, v, v, v;
java.lang.Exception v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
java.time.Clock v;
java.lang.String v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__NO_DEL_IND__WITH_OPTIMIZATION_FILTER_UNSUPPORTED_DATATYPE()>();
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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: 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()>();
label:
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.TestScenario: org.finos.legend.engine.persistence.components.common.Datasets getDatasets()>();
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)>("Optimization filter\'s data type [VARCHAR] is not supported", v);
label:
return;
catch java.lang.Exception from label to label with label;
}
void testUnitemporalDeltaWithNoVersioningAndStagingFilters()
{
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.RelationalSink v;
java.util.Map v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases 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;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__NO_VERSIONING__WITH_STAGING_FILTER()>();
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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: 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)>(0);
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>("watermark", "my_watermark_value");
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder putAllAdditionalMetadata(java.util.Map)>(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.UnitmemporalDeltaBatchIdBasedTestCases: void verifyUnitemporalDeltaWithNoVersionAndStagingFilter(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalDeltaWithNoVersionAndStagingFilter(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalDeltaWithNoVersioningAndFilteredDataset()
{
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.relational.api.RelationalGenerator$Builder v, v, v, v, v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
java.time.Clock v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__NO_VERSIONING__WITH_FILTERED_DATASET()>();
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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: 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)>(0);
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.UnitmemporalDeltaBatchIdBasedTestCases: void verifyUnitemporalDeltaWithNoVersionAndFilteredDataset(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalDeltaWithNoVersionAndFilteredDataset(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalDeltaWithFilterDupsMaxVersionWithStagingFilter()
{
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.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
java.lang.String v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases 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;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__FILTER_DUPS__MAX_VERSION__WITH_STAGING_FILTER()>();
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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: 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)>(0);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: void verifyUnitemporalDeltaWithFilterDupsMaxVersionWithStagingFilter(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalDeltaWithFilterDupsMaxVersionWithStagingFilter(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalDeltaWithFilterDupsMaxVersionWithFilteredDataset()
{
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.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
java.lang.String v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases 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;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__FILTER_DUPS__MAX_VERSION__WITH_FILTERED_DATASET()>();
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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: 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)>(0);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: void verifyUnitemporalDeltaWithFilterDupsMaxVersionWithFilteredDataset(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalDeltaWithFilterDupsMaxVersionWithFilteredDataset(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalDeltaWithNoDedupMaxVersionWithoutPerformAndStagingFilters()
{
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.relational.api.RelationalGenerator$Builder v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
java.time.Clock v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__NO_DEDUP__MAX_VERSION_WITHOUT_PERFORM__WITH_STAGING_FILTER()>();
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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: 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)>(0);
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.UnitmemporalDeltaBatchIdBasedTestCases: void verifyUnitemporalDeltaWithNoDedupMaxVersionWithoutPerformAndStagingFilters(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalDeltaWithNoDedupMaxVersionWithoutPerformAndStagingFilters(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalDeltaWithFailOnDupsMaxVersioningWithoutPerform()
{
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.RelationalSink v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
java.lang.String v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases 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;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__FAIL_ON_DUPS__MAX_VERSIONING_WITHOUT_PERFORM__NO_STAGING_FILTER()>();
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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: 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 batchSuccessStatusValue(java.lang.String)>("SUCCEEDED");
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: void verifyUnitemporalDeltaWithFailOnDupsMaxVersioningWithoutPerform(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalDeltaWithFailOnDupsMaxVersioningWithoutPerform(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
void testUnitemporalDeltaWithNoDedupMaxVersioningAndUpperCaseWithoutStagingFilters()
{
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.relational.RelationalSink v;
java.util.Map v;
org.finos.legend.engine.persistence.components.scenarios.TestScenario v;
java.lang.String v;
org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases 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, v;
org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios v;
java.time.Clock v;
v := @this: org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases;
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios scenarios>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.scenarios.UnitemporalDeltaBatchIdBasedScenarios: org.finos.legend.engine.persistence.components.scenarios.TestScenario BATCH_ID_BASED__NO_DEDUP__MAX_VERSIONING__NO_STAGING_FILTER()>();
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.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: 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 = <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 = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>("watermark", "my_watermark_value");
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder putAllAdditionalMetadata(java.util.Map)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder: org.finos.legend.engine.persistence.components.relational.api.RelationalGenerator$Builder sampleRowCount(int)>(10);
v = v.<org.finos.legend.engine.persistence.components.testcases.ingestmode.unitemporal.UnitmemporalDeltaBatchIdBasedTestCases: 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.UnitmemporalDeltaBatchIdBasedTestCases: void verifyUnitemporalDeltaWithNoDedupMaxVersioningAndUpperCaseWithoutStagingFilters(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult)>(v);
return;
}
public abstract void verifyUnitemporalDeltaWithNoDedupMaxVersioningAndUpperCaseWithoutStagingFilters(org.finos.legend.engine.persistence.components.relational.api.GeneratorResult);
public abstract org.finos.legend.engine.persistence.components.relational.RelationalSink getRelationalSink();
}