public class BulkStatusComputation extends AbstractComputation
Inputs:
BulkStatus
sharded by command idBulkStatus
full into the done stream.Constructor and Description |
---|
BulkStatusComputation(String name) |
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.
|
init, metadata, processFailure, processRetry, processTimer
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
destroy, signalStop
public BulkStatusComputation(String name)
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.