QRunIO/qqq
2
0
Fork 0
mirror of https://github.com/Kingsrook/qqq.git synced 2025-07-18 05:01:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add withSchedule; fix return on withBasepullConfiguration; add overload withTransformStepClass

Browse Source
This commit is contained in:
darin.kelkhoff
2022-12-19 14:59:58 -06:00
parent dd9253fde4
commit 040dae55d5
1 changed files with 27 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
qqq-backend-core/src/main/java/com/kingsrook/qqq/backend/core/processes/implementations/tablesync/TableSyncProcess.java
View File

@ -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.layout.QIcon;
import com.kingsrook.qqq.backend.core.model.metadata.processes.QFrontendStepMetaData; 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.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.BasepullConfiguration;
import com.kingsrook.qqq.backend.core.processes.implementations.basepull.ExtractViaBasepullQueryStep; 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.ExtractViaQueryStep;
import com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.LoadViaInsertOrUpdateStep; import com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.LoadViaInsertOrUpdateStep;
import com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.StreamedETLWithFrontendProcess; 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<? extends AbstractTransformStep> 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 ** Fluent setter for transformStepClass. Note - call this method also makes
** sourceTable and destinationTable be set - by getting them from the ** sourceTable and destinationTable be set - by getting them from the
@ -181,10 +194,23 @@ public class TableSyncProcess
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public StreamedETLWithFrontendProcess.Builder withBasepullConfiguration(BasepullConfiguration basepullConfiguration) public Builder withBasepullConfiguration(BasepullConfiguration basepullConfiguration)
{ {
processMetaData.setBasepullConfiguration(basepullConfiguration); processMetaData.setBasepullConfiguration(basepullConfiguration);
return (this); return (this);
} }
/*******************************************************************************
**
*******************************************************************************/
@Override
public Builder withSchedule(QScheduleMetaData schedule)
{
processMetaData.setSchedule(schedule);
return (this);
}
} }
} }