Class SortBlob
java.lang.Object
org.nuxeo.lib.stream.computation.AbstractComputation
org.nuxeo.ecm.core.bulk.action.computation.AbstractTransientBlobComputation
org.nuxeo.ecm.core.bulk.action.computation.SortBlob
- All Implemented Interfaces:
Computation
- Since:
- 10.3
-
Field Summary
Modifier and TypeFieldDescriptionprotected static final String
static final String
protected static final int
static final String
protected static final String
Fields inherited from class org.nuxeo.ecm.core.bulk.action.computation.AbstractTransientBlobComputation
id, temp
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
-
Method Summary
Modifier and TypeMethodDescriptionprotected void
deleteTempFile
(Path path) void
processRecord
(ComputationContext context, String inputStreamName, Record record) Process an incoming record on one of the computation's input streams.protected Blob
Methods inherited from class org.nuxeo.ecm.core.bulk.action.computation.AbstractTransientBlobComputation
createTemp, getBlob, getTransientStoreKey, init, storeBlob
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, signalStop
-
Field Details
-
NAME
- See Also:
-
SORT_PARAMETER
- See Also:
-
ZIP_STREAM
- See Also:
-
EXPOSE_BLOB_STREAM
- See Also:
-
NB_OUTPUT_STREAMS
protected static final int NB_OUTPUT_STREAMS- See Also:
-
-
Constructor Details
-
SortBlob
public SortBlob()
-
-
Method Details
-
processRecord
Description copied from interface:Computation
Process an incoming record on one of the computation's input streams.- Parameters:
context
- The computation context object provided by the system.inputStreamName
- Name of the input stream that provides the record.record
- The record.
-
deleteTempFile
-
sort
-