Class AbstractImportProcessExecutionAnalysisContext
java.lang.Object
de.hybris.platform.impex.distributed.process.AbstractImportProcessExecutionAnalysisContext
- All Implemented Interfaces:
DistributedProcessHandler.ProcessExecutionAnalysisContext
public abstract class AbstractImportProcessExecutionAnalysisContext
extends Object
implements DistributedProcessHandler.ProcessExecutionAnalysisContext
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprotected static classprotected static class -
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionAbstractImportProcessExecutionAnalysisContext(ModelService modelService, FlexibleSearchService flexibleSearchService) -
Method Summary
Modifier and TypeMethodDescriptionprotected ImportBatchModelbooleanbooleanqueryForBatchRows(String queryString, Map<String, Object> params) queryForInputBatchRows(String queryString, Map<String, Object> params) Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface de.hybris.platform.processing.distributed.defaultimpl.DistributedProcessHandler.ProcessExecutionAnalysisContext
nextExecutionInputBatches, prepareProcessForNextExecution
-
Field Details
-
INPUT_SELECT_CLAUSE
-
ROWS_SELECT_CLAUSE
-
-
Constructor Details
-
AbstractImportProcessExecutionAnalysisContext
public AbstractImportProcessExecutionAnalysisContext(ModelService modelService, FlexibleSearchService flexibleSearchService)
-
-
Method Details
-
processFailed
public boolean processFailed()- Specified by:
processFailedin interfaceDistributedProcessHandler.ProcessExecutionAnalysisContext
-
processSucceeded
public boolean processSucceeded()- Specified by:
processSucceededin interfaceDistributedProcessHandler.ProcessExecutionAnalysisContext
-
createInputBatch
protected ImportBatchModel createInputBatch(AbstractImportProcessExecutionAnalysisContext.BatchExecutionData executionData) -
queryForInputBatchRows
-
queryForBatchRows
-