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
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 ClassesModifier and TypeClassDescriptionstatic classstatic interface -
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
ConstructorsModifierConstructorDescriptionprotectedQueryBasedCreationData(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 TypeMethodDescriptionbuilder()Stream<? extends SimpleBatchCreationData>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
-
Constructor Details
-
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 Details
-
initialBatches
Description copied from interface:ProcessCreationDataResponsible for returning stream for creating initial batches used by distributed process.- Specified by:
initialBatchesin interfaceProcessCreationData- Specified by:
initialBatchesin classSimpleAbstractDistributedProcessCreationData- Returns:
- Stream of batch data
-
builder
-