Merge pull request #94 from Kingsrook/feature/rename-run-to-runOnePage

Rename 'run' to 'runOnePage'
This commit is contained in:
2024-06-04 19:54:57 -05:00
committed by GitHub
31 changed files with 45 additions and 43 deletions

View File

@ -457,7 +457,7 @@ public class GenerateReportAction extends AbstractQActionFunction<ReportInput, R
if(finalTransformStep != null) if(finalTransformStep != null)
{ {
finalTransformStepInput.setRecords(records); finalTransformStepInput.setRecords(records);
finalTransformStep.run(finalTransformStepInput, finalTransformStepOutput); finalTransformStep.runOnePage(finalTransformStepInput, finalTransformStepOutput);
records = finalTransformStepOutput.getRecords(); records = finalTransformStepOutput.getRecords();
} }

View File

@ -112,12 +112,12 @@ public class BulkDeleteLoadStep extends LoadViaDeleteStep implements ProcessSumm
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
//////////////////////////// ////////////////////////////
// have base class delete // // have base class delete //
//////////////////////////// ////////////////////////////
super.run(runBackendStepInput, runBackendStepOutput); super.runOnePage(runBackendStepInput, runBackendStepOutput);
QTableMetaData table = runBackendStepInput.getInstance().getTable(runBackendStepInput.getTableName()); QTableMetaData table = runBackendStepInput.getInstance().getTable(runBackendStepInput.getTableName());
String primaryKeyFieldName = table.getPrimaryKeyField(); String primaryKeyFieldName = table.getPrimaryKeyField();

View File

@ -78,7 +78,7 @@ public class BulkDeleteTransformStep extends AbstractTransformStep
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
QTableMetaData table = runBackendStepInput.getTable(); QTableMetaData table = runBackendStepInput.getTable();
String primaryKeyField = table.getPrimaryKeyField(); String primaryKeyField = table.getPrimaryKeyField();

View File

@ -114,12 +114,12 @@ public class BulkEditLoadStep extends LoadViaUpdateStep implements ProcessSummar
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
//////////////////////////// ////////////////////////////
// have base class update // // have base class update //
//////////////////////////// ////////////////////////////
super.run(runBackendStepInput, runBackendStepOutput); super.runOnePage(runBackendStepInput, runBackendStepOutput);
//////////////////////////////////////////////////////// ////////////////////////////////////////////////////////
// roll up results based on output from update action // // roll up results based on output from update action //

View File

@ -103,7 +103,7 @@ public class BulkEditTransformStep extends AbstractTransformStep
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
///////////////////////////////////////////////////////////////////////////////////////////////////////////////// /////////////////////////////////////////////////////////////////////////////////////////////////////////////////
// on the validate step, we haven't read the full file, so we don't know how many rows there are - thus // // on the validate step, we haven't read the full file, so we don't know how many rows there are - thus //

View File

@ -118,7 +118,7 @@ public class BulkInsertTransformStep extends AbstractTransformStep
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
int rowsInThisPage = runBackendStepInput.getRecords().size(); int rowsInThisPage = runBackendStepInput.getRecords().size();
QTableMetaData table = runBackendStepInput.getInstance().getTable(runBackendStepInput.getTableName()); QTableMetaData table = runBackendStepInput.getInstance().getTable(runBackendStepInput.getTableName());

View File

@ -61,7 +61,7 @@ public class LoadViaDeleteStep extends AbstractLoadStep
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
QTableMetaData table = runBackendStepInput.getTable(); QTableMetaData table = runBackendStepInput.getTable();

View File

@ -73,7 +73,7 @@ public class LoadViaInsertOrUpdateStep extends AbstractLoadStep
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
evaluateRecords(runBackendStepInput); evaluateRecords(runBackendStepInput);
insertAndUpdateRecords(runBackendStepInput, runBackendStepOutput); insertAndUpdateRecords(runBackendStepInput, runBackendStepOutput);

View File

@ -60,7 +60,7 @@ public class LoadViaInsertStep extends AbstractLoadStep
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
InsertInput insertInput = new InsertInput(); InsertInput insertInput = new InsertInput();
insertInput.setInputSource(getInputSource()); insertInput.setInputSource(getInputSource());

View File

@ -62,7 +62,7 @@ public class LoadViaUpdateStep extends AbstractLoadStep
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
UpdateInput updateInput = new UpdateInput(); UpdateInput updateInput = new UpdateInput();
updateInput.setInputSource(getInputSource()); updateInput.setInputSource(getInputSource());

View File

@ -40,7 +40,7 @@ public class NoopLoadStep extends AbstractLoadStep
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
/////////// ///////////
// noop. // // noop. //

View File

@ -67,7 +67,7 @@ public class NoopTransformStep extends AbstractTransformStep
* *
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
//////////////////////////////// ////////////////////////////////
// return if no input records // // return if no input records //

View File

@ -267,7 +267,7 @@ public class StreamedETLExecuteStep extends BaseStreamedETLStep implements Backe
///////////////////////////////////////////////////// /////////////////////////////////////////////////////
// pass the records through the transform function // // pass the records through the transform function //
///////////////////////////////////////////////////// /////////////////////////////////////////////////////
transformStep.run(streamedBackendStepInput, streamedBackendStepOutput); transformStep.runOnePage(streamedBackendStepInput, streamedBackendStepOutput);
List<AuditInput> auditInputListFromTransform = streamedBackendStepOutput.getAuditInputList(); List<AuditInput> auditInputListFromTransform = streamedBackendStepOutput.getAuditInputList();
//////////////////////////////////////////////// ////////////////////////////////////////////////
@ -276,7 +276,7 @@ public class StreamedETLExecuteStep extends BaseStreamedETLStep implements Backe
streamedBackendStepInput = new StreamedBackendStepInput(runBackendStepInput, streamedBackendStepOutput.getRecords()); streamedBackendStepInput = new StreamedBackendStepInput(runBackendStepInput, streamedBackendStepOutput.getRecords());
streamedBackendStepOutput = new StreamedBackendStepOutput(runBackendStepOutput); streamedBackendStepOutput = new StreamedBackendStepOutput(runBackendStepOutput);
loadStep.run(streamedBackendStepInput, streamedBackendStepOutput); loadStep.runOnePage(streamedBackendStepInput, streamedBackendStepOutput);
List<AuditInput> auditInputListFromLoad = streamedBackendStepOutput.getAuditInputList(); List<AuditInput> auditInputListFromLoad = streamedBackendStepOutput.getAuditInputList();
/////////////////////////////////////////////////////// ///////////////////////////////////////////////////////

View File

@ -206,7 +206,7 @@ public class StreamedETLPreviewStep extends BaseStreamedETLStep implements Backe
///////////////////////////////////////////////////// /////////////////////////////////////////////////////
// pass the records through the transform function // // pass the records through the transform function //
///////////////////////////////////////////////////// /////////////////////////////////////////////////////
transformStep.run(streamedBackendStepInput, streamedBackendStepOutput); transformStep.runOnePage(streamedBackendStepInput, streamedBackendStepOutput);
//////////////////////////////////////////////////// ////////////////////////////////////////////////////
// add the transformed records to the output list // // add the transformed records to the output list //

View File

@ -170,7 +170,7 @@ public class StreamedETLValidateStep extends BaseStreamedETLStep implements Back
///////////////////////////////////////////////////// /////////////////////////////////////////////////////
// pass the records through the transform function // // pass the records through the transform function //
///////////////////////////////////////////////////// /////////////////////////////////////////////////////
transformStep.run(streamedBackendStepInput, streamedBackendStepOutput); transformStep.runOnePage(streamedBackendStepInput, streamedBackendStepOutput);
/////////////////////////////////////////////////////// ///////////////////////////////////////////////////////
// copy a small number of records to the output list // // copy a small number of records to the output list //

View File

@ -118,7 +118,7 @@ public class GarbageCollectorTransformStep extends AbstractTransformStep
* *
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
//////////////////////////////// ////////////////////////////////
// return if no input records // // return if no input records //

View File

@ -203,7 +203,7 @@ public abstract class AbstractMergeDuplicatesTransformStep extends AbstractTrans
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
if(CollectionUtils.nullSafeIsEmpty(runBackendStepInput.getRecords())) if(CollectionUtils.nullSafeIsEmpty(runBackendStepInput.getRecords()))
{ {

View File

@ -61,9 +61,9 @@ public class MergeDuplicatesLoadStep extends LoadViaInsertOrUpdateStep
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
super.run(runBackendStepInput, runBackendStepOutput); super.runOnePage(runBackendStepInput, runBackendStepOutput);
ListingHash<String, Serializable> otherTableIdsToDelete = (ListingHash<String, Serializable>) runBackendStepInput.getValue("otherTableIdsToDelete"); ListingHash<String, Serializable> otherTableIdsToDelete = (ListingHash<String, Serializable>) runBackendStepInput.getValue("otherTableIdsToDelete");
ListingHash<String, QQueryFilter> otherTableFiltersToDelete = (ListingHash<String, QQueryFilter>) runBackendStepInput.getValue("otherTableFiltersToDelete"); ListingHash<String, QQueryFilter> otherTableFiltersToDelete = (ListingHash<String, QQueryFilter>) runBackendStepInput.getValue("otherTableFiltersToDelete");

View File

@ -113,7 +113,7 @@ public class RunRecordScriptLoadStep extends AbstractLoadStep implements Process
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
runBackendStepInput.getAsyncJobCallback().updateStatus("Running script"); runBackendStepInput.getAsyncJobCallback().updateStatus("Running script");

View File

@ -88,9 +88,9 @@ public class RunRecordScriptTransformStep extends NoopTransformStep
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
super.run(runBackendStepInput, runBackendStepOutput); super.runOnePage(runBackendStepInput, runBackendStepOutput);
runBackendStepOutput.addValue(StreamedETLWithFrontendProcess.FIELD_VALIDATION_SUMMARY, doGetProcessSummary(runBackendStepOutput, false)); runBackendStepOutput.addValue(StreamedETLWithFrontendProcess.FIELD_VALIDATION_SUMMARY, doGetProcessSummary(runBackendStepOutput, false));
} }

View File

@ -190,6 +190,8 @@ public abstract class AbstractTableSyncTransformStep extends AbstractTransformSt
this(sourceTable, sourceTableKeyField, destinationTable, destinationTableForeignKey, true, true); this(sourceTable, sourceTableKeyField, destinationTable, destinationTableForeignKey, true, true);
} }
/******************************************************************************* /*******************************************************************************
** artificial method, here to make jacoco see that this class is indeed ** artificial method, here to make jacoco see that this class is indeed
** included in test coverage... ** included in test coverage...
@ -207,7 +209,7 @@ public abstract class AbstractTableSyncTransformStep extends AbstractTransformSt
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
if(CollectionUtils.nullSafeIsEmpty(runBackendStepInput.getRecords())) if(CollectionUtils.nullSafeIsEmpty(runBackendStepInput.getRecords()))
{ {

View File

@ -78,7 +78,7 @@ public class PauseQuartzJobsProcess extends AbstractLoadStep implements MetaData
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
try try
{ {

View File

@ -78,7 +78,7 @@ public class ResumeQuartzJobsProcess extends AbstractLoadStep implements MetaDat
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
try try
{ {

View File

@ -2258,7 +2258,7 @@ public class QInstanceValidatorTest extends BaseTest
/////////////////////////////////////////////// ///////////////////////////////////////////////
public abstract class TestAbstractClass extends AbstractTransformStep implements BackendStep public abstract class TestAbstractClass extends AbstractTransformStep implements BackendStep
{ {
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
} }
} }
@ -2270,7 +2270,7 @@ public class QInstanceValidatorTest extends BaseTest
/////////////////////////////////////////////// ///////////////////////////////////////////////
private class TestPrivateClass extends AbstractTransformStep implements BackendStep private class TestPrivateClass extends AbstractTransformStep implements BackendStep
{ {
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
} }
@ -2297,7 +2297,7 @@ public class QInstanceValidatorTest extends BaseTest
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
} }

View File

@ -111,7 +111,7 @@ class BulkInsertTransformStepTest extends BaseTest
newQRecord("uuid-D", "SKU-2", 1) // violate sku/storeId UK from pre-existing records newQRecord("uuid-D", "SKU-2", 1) // violate sku/storeId UK from pre-existing records
)); ));
bulkInsertTransformStep.preRun(input, output); bulkInsertTransformStep.preRun(input, output);
bulkInsertTransformStep.run(input, output); bulkInsertTransformStep.runOnePage(input, output);
/////////////////////////////////////////////////////// ///////////////////////////////////////////////////////
// assert about the records that passed successfully // // assert about the records that passed successfully //
@ -193,7 +193,7 @@ class BulkInsertTransformStepTest extends BaseTest
newQRecord("uuid-D", "SKU-2", 1) // violate sku/storeId UK from pre-existing records newQRecord("uuid-D", "SKU-2", 1) // violate sku/storeId UK from pre-existing records
)); ));
bulkInsertTransformStep.preRun(input, output); bulkInsertTransformStep.preRun(input, output);
bulkInsertTransformStep.run(input, output); bulkInsertTransformStep.runOnePage(input, output);
/////////////////////////////////////////////////////// ///////////////////////////////////////////////////////
// assert that all records pass. // assert that all records pass.

View File

@ -76,7 +76,7 @@ class LoadViaInsertOrUpdateStepTest extends BaseTest
input.setRecords(inputRecordList); input.setRecords(inputRecordList);
input.addValue(LoadViaInsertOrUpdateStep.FIELD_DESTINATION_TABLE, TestUtils.TABLE_NAME_PERSON_MEMORY); input.addValue(LoadViaInsertOrUpdateStep.FIELD_DESTINATION_TABLE, TestUtils.TABLE_NAME_PERSON_MEMORY);
RunBackendStepOutput output = new RunBackendStepOutput(); RunBackendStepOutput output = new RunBackendStepOutput();
new LoadViaInsertOrUpdateStep().run(input, output); new LoadViaInsertOrUpdateStep().runOnePage(input, output);
List<QRecord> qRecords = TestUtils.queryTable(qInstance, TestUtils.TABLE_NAME_PERSON_MEMORY); List<QRecord> qRecords = TestUtils.queryTable(qInstance, TestUtils.TABLE_NAME_PERSON_MEMORY);
assertEquals(2, qRecords.size()); assertEquals(2, qRecords.size());

View File

@ -56,7 +56,7 @@ class NoopTransformStepTest extends BaseTest
RunBackendStepOutput output = new RunBackendStepOutput(); RunBackendStepOutput output = new RunBackendStepOutput();
NoopTransformStep noopTransformStep = new NoopTransformStep(); NoopTransformStep noopTransformStep = new NoopTransformStep();
noopTransformStep.run(input, output); noopTransformStep.runOnePage(input, output);
assertEquals(1, output.getRecords().size()); assertEquals(1, output.getRecords().size());
assertEquals(47, output.getRecords().get(0).getValueInteger("id")); assertEquals(47, output.getRecords().get(0).getValueInteger("id"));

View File

@ -419,7 +419,7 @@ public class StreamedETLWithFrontendProcessTest extends BaseTest
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
for(QRecord qRecord : runBackendStepInput.getRecords()) for(QRecord qRecord : runBackendStepInput.getRecords())
{ {
@ -452,7 +452,7 @@ public class StreamedETLWithFrontendProcessTest extends BaseTest
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
for(QRecord qRecord : runBackendStepInput.getRecords()) for(QRecord qRecord : runBackendStepInput.getRecords())
{ {
@ -518,7 +518,7 @@ public class StreamedETLWithFrontendProcessTest extends BaseTest
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
for(QRecord qRecord : runBackendStepInput.getRecords()) for(QRecord qRecord : runBackendStepInput.getRecords())
{ {
@ -552,7 +552,7 @@ public class StreamedETLWithFrontendProcessTest extends BaseTest
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
for(QRecord qRecord : runBackendStepInput.getRecords()) for(QRecord qRecord : runBackendStepInput.getRecords())
{ {
@ -584,7 +584,7 @@ public class StreamedETLWithFrontendProcessTest extends BaseTest
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
/////////////////////////////////// ///////////////////////////////////
// just pass the records through // // just pass the records through //

View File

@ -61,7 +61,7 @@ public class TransformPersonStep extends AbstractTransformStep
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
for(QRecord record : runBackendStepInput.getRecords()) for(QRecord record : runBackendStepInput.getRecords())
{ {

View File

@ -75,7 +75,7 @@ public class ClonePeopleTransformStep extends AbstractTransformStep implements P
** **
*******************************************************************************/ *******************************************************************************/
@Override @Override
public void run(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException public void runOnePage(RunBackendStepInput runBackendStepInput, RunBackendStepOutput runBackendStepOutput) throws QException
{ {
for(QRecord inputPerson : runBackendStepInput.getRecords()) for(QRecord inputPerson : runBackendStepInput.getRecords())
{ {

View File

@ -94,7 +94,7 @@ class ClonePeopleTransformStepTest
ClonePeopleTransformStep clonePeopleTransformStep = new ClonePeopleTransformStep(); ClonePeopleTransformStep clonePeopleTransformStep = new ClonePeopleTransformStep();
input.setRecords(queryOutput.getRecords()); input.setRecords(queryOutput.getRecords());
clonePeopleTransformStep.run(input, output); clonePeopleTransformStep.runOnePage(input, output);
ArrayList<ProcessSummaryLineInterface> processSummary = clonePeopleTransformStep.getProcessSummary(output, true); ArrayList<ProcessSummaryLineInterface> processSummary = clonePeopleTransformStep.getProcessSummary(output, true);