Uses of Interface
org.nuxeo.lib.stream.computation.ComputationContext

Packages that use ComputationContext

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

Uses of ComputationContext in org.nuxeo.audit.storage.stream

Methods in org.nuxeo.audit.storage.stream with parameters of type ComputationContext

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

Uses of ComputationContext in org.nuxeo.ecm.core.bulk.action.computation

Methods in org.nuxeo.ecm.core.bulk.action.computation with parameters of type ComputationContext

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)

Uses of ComputationContext in org.nuxeo.ecm.core.bulk.computation

Methods in org.nuxeo.ecm.core.bulk.computation with parameters of type ComputationContext

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)

Uses of ComputationContext in org.nuxeo.ecm.core.work

Methods in org.nuxeo.ecm.core.work with parameters of type ComputationContext

Modifier and Type	Method and Description
void	WorkComputation.processRecord(ComputationContext context, String inputStreamName, Record record)

Uses of ComputationContext in org.nuxeo.ecm.platform.audit.impl

Methods in org.nuxeo.ecm.platform.audit.impl with parameters of type ComputationContext

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)

Uses of ComputationContext in org.nuxeo.ecm.platform.csv.export.computation

Methods in org.nuxeo.ecm.platform.csv.export.computation with parameters of type ComputationContext

Modifier and Type	Method and Description
void	CSVProjectionComputation.endBucket(ComputationContext context, BulkStatus delta)

Uses of ComputationContext in org.nuxeo.elasticsearch.bulk

Methods in org.nuxeo.elasticsearch.bulk with parameters of type ComputationContext

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)

Uses of ComputationContext in org.nuxeo.lib.stream.computation

Methods in org.nuxeo.lib.stream.computation with parameters of type ComputationContext

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) Called when Computation.processRecord(org.nuxeo.lib.stream.computation.ComputationContext, java.lang.String, org.nuxeo.lib.stream.computation.Record) or Computation.processTimer(org.nuxeo.lib.stream.computation.ComputationContext, java.lang.String, long) fails and cannot be retried.
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) Called after a failure in Computation.processRecord(org.nuxeo.lib.stream.computation.ComputationContext, java.lang.String, org.nuxeo.lib.stream.computation.Record) or Computation.processTimer(org.nuxeo.lib.stream.computation.ComputationContext, java.lang.String, long) before retrying.
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)

Uses of ComputationContext in org.nuxeo.lib.stream.computation.internals

Classes in org.nuxeo.lib.stream.computation.internals that implement ComputationContext

Modifier and Type	Class and Description
class	ComputationContextImpl

Uses of ComputationContext in org.nuxeo.lib.stream.tools.command

Methods in org.nuxeo.lib.stream.tools.command with parameters of type ComputationContext

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)