public class SortBlob extends AbstractTransientBlobComputation
Modifier and Type | Field and 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 |
Constructor and Description |
---|
SortBlob() |
Modifier and Type | Method and 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) |
createTemp, getBlob, getTransientStoreKey, init, storeBlob
metadata, processFailure, processRetry, processTimer
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
destroy, signalStop
public static final String NAME
public static final String SORT_PARAMETER
protected static final String ZIP_STREAM
protected static final String EXPOSE_BLOB_STREAM
protected static final int NB_OUTPUT_STREAMS
public SortBlob()
public void processRecord(ComputationContext context, String inputStreamName, Record record)
Computation
context
- The computation context object provided by the system.inputStreamName
- Name of the input stream that provides the record.record
- The record.Copyright © 2019 Nuxeo. All rights reserved.