Package org.nuxeo.ecm.core.bulk

Class S3SetBlobLengthAction.SetBlobLengthComputation

java.lang.Object

org.nuxeo.lib.stream.computation.AbstractComputation

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

org.nuxeo.ecm.core.bulk.S3SetBlobLengthAction.SetBlobLengthComputation

All Implemented Interfaces:

Computation

Enclosing class:

S3SetBlobLengthAction

public static class S3SetBlobLengthAction.SetBlobLengthComputation
extends AbstractBulkComputation

Field Summary

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
SetBlobLengthComputation()

Method Summary

Modifier and Type	Method	Description
protected void	compute(CoreSession session, List<String> ids, Map<String,Serializable> properties)
protected Blob	fixBlob(String docId, ManagedBlob blob, boolean force)
protected void	fixBlobLength(AbstractSession session, String docId, String xpath, boolean force)
protected long	getBlobLengthFromS3(String docId, ManagedBlob blob)

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

endBucket, getBatchTransactionTimeout, getCommand, getCurrentCommand, isAbortedCommand, loadDocuments, loadDocumentsOneByOne, loginSystemOrUser, processBatchOfDocuments, processFailure, processRecord, startBucket, 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

Constructor Details

SetBlobLengthComputation

public SetBlobLengthComputation()

Method Details

compute

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

Specified by:

compute in class AbstractBulkComputation

fixBlobLength

protected void fixBlobLength(AbstractSession session,
 String docId,
 String xpath,
 boolean force)

fixBlob

protected Blob fixBlob(String docId,
 ManagedBlob blob,
 boolean force)

getBlobLengthFromS3

protected long getBlobLengthFromS3(String docId,
 ManagedBlob blob)