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

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

public class SortBlob
extends AbstractTransientBlobComputation

Since:

10.3

Field Summary

Fields

Modifier and Type	Field	Description
protected static String	EXPOSE_BLOB_STREAM
static String	NAME
protected static int	NB_OUTPUT_STREAMS
static String	SORT_PARAMETER
protected static String	ZIP_STREAM

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

Constructors

Constructor	Description
SortBlob()

Method Summary

Modifier and Type	Method	Description
void	processRecord(ComputationContext context, String inputStreamName, Record record)	Process an incoming record on one of the computation's input streams.
protected Blob	sort(Blob blob, String commandId)

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 Detail

NAME

public static final String NAME

See Also:

Constant Field Values

SORT_PARAMETER

public static final String SORT_PARAMETER

See Also:

Constant Field Values

ZIP_STREAM

protected static final String ZIP_STREAM

See Also:

Constant Field Values

EXPOSE_BLOB_STREAM

protected static final String EXPOSE_BLOB_STREAM

See Also:

Constant Field Values

NB_OUTPUT_STREAMS

protected static final int NB_OUTPUT_STREAMS

See Also:

Constant Field Values

Constructor Detail

SortBlob

public SortBlob()

Method Detail

processRecord

public void processRecord(ComputationContext context,
                          String inputStreamName,
                          Record record)

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.

sort

protected Blob sort(Blob blob,
                    String commandId)