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 java.lang.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 java.lang.String	INPUT_SELECT_CLAUSE
protected static java.lang.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 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

Field Detail

INPUT_SELECT_CLAUSE

protected static java.lang.String INPUT_SELECT_CLAUSE

ROWS_SELECT_CLAUSE

protected static java.lang.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 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)