From 040dae55d5022752c1339f38b02c4f21b71206e8 Mon Sep 17 00:00:00 2001 From: Darin Kelkhoff Date: Mon, 19 Dec 2022 14:59:58 -0600 Subject: [PATCH] Add withSchedule; fix return on withBasepullConfiguration; add overload withTransformStepClass --- .../tablesync/TableSyncProcess.java | 28 ++++++++++++++++++- 1 file changed, 27 insertions(+), 1 deletion(-) diff --git a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/tablesync/TableSyncProcess.java b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/tablesync/TableSyncProcess.java index fff49bc1..60e45da7 100644 --- a/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/tablesync/TableSyncProcess.java +++ b/qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/tablesync/TableSyncProcess.java @@ -31,8 +31,10 @@ import com.kingsrook.qqq.backend.core.model.metadata.fields.QFieldType; import com.kingsrook.qqq.backend.core.model.metadata.layout.QIcon; import com.kingsrook.qqq.backend.core.model.metadata.processes.QFrontendStepMetaData; import com.kingsrook.qqq.backend.core.model.metadata.processes.QProcessMetaData; +import com.kingsrook.qqq.backend.core.model.metadata.scheduleing.QScheduleMetaData; import com.kingsrook.qqq.backend.core.processes.implementations.basepull.BasepullConfiguration; import com.kingsrook.qqq.backend.core.processes.implementations.basepull.ExtractViaBasepullQueryStep; +import com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.AbstractTransformStep; import com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.ExtractViaQueryStep; import com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.LoadViaInsertOrUpdateStep; import com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.StreamedETLWithFrontendProcess; @@ -85,6 +87,17 @@ public class TableSyncProcess + /******************************************************************************* + ** Fluent setter for transformStepClass + ** + *******************************************************************************/ + public Builder withTransformStepClass(Class transformStepClass) + { + throw (new IllegalArgumentException("withTransformStepClass should not be called in a TableSyncProcess. You probably meant withSyncTransformStepClass")); + } + + + /******************************************************************************* ** Fluent setter for transformStepClass. Note - call this method also makes ** sourceTable and destinationTable be set - by getting them from the @@ -181,10 +194,23 @@ public class TableSyncProcess ** *******************************************************************************/ @Override - public StreamedETLWithFrontendProcess.Builder withBasepullConfiguration(BasepullConfiguration basepullConfiguration) + public Builder withBasepullConfiguration(BasepullConfiguration basepullConfiguration) { processMetaData.setBasepullConfiguration(basepullConfiguration); return (this); } + + + + /******************************************************************************* + ** + *******************************************************************************/ + @Override + public Builder withSchedule(QScheduleMetaData schedule) + { + processMetaData.setSchedule(schedule); + return (this); + } + } }