Class AbstractImportProcessExecutionAnalysisContext
- java.lang.Object
-
- de.hybris.platform.impex.distributed.process.AbstractImportProcessExecutionAnalysisContext
-
- All Implemented Interfaces:
DistributedProcessHandler.ProcessExecutionAnalysisContext
public abstract class AbstractImportProcessExecutionAnalysisContext extends java.lang.Object implements DistributedProcessHandler.ProcessExecutionAnalysisContext
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description protected static class
AbstractImportProcessExecutionAnalysisContext.BatchExecutionData
protected static class
AbstractImportProcessExecutionAnalysisContext.BatchRow
-
Field Summary
Fields Modifier and Type Field Description protected static java.lang.String
INPUT_SELECT_CLAUSE
protected static java.lang.String
ROWS_SELECT_CLAUSE
-
Constructor Summary
Constructors Constructor Description AbstractImportProcessExecutionAnalysisContext(ModelService modelService, FlexibleSearchService flexibleSearchService)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected ImportBatchModel
createInputBatch(AbstractImportProcessExecutionAnalysisContext.BatchExecutionData executionData)
boolean
processFailed()
boolean
processSucceeded()
protected java.util.stream.Stream<AbstractImportProcessExecutionAnalysisContext.BatchExecutionData>
queryForBatchRows(java.lang.String queryString, java.util.Map<java.lang.String,java.lang.Object> params)
protected java.util.stream.Stream<AbstractImportProcessExecutionAnalysisContext.BatchExecutionData>
queryForInputBatchRows(java.lang.String queryString, java.util.Map<java.lang.String,java.lang.Object> params)
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface de.hybris.platform.processing.distributed.defaultimpl.DistributedProcessHandler.ProcessExecutionAnalysisContext
nextExecutionInputBatches, prepareProcessForNextExecution
-
-
-
-
Constructor Detail
-
AbstractImportProcessExecutionAnalysisContext
public AbstractImportProcessExecutionAnalysisContext(ModelService modelService, FlexibleSearchService flexibleSearchService)
-
-
Method Detail
-
processFailed
public boolean processFailed()
- Specified by:
processFailed
in interfaceDistributedProcessHandler.ProcessExecutionAnalysisContext
-
processSucceeded
public boolean processSucceeded()
- Specified by:
processSucceeded
in interfaceDistributedProcessHandler.ProcessExecutionAnalysisContext
-
createInputBatch
protected ImportBatchModel createInputBatch(AbstractImportProcessExecutionAnalysisContext.BatchExecutionData executionData)
-
queryForInputBatchRows
protected java.util.stream.Stream<AbstractImportProcessExecutionAnalysisContext.BatchExecutionData> queryForInputBatchRows(java.lang.String queryString, java.util.Map<java.lang.String,java.lang.Object> params)
-
queryForBatchRows
protected java.util.stream.Stream<AbstractImportProcessExecutionAnalysisContext.BatchExecutionData> queryForBatchRows(java.lang.String queryString, java.util.Map<java.lang.String,java.lang.Object> params)
-
-