de.hybris.platform.processing.distributed.simple.data

Class QueryBasedCreationData

java.lang.Object

de.hybris.platform.processing.distributed.simple.data.SimpleAbstractDistributedProcessCreationData

de.hybris.platform.processing.distributed.simple.data.QueryBasedCreationData

All Implemented Interfaces:

ProcessCreationData

public class QueryBasedCreationData
extends SimpleAbstractDistributedProcessCreationData

Process creation data which is based on Flexible Search Query. By default it queries for PKs of an Item and only PKs will be on a result list. According to the batch size a List of resulting PKs will be available as a context data for individual batch processing. More complex, multi-value queries are also supported but result class list must be provided. Keep in mind that result must be serializable since it is stored in a BLOB field of a Batch later on.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	QueryBasedCreationData.Builder
static interface	QueryBasedCreationData.QueryHook

Field Summary

Fields inherited from class de.hybris.platform.processing.distributed.simple.data.SimpleAbstractDistributedProcessCreationData

batchSize, DEFAULT_BATCH_SIZE, DEFAULT_NUM_RETRIES, handlerId, nodeGroup, numOfRetries, processId, processModelClass, scriptCode

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	QueryBasedCreationData(String handlerId, String processId, String nodeGroup, Integer batchSize, Integer numOfRetries, String query, Map<String,Object> queryParams, List<Class<?>> resultClasses, FlexibleSearchQuery flexibleSearchQuery, String scriptCode, boolean useDatabasePaging, QueryBasedCreationData.QueryHook beforeQueryHook, Class<? extends SimpleDistributedProcessModel> processModelClass)

Method Summary

Modifier and Type	Method and Description
static QueryBasedCreationData.Builder	builder()
Stream<? extends SimpleBatchCreationData>	initialBatches() Responsible for returning stream for creating initial batches used by distributed process.

Methods inherited from class de.hybris.platform.processing.distributed.simple.data.SimpleAbstractDistributedProcessCreationData

getBatchSize, getHandlerBeanId, getNodeGroup, getNumOfRetries, getProcessId, getProcessModelClass, getScriptCode

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QueryBasedCreationData

protected QueryBasedCreationData(String handlerId,
                                 String processId,
                                 String nodeGroup,
                                 Integer batchSize,
                                 Integer numOfRetries,
                                 String query,
                                 Map<String,Object> queryParams,
                                 List<Class<?>> resultClasses,
                                 FlexibleSearchQuery flexibleSearchQuery,
                                 String scriptCode,
                                 boolean useDatabasePaging,
                                 QueryBasedCreationData.QueryHook beforeQueryHook,
                                 Class<? extends SimpleDistributedProcessModel> processModelClass)

Method Detail

initialBatches

public Stream<? extends SimpleBatchCreationData> initialBatches()

Description copied from interface: ProcessCreationData

Responsible for returning stream for creating initial batches used by distributed process.

Specified by:

initialBatches in interface ProcessCreationData

Specified by:

initialBatches in class SimpleAbstractDistributedProcessCreationData

Returns:

Stream of batch data

builder

public static QueryBasedCreationData.Builder builder()