public class ComputationWork extends AbstractComputation
metadata
Constructor and Description |
---|
ComputationWork(String name) |
Modifier and Type | Method and Description |
---|---|
static Work |
deserialize(byte[] data) |
void |
init(ComputationContext context)
Called when the framework has registered the computation successfully.
|
void |
processRecord(ComputationContext context,
String inputStreamName,
Record record)
Process an incoming record on one of the computation's input streams.
|
static byte[] |
serialize(Work work) |
destroy, metadata, processTimer
public ComputationWork(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.public void init(ComputationContext context)
Computation
init
in interface Computation
init
in class AbstractComputation
context
- The computation context object provided by the system.public static Work deserialize(byte[] data)
Copyright © 2017 Nuxeo. All rights reserved.