public class MakeBlob extends AbstractTransientBlobComputation
Modifier and Type | Field and Description |
---|---|
protected static long |
CHECK_DELAY_MS |
protected Map<String,Long> |
counters |
protected static String |
EXPOSE_BLOB_STREAM |
protected Map<String,DataBucket> |
lastBuckets |
static String |
NAME |
protected static int |
NB_OUTPUT_STREAMS |
protected boolean |
produceImmediate |
protected static String |
SORT_STREAM |
protected Map<String,Long> |
totals |
protected static String |
ZIP_STREAM |
Constructor and Description |
---|
MakeBlob() |
MakeBlob(boolean produceImmediate) |
Modifier and Type | Method and Description |
---|---|
protected void |
appendHeaderFooterToFile(Path filePath,
String commandId,
byte[] header,
byte[] footer) |
protected Path |
appendToFile(String commandId,
byte[] content) |
protected void |
finishBlob(ComputationContext context,
String commandId) |
protected String |
getOutputStream(String commandId) |
protected Long |
getTotal(String commandId) |
void |
init(ComputationContext context)
Called when the framework has registered the computation successfully.
|
void |
processRecord(ComputationContext context,
String documentIdsStreamName,
Record record)
Process an incoming record on one of the computation's input streams.
|
void |
processTimer(ComputationContext context,
String key,
long timestamp)
Process a timer callback previously set via
ComputationContext.setTimer(String, long) . |
protected String |
saveInTransientStore(String commandId,
String storeName) |
createTemp, getBlob, getTransientStoreKey, storeBlob
metadata, processFailure, processRetry
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
destroy, signalStop
public static final String NAME
protected static final long CHECK_DELAY_MS
protected static final String SORT_STREAM
protected static final String ZIP_STREAM
protected static final String EXPOSE_BLOB_STREAM
protected static final int NB_OUTPUT_STREAMS
protected final Map<String,DataBucket> lastBuckets
protected final boolean produceImmediate
public void init(ComputationContext context)
Computation
init
in interface Computation
init
in class AbstractTransientBlobComputation
context
- The computation context object provided by the system.public void processTimer(ComputationContext context, String key, long timestamp)
Computation
ComputationContext.setTimer(String, long)
.processTimer
in interface Computation
processTimer
in class AbstractComputation
context
- The computation context object provided by the system.key
- The name of the timer.timestamp
- The timestamp (in ms) for which the callback was scheduled.public void processRecord(ComputationContext context, String documentIdsStreamName, Record record)
Computation
context
- The computation context object provided by the system.documentIdsStreamName
- Name of the input stream that provides the record.record
- The record.protected Path appendToFile(String commandId, byte[] content)
protected void appendHeaderFooterToFile(Path filePath, String commandId, byte[] header, byte[] footer)
protected String saveInTransientStore(String commandId, String storeName)
protected String getOutputStream(String commandId)
protected void finishBlob(ComputationContext context, String commandId)
Copyright © 2019 Nuxeo. All rights reserved.