de.hybris.platform.impex.distributed.process

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 Classes

Modifier and Type	Class and Description
protected static class	AbstractImportProcessExecutionAnalysisContext.BatchExecutionData
protected static class	AbstractImportProcessExecutionAnalysisContext.BatchRow

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	INPUT_SELECT_CLAUSE
protected static String	ROWS_SELECT_CLAUSE

Constructor Summary

Constructors

Constructor and Description
AbstractImportProcessExecutionAnalysisContext(ModelService modelService, FlexibleSearchService flexibleSearchService)

Method Summary

Modifier and Type	Method and Description
protected ImportBatchModel	createInputBatch(AbstractImportProcessExecutionAnalysisContext.BatchExecutionData executionData)
boolean	processFailed()
boolean	processSucceeded()
protected Stream<AbstractImportProcessExecutionAnalysisContext.BatchExecutionData>	queryForBatchRows(String queryString, Map<String,Object> params)
protected Stream<AbstractImportProcessExecutionAnalysisContext.BatchExecutionData>	queryForInputBatchRows(String queryString, Map<String,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

Field Detail

INPUT_SELECT_CLAUSE

protected static String INPUT_SELECT_CLAUSE

ROWS_SELECT_CLAUSE

protected static String ROWS_SELECT_CLAUSE

Constructor Detail

AbstractImportProcessExecutionAnalysisContext

public AbstractImportProcessExecutionAnalysisContext(ModelService modelService,
                                                     FlexibleSearchService flexibleSearchService)

Method Detail

processFailed

public boolean processFailed()

Specified by:

processFailed in interface DistributedProcessHandler.ProcessExecutionAnalysisContext

processSucceeded

public boolean processSucceeded()

Specified by:

processSucceeded in interface DistributedProcessHandler.ProcessExecutionAnalysisContext

createInputBatch

protected ImportBatchModel createInputBatch(AbstractImportProcessExecutionAnalysisContext.BatchExecutionData executionData)

queryForInputBatchRows

protected Stream<AbstractImportProcessExecutionAnalysisContext.BatchExecutionData> queryForInputBatchRows(String queryString,
                                                                                                          Map<String,Object> params)

queryForBatchRows

protected Stream<AbstractImportProcessExecutionAnalysisContext.BatchExecutionData> queryForBatchRows(String queryString,
                                                                                                     Map<String,Object> params)