Class MergeDuplicatesLoadStep

java.lang.Object

com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.AbstractLoadStep

com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.LoadViaInsertOrUpdateStep

com.kingsrook.qqq.backend.core.processes.implementations.mergeduplicates.MergeDuplicatesLoadStep

public class MergeDuplicatesLoadStep
extends LoadViaInsertOrUpdateStep

Generic ETL Load step for a merge duplicates process. Uses otherTable* fields from the process state to do additional deletes, inserts and/or updates.

Field Summary

Fields inherited from class com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.LoadViaInsertOrUpdateStep

FIELD_DESTINATION_TABLE, FIELD_SKIP_UNIQUE_KEY_CHECK, recordsToInsert, recordsToUpdate

Fields inherited from class com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.AbstractLoadStep

session

Constructor Summary

Constructors

Constructor	Description
MergeDuplicatesLoadStep()

Method Summary

Modifier and Type	Method	Description
void	runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput)	Execute the backend step - using the request as input, and the result as output.

Methods inherited from class com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.LoadViaInsertOrUpdateStep

evaluateRecords, getInputSource, insertAndUpdateRecords, openTransaction, splitRecordsForInsertOrUpdate

Methods inherited from class com.kingsrook.qqq.backend.core.processes.implementations.etl.streamedwithfrontend.AbstractLoadStep

getOverrideRecordPipeCapacity, getTransaction, getTransformStep, postRun, preRun, setTransaction, setTransformStep, withTransformStep

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MergeDuplicatesLoadStep

public MergeDuplicatesLoadStep()

Method Details

runOnePage

public void runOnePage(RunBackendStepInput runBackendStepInput,
 RunBackendStepOutput runBackendStepOutput)
                throws QException

Description copied from class: LoadViaInsertOrUpdateStep

Execute the backend step - using the request as input, and the result as output.

Overrides:

runOnePage in class LoadViaInsertOrUpdateStep

Throws:

QException