Package | Description |
---|---|
org.nuxeo.audit.storage.stream | |
org.nuxeo.ecm.core.bulk.action.computation | |
org.nuxeo.ecm.core.bulk.computation | |
org.nuxeo.ecm.core.work | |
org.nuxeo.ecm.platform.audit.impl | |
org.nuxeo.ecm.platform.csv.export.computation | |
org.nuxeo.elasticsearch.bulk | |
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 |
AbstractBulkComputation.endBucket(ComputationContext context,
BulkStatus delta)
Can be overridden to write to downstream computation or add results to status
|
protected void |
MakeBlob.finishBlob(ComputationContext context,
String commandId) |
void |
MakeBlob.init(ComputationContext context) |
void |
AbstractTransientBlobComputation.init(ComputationContext context) |
void |
AbstractBulkComputation.processFailure(ComputationContext context,
Throwable failure) |
void |
ZipBlob.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
void |
SortBlob.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
void |
MakeBlob.processRecord(ComputationContext context,
String documentIdsStreamName,
Record record) |
void |
ExposeBlob.processRecord(ComputationContext context,
String documentIdsStreamName,
Record record) |
void |
AbstractBulkComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
void |
MakeBlob.processTimer(ComputationContext context,
String key,
long timestamp) |
static void |
AbstractBulkComputation.updateStatus(ComputationContext context,
BulkStatus delta) |
Modifier and Type | Method and Description |
---|---|
protected void |
BulkScrollerComputation.processRecord(ComputationContext context,
Record record) |
void |
BulkStatusComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
void |
BulkScrollerComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
protected void |
BulkScrollerComputation.produceBucket(ComputationContext context,
String action,
String commandId,
int bucketSize,
long bucketNumber)
Produces a bucket as a record to appropriate bulk action stream.
|
protected void |
BulkScrollerComputation.updateStatusAfterScroll(ComputationContext context,
String commandId,
long documentCount) |
protected void |
BulkScrollerComputation.updateStatusAfterScroll(ComputationContext context,
String commandId,
long documentCount,
String errorMessage) |
protected void |
BulkScrollerComputation.updateStatusAfterScroll(ComputationContext context,
String commandId,
String errorMessage) |
protected void |
BulkScrollerComputation.updateStatusAsScrolling(ComputationContext context,
String commandId) |
Modifier and Type | Method and Description |
---|---|
void |
WorkComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
Modifier and Type | Method and Description |
---|---|
void |
StreamAuditWriter.AuditLogWriterComputation.batchFailure(ComputationContext context,
String inputStreamName,
List<Record> records) |
void |
StreamAuditWriter.AuditLogWriterComputation.batchProcess(ComputationContext context,
String inputStreamName,
List<Record> records) |
Modifier and Type | Method and Description |
---|---|
void |
CSVProjectionComputation.endBucket(ComputationContext context,
BulkStatus delta) |
Modifier and Type | Method and Description |
---|---|
void |
IndexRequestComputation.endBucket(ComputationContext context,
BulkStatus delta) |
void |
IndexCompletionComputation.init(ComputationContext context) |
void |
BulkIndexComputation.init(ComputationContext context) |
void |
IndexCompletionComputation.processRecord(ComputationContext context,
String inputStream,
Record record) |
void |
BulkIndexComputation.processRecord(ComputationContext context,
String inputStream,
Record record) |
void |
BulkIndexComputation.processTimer(ComputationContext context,
String key,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
abstract void |
AbstractBatchComputation.batchFailure(ComputationContext context,
String inputStreamName,
List<Record> records)
Called when the retry policy has failed.
|
protected abstract void |
AbstractBatchComputation.batchProcess(ComputationContext context,
String inputStreamName,
List<Record> records)
Called when:
- the batch capacity is reached - the time threshold is reached - the inputStreamName has changed If this method raises an exception the retry policy is applied. |
protected void |
AbstractBatchComputation.checkpointBatch(ComputationContext context) |
void |
Computation.init(ComputationContext context)
Called when the framework has registered the computation successfully.
|
void |
AbstractComputation.init(ComputationContext context) |
void |
AbstractBatchComputation.init(ComputationContext context) |
void |
Computation.processFailure(ComputationContext context,
Throwable failure)
|
void |
AbstractComputation.processFailure(ComputationContext context,
Throwable failure) |
void |
AbstractBatchComputation.processFailure(ComputationContext context,
Throwable failure) |
void |
Computation.processRecord(ComputationContext context,
String inputStreamName,
Record record)
Process an incoming record on one of the computation's input streams.
|
void |
AbstractBatchComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
void |
Computation.processRetry(ComputationContext context,
Throwable failure)
|
void |
AbstractComputation.processRetry(ComputationContext context,
Throwable failure) |
void |
AbstractBatchComputation.processRetry(ComputationContext context,
Throwable failure) |
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) |
void |
AbstractBatchComputation.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 |
LatencyMonitorComputation.init(ComputationContext context) |
void |
LatencyTrackerComputation.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
void |
LatencyTrackerComputation.processTimer(ComputationContext context,
String key,
long timestamp) |
void |
LatencyMonitorComputation.processTimer(ComputationContext context,
String key,
long timestamp) |
Copyright © 2019 Nuxeo. All rights reserved.