Modifier and Type | Method and Description |
---|---|
void |
Computation.init(ComputationContext context)
Called when the framework has registered the computation successfully.
|
void |
AbstractComputation.init(ComputationContext context) |
void |
Computation.processRecord(ComputationContext context,
String inputStreamName,
Record record)
Process an incoming record on one of the computation's input streams.
|
void |
Computation.processTimer(ComputationContext context,
String key,
long timestamp)
Process a timer callback previously set via
setTimer(String, long) . |
void |
AbstractComputation.processTimer(ComputationContext context,
String key,
long timestamp) |
Modifier and Type | Class and Description |
---|---|
class |
ComputationContextImpl |
Modifier and Type | Method and Description |
---|---|
void |
ComputationWork.init(ComputationContext context) |
void |
ComputationWork.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
Copyright © 2017 Nuxeo. All rights reserved.