Package org.nuxeo.ecm.automation.core.operations.services.bulk

Class AbstractAutomationBulkAction.AutomationComputation

java.lang.Object

org.nuxeo.lib.stream.computation.AbstractComputation

org.nuxeo.ecm.core.bulk.action.computation.AbstractBulkComputation

org.nuxeo.ecm.automation.core.operations.services.bulk.AbstractAutomationBulkAction.AutomationComputation

All Implemented Interfaces:

Computation

Enclosing class:

AbstractAutomationBulkAction

public static class AbstractAutomationBulkAction.AutomationComputation
extends AbstractBulkComputation

Field Summary

Fields

Modifier and Type	Field	Description
static String	DOC_INPUT_TYPE
static String	DOCS_INPUT_TYPE
protected boolean	failOnError
protected String	inputType
protected String	operationId
protected Map<String,?>	params
protected AutomationService	service

Fields inherited from class org.nuxeo.ecm.core.bulk.action.computation.AbstractBulkComputation

command, commands, delta, SELECT_DOCUMENTS_IN

Fields inherited from class org.nuxeo.lib.stream.computation.AbstractComputation

INPUT_1, INPUT_2, INPUT_3, INPUT_NULL, metadata, OUTPUT_1, OUTPUT_2, OUTPUT_3, OUTPUT_4

Constructor Summary

Constructors

Constructor	Description
AutomationComputation(String name, boolean failOnError)

Method Summary

Modifier and Type	Method	Description
protected void	checkOperation(String operationId)
protected void	checkParams(Serializable serializable)
protected void	compute(CoreSession session, List<String> ids, Map<String,Serializable> properties)
protected void	handleError(List<DocumentModel> documents, Exception e)
protected void	runOperationOnAllDocuments(CoreSession session, DocumentModelList documents)
protected void	runOperationOnEachDocument(CoreSession session, DocumentModelList documents)
void	startBucket(String bucketKey)	Can be overridden to init stuff before processing the bucket

Methods inherited from class org.nuxeo.ecm.core.bulk.action.computation.AbstractBulkComputation

endBucket, getBatchTransactionTimeout, getCommand, getCurrentCommand, isAbortedCommand, loadDocuments, loadDocumentsOneByOne, loginSystemOrUser, processBatchOfDocuments, processFailure, processRecord, updateStatus

Methods inherited from class org.nuxeo.lib.stream.computation.AbstractComputation

init, metadata, processRetry, processTimer

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.nuxeo.lib.stream.computation.Computation

destroy, signalStop

Field Detail

DOC_INPUT_TYPE

public static final String DOC_INPUT_TYPE

See Also:

Constant Field Values

DOCS_INPUT_TYPE

public static final String DOCS_INPUT_TYPE

See Also:

Constant Field Values

failOnError

protected final boolean failOnError

service

protected AutomationService service

operationId

protected String operationId

inputType

protected String inputType

params

protected Map<String,?> params

Constructor Detail

AutomationComputation

public AutomationComputation(String name,
                             boolean failOnError)

Method Detail

startBucket

public void startBucket(String bucketKey)

Description copied from class: AbstractBulkComputation

Can be overridden to init stuff before processing the bucket

Overrides:

startBucket in class AbstractBulkComputation

compute

protected void compute(CoreSession session,
                       List<String> ids,
                       Map<String,Serializable> properties)

Specified by:

compute in class AbstractBulkComputation

runOperationOnAllDocuments

protected void runOperationOnAllDocuments(CoreSession session,
                                          DocumentModelList documents)

runOperationOnEachDocument

protected void runOperationOnEachDocument(CoreSession session,
                                          DocumentModelList documents)

handleError

protected void handleError(List<DocumentModel> documents,
                           Exception e)

checkOperation

protected void checkOperation(String operationId)

checkParams

protected void checkParams(Serializable serializable)