Package | Description |
---|---|
org.nuxeo.audit.storage.stream | |
org.nuxeo.ecm.core.bulk | |
org.nuxeo.ecm.core.bulk.actions | |
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 | |
org.nuxeo.lib.stream.tools.command |
Modifier and Type | Method and Description |
---|---|
void |
StreamAuditStorageWriter.AuditStorageLogWriterComputation.init(ComputationContext context) |
void |
StreamAuditStorageWriter.AuditStorageLogWriterComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
void |
StreamAuditStorageWriter.AuditStorageLogWriterComputation.processTimer(ComputationContext context,
String key,
long timestamp) |
protected void |
StreamAuditStorageWriter.AuditStorageLogWriterComputation.writeJsonEntriesToAudit(ComputationContext context)
Store JSON entries in the Directory Audit Storage
|
Modifier and Type | Method and Description |
---|---|
void |
StreamBulkProcessor.CounterComputation.init(ComputationContext context) |
protected void |
StreamBulkProcessor.BulkDocumentScrollerComputation.processRecord(ComputationContext context,
Record record) |
void |
StreamBulkProcessor.BulkDocumentScrollerComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
void |
StreamBulkProcessor.CounterComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
void |
StreamBulkProcessor.KeyValueWriterComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
void |
StreamBulkProcessor.CounterComputation.processTimer(ComputationContext context,
String key,
long timestamp) |
protected void |
StreamBulkProcessor.BulkDocumentScrollerComputation.produceBucket(ComputationContext context,
String action,
String commandId,
long nbDocSent)
Produces a bucket as a record to appropriate bulk action stream.
|
Modifier and Type | Method and Description |
---|---|
void |
SetPropertiesAction.SetPropertyComputation.init(ComputationContext context) |
protected void |
SetPropertiesAction.SetPropertyComputation.processBatch(ComputationContext context) |
void |
SetPropertiesAction.SetPropertyComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
void |
SetPropertiesAction.SetPropertyComputation.processTimer(ComputationContext context,
String key,
long timestamp) |
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 |
Modifier and Type | Method and Description |
---|---|
void |
LatencyTrackerComputation.init(ComputationContext context) |
void |
LatencyTrackerComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
void |
LatencyTrackerComputation.processTimer(ComputationContext context,
String key,
long timestamp) |
Copyright © 2018 Nuxeo. All rights reserved.