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

Packages that use ComputationContext

Package	Description
org.nuxeo.audit.storage.stream
org.nuxeo.ecm.automation.core.operations.services.workmanager
org.nuxeo.ecm.core.blob.stream
org.nuxeo.ecm.core.bulk.action.computation
org.nuxeo.ecm.core.bulk.computation
org.nuxeo.ecm.core.bulk.introspection
org.nuxeo.ecm.core.model.stream
org.nuxeo.ecm.core.work
org.nuxeo.ecm.platform.audit.impl
org.nuxeo.ecm.platform.csv.export.computation
org.nuxeo.ecm.platform.video.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
org.nuxeo.runtime.stream

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	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.automation.core.operations.services.workmanager

Methods in org.nuxeo.ecm.automation.core.operations.services.workmanager with parameters of type ComputationContext

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

Uses of ComputationContext in org.nuxeo.ecm.core.blob.stream

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

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

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	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	AbstractTransientBlobComputation.init(ComputationContext context)
void	MakeBlob.init(ComputationContext context)
void	AbstractBulkComputation.processFailure(ComputationContext context, Throwable failure)
void	AbstractBulkComputation.processRecord(ComputationContext context, String inputStreamName, Record record)
void	ExposeBlob.processRecord(ComputationContext context, String documentIdsStreamName, Record record)
void	MakeBlob.processRecord(ComputationContext context, String documentIdsStreamName, Record record)
void	SortBlob.processRecord(ComputationContext context, String inputStreamName, Record record)
void	ZipBlob.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	Description
void	BulkScrollerComputation.processRecord(ComputationContext context, String inputStreamName, Record record)
protected void	BulkScrollerComputation.processRecord(ComputationContext context, Record record)
void	BulkStatusComputation.processRecord(ComputationContext context, String inputStreamName, Record record)
protected void	BulkScrollerComputation.produceBucket(ComputationContext context, String commandId, int bucketSize, long bucketNumber, long documentCount)	Produces a bucket as a record to appropriate bulk action stream.
protected void	BulkScrollerComputation.updateStatusAfterScroll(ComputationContext context, String commandId, long documentCount, boolean limited)
protected void	BulkScrollerComputation.updateStatusAfterScroll(ComputationContext context, String commandId, long documentCount, String errorMessage, Integer errorCode, boolean limited)
protected void	BulkScrollerComputation.updateStatusAfterScroll(ComputationContext context, String commandId, String errorMessage, Integer errorCode)
protected void	BulkScrollerComputation.updateStatusAsFlushing(ComputationContext context, String commandId)
protected void	BulkScrollerComputation.updateStatusAsScrolling(ComputationContext context, String commandId)

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

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

Modifier and Type	Method	Description
void	StreamIntrospectionComputation.init(ComputationContext context)
void	StreamIntrospectionComputation.processRecord(ComputationContext context, String inputStreamName, Record record)
void	StreamIntrospectionComputation.processTimer(ComputationContext context, String key, long timestamp)

Uses of ComputationContext in org.nuxeo.ecm.core.model.stream

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

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

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	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	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	Description
void	CSVProjectionComputation.endBucket(ComputationContext context, BulkStatus delta)

Uses of ComputationContext in org.nuxeo.ecm.platform.video.computation

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

Modifier and Type	Method	Description
void	RecomputeVideoInfoComputation.endBucket(ComputationContext context, BulkStatus delta)
void	RecomputeVideoInfoComputation.processRecord(ComputationContext context, String inputStreamName, Record record)

Uses of ComputationContext in org.nuxeo.elasticsearch.bulk

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

Modifier and Type	Method	Description
void	IndexRequestComputation.endBucket(ComputationContext context, BulkStatus delta)
void	BulkIndexComputation.init(ComputationContext context)
void	IndexCompletionComputation.init(ComputationContext context)
void	BulkIndexComputation.processRecord(ComputationContext context, String inputStream, Record record)
void	IndexCompletionComputation.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	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	AbstractBatchComputation.init(ComputationContext context)
void	AbstractComputation.init(ComputationContext context)
void	Computation.init(ComputationContext context)	Called when the framework has registered the computation successfully.
void	AbstractBatchComputation.processFailure(ComputationContext context, Throwable failure)
void	AbstractComputation.processFailure(ComputationContext context, Throwable failure)
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	AbstractBatchComputation.processRecord(ComputationContext context, String inputStreamName, Record record)
void	Computation.processRecord(ComputationContext context, String inputStreamName, Record record)	Process an incoming record on one of the computation's input streams.
void	AbstractBatchComputation.processRetry(ComputationContext context, Throwable failure)
void	AbstractComputation.processRetry(ComputationContext context, Throwable failure)
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	AbstractBatchComputation.processTimer(ComputationContext context, String key, long timestamp)
void	AbstractComputation.processTimer(ComputationContext context, String key, long timestamp)
void	Computation.processTimer(ComputationContext context, String key, long timestamp)	Process a timer callback previously set via setTimer(String, long).

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	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	Description
void	LatencyDatadogComputation.init(ComputationContext context)
void	LatencyMonitorComputation.init(ComputationContext context)
void	LatencyTrackerComputation.init(ComputationContext context)
protected void	LatencyDatadogComputation.processLatencies(ComputationContext context, LogPartitionGroup logGroup, List<Latency> latencies)
protected void	LatencyMonitorComputation.processLatencies(ComputationContext context, LogPartitionGroup logGroup, List<Latency> latencies)
protected void	LatencyTrackerComputation.processLatencies(ComputationContext context, LogPartitionGroup logGroup, List<Latency> latencies)
void	LatencyTrackerComputation.processRecord(ComputationContext context, String inputStreamName, Record record)
void	LatencyTrackerComputation.processTimer(ComputationContext context, String key, long timestamp)

Uses of ComputationContext in org.nuxeo.runtime.stream

Methods in org.nuxeo.runtime.stream with parameters of type ComputationContext

Modifier and Type	Method	Description
void	StreamMetricsComputation.init(ComputationContext context)
void	StreamMetricsComputation.processRecord(ComputationContext context, String inputStreamName, Record record)
void	StreamMetricsComputation.processTimer(ComputationContext context, String key, long timestamp)