class org.finos.legend.engine.persistence.components.planner.UnitemporalPlanner$DetermineRowsAddedInSinkCondition extends java.lang.Object implements org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.TransactionMilestoningVisitor
{
private final org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset mainDataset;
private final org.finos.legend.engine.persistence.components.logicalplan.values.StringValue mainTableName;
private final org.finos.legend.engine.persistence.components.util.MetadataUtils metadataUtils;
private final org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp batchStartTimestamp;
private void <init>(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, org.finos.legend.engine.persistence.components.logicalplan.values.StringValue, org.finos.legend.engine.persistence.components.util.MetadataUtils, org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp)
{
org.finos.legend.engine.persistence.components.planner.UnitemporalPlanner$DetermineRowsAddedInSinkCondition v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v;
org.finos.legend.engine.persistence.components.logicalplan.values.StringValue v;
org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp v;
org.finos.legend.engine.persistence.components.util.MetadataUtils v;
v := @this: org.finos.legend.engine.persistence.components.planner.UnitemporalPlanner$DetermineRowsAddedInSinkCondition;
v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset;
v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue;
v := @parameter: org.finos.legend.engine.persistence.components.util.MetadataUtils;
v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.finos.legend.engine.persistence.components.planner.UnitemporalPlanner$DetermineRowsAddedInSinkCondition: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset mainDataset> = v;
v.<org.finos.legend.engine.persistence.components.planner.UnitemporalPlanner$DetermineRowsAddedInSinkCondition: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue mainTableName> = v;
v.<org.finos.legend.engine.persistence.components.planner.UnitemporalPlanner$DetermineRowsAddedInSinkCondition: org.finos.legend.engine.persistence.components.util.MetadataUtils metadataUtils> = v;
v.<org.finos.legend.engine.persistence.components.planner.UnitemporalPlanner$DetermineRowsAddedInSinkCondition: org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp batchStartTimestamp> = v;
return;
}
public org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition visitBatchId(org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchIdAbstract)
{
org.finos.legend.engine.persistence.components.util.MetadataUtils v;
org.finos.legend.engine.persistence.components.planner.UnitemporalPlanner$DetermineRowsAddedInSinkCondition v;
org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchIdAbstract v;
org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition v;
org.finos.legend.engine.persistence.components.logicalplan.values.BatchIdValue v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v;
org.finos.legend.engine.persistence.components.logicalplan.values.StringValue v;
java.lang.String v;
v := @this: org.finos.legend.engine.persistence.components.planner.UnitemporalPlanner$DetermineRowsAddedInSinkCondition;
v := @parameter: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchIdAbstract;
v = v.<org.finos.legend.engine.persistence.components.planner.UnitemporalPlanner$DetermineRowsAddedInSinkCondition: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset mainDataset>;
v = v.<org.finos.legend.engine.persistence.components.planner.UnitemporalPlanner$DetermineRowsAddedInSinkCondition: org.finos.legend.engine.persistence.components.util.MetadataUtils metadataUtils>;
v = v.<org.finos.legend.engine.persistence.components.planner.UnitemporalPlanner$DetermineRowsAddedInSinkCondition: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue mainTableName>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: org.finos.legend.engine.persistence.components.logicalplan.values.BatchIdValue getBatchId(org.finos.legend.engine.persistence.components.logicalplan.values.StringValue)>(v);
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchIdAbstract: java.lang.String batchIdInName()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.util.LogicalPlanUtils: org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition getBatchIdEqualityCondition(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset,org.finos.legend.engine.persistence.components.logicalplan.values.Value,java.lang.String)>(v, v, v);
return v;
}
public org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition visitDateTime(org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.TransactionDateTimeAbstract)
{
org.finos.legend.engine.persistence.components.planner.UnitemporalPlanner$DetermineRowsAddedInSinkCondition v;
org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v;
java.lang.String v;
org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp v;
org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.TransactionDateTimeAbstract v;
v := @this: org.finos.legend.engine.persistence.components.planner.UnitemporalPlanner$DetermineRowsAddedInSinkCondition;
v := @parameter: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.TransactionDateTimeAbstract;
v = v.<org.finos.legend.engine.persistence.components.planner.UnitemporalPlanner$DetermineRowsAddedInSinkCondition: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset mainDataset>;
v = v.<org.finos.legend.engine.persistence.components.planner.UnitemporalPlanner$DetermineRowsAddedInSinkCondition: org.finos.legend.engine.persistence.components.logicalplan.values.BatchStartTimestamp batchStartTimestamp>;
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.TransactionDateTimeAbstract: java.lang.String dateTimeInName()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.util.LogicalPlanUtils: org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition getBatchTimeEqualityCondition(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset,org.finos.legend.engine.persistence.components.logicalplan.values.Value,java.lang.String)>(v, v, v);
return v;
}
public org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition visitBatchIdAndDateTime(org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchIdAndDateTimeAbstract)
{
org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchIdAndDateTimeAbstract v;
org.finos.legend.engine.persistence.components.util.MetadataUtils v;
org.finos.legend.engine.persistence.components.planner.UnitemporalPlanner$DetermineRowsAddedInSinkCondition v;
org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition v;
org.finos.legend.engine.persistence.components.logicalplan.values.BatchIdValue v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v;
org.finos.legend.engine.persistence.components.logicalplan.values.StringValue v;
java.lang.String v;
v := @this: org.finos.legend.engine.persistence.components.planner.UnitemporalPlanner$DetermineRowsAddedInSinkCondition;
v := @parameter: org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchIdAndDateTimeAbstract;
v = v.<org.finos.legend.engine.persistence.components.planner.UnitemporalPlanner$DetermineRowsAddedInSinkCondition: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset mainDataset>;
v = v.<org.finos.legend.engine.persistence.components.planner.UnitemporalPlanner$DetermineRowsAddedInSinkCondition: org.finos.legend.engine.persistence.components.util.MetadataUtils metadataUtils>;
v = v.<org.finos.legend.engine.persistence.components.planner.UnitemporalPlanner$DetermineRowsAddedInSinkCondition: org.finos.legend.engine.persistence.components.logicalplan.values.StringValue mainTableName>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.MetadataUtils: org.finos.legend.engine.persistence.components.logicalplan.values.BatchIdValue getBatchId(org.finos.legend.engine.persistence.components.logicalplan.values.StringValue)>(v);
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.transactionmilestoning.BatchIdAndDateTimeAbstract: java.lang.String batchIdInName()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.util.LogicalPlanUtils: org.finos.legend.engine.persistence.components.logicalplan.conditions.Condition getBatchIdEqualityCondition(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset,org.finos.legend.engine.persistence.components.logicalplan.values.Value,java.lang.String)>(v, v, v);
return v;
}
}