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

Class AbstractTransientBlobComputation

java.lang.Object

org.nuxeo.lib.stream.computation.AbstractComputation

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

All Implemented Interfaces:

Computation

Direct Known Subclasses:

ExposeBlob, MakeBlob, SortBlob, ZipBlob

public abstract class AbstractTransientBlobComputation
extends AbstractComputation

Since:

10.3

Field Summary

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

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

Constructor Summary

Constructors

Constructor and Description
AbstractTransientBlobComputation(String name)
AbstractTransientBlobComputation(String name, int nbOutputStreams)

Method Summary

Modifier and Type	Method and Description
protected Path	createTemp(String commandId)
Blob	getBlob(String key, String storeName)
protected String	getTransientStoreKey(String commandId)
void	init(ComputationContext context) Called when the framework has registered the computation successfully.
protected void	storeBlob(Blob blob, String commandId, String storeName)

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

metadata, processFailure, 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, processRecord, signalStop

Constructor Detail

AbstractTransientBlobComputation

public AbstractTransientBlobComputation(String name)

AbstractTransientBlobComputation

public AbstractTransientBlobComputation(String name,
                                        int nbOutputStreams)

Method Detail

init

public void init(ComputationContext context)

Description copied from interface: Computation

Called when the framework has registered the computation successfully. Gives users a first opportunity to schedule timer callbacks and produce records.

Specified by:

init in interface Computation

Overrides:

init in class AbstractComputation

Parameters:

context - The computation context object provided by the system.

getTransientStoreKey

protected String getTransientStoreKey(String commandId)

getBlob

public Blob getBlob(String key,
                    String storeName)

storeBlob

protected void storeBlob(Blob blob,
                         String commandId,
                         String storeName)

createTemp

protected Path createTemp(String commandId)