Package | Description |
---|---|
org.nuxeo.ecm.core.work | |
org.nuxeo.ecm.platform.audit.impl | |
org.nuxeo.lib.stream.computation |
The Computation pattern with a Log implementation.
|
org.nuxeo.lib.stream.computation.internals |
Modifier and Type | Method and Description |
---|---|
void |
WorkComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
Modifier and Type | Method and Description |
---|---|
void |
StreamAuditWriter.AuditLogWriterComputation.init(ComputationContext context) |
void |
StreamAuditWriter.AuditLogWriterComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
void |
StreamAuditWriter.AuditLogWriterComputation.processTimer(ComputationContext context,
String key,
long timestamp) |
protected void |
StreamAuditWriter.AuditLogWriterComputation.writeEntriesToAudit(ComputationContext context) |
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 |
Copyright © 2018 Nuxeo. All rights reserved.