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

Packages that use Computation

Package	Description
org.nuxeo.audit.storage.stream
org.nuxeo.drive.action
org.nuxeo.ecm.automation.core.operations.services.bulk
org.nuxeo.ecm.automation.core.operations.services.workmanager
org.nuxeo.ecm.core.action
org.nuxeo.ecm.core.blob.stream
org.nuxeo.ecm.core.bulk
org.nuxeo.ecm.core.bulk.action
org.nuxeo.ecm.core.bulk.action.computation
org.nuxeo.ecm.core.bulk.computation
org.nuxeo.ecm.core.bulk.introspection
org.nuxeo.ecm.core.migrator
org.nuxeo.ecm.core.model.stream
org.nuxeo.ecm.core.security
org.nuxeo.ecm.core.storage.action
org.nuxeo.ecm.core.storage.dbs.action
org.nuxeo.ecm.core.work
org.nuxeo.ecm.platform.audit.impl
org.nuxeo.ecm.platform.csv.export.computation
org.nuxeo.ecm.platform.picture.recompute
org.nuxeo.ecm.platform.routing.core.bulk
org.nuxeo.ecm.platform.thumbnail.action
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.log	Computation pattern implemented with Log
org.nuxeo.lib.stream.tools.command
org.nuxeo.runtime.stream

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

Classes in org.nuxeo.audit.storage.stream that implement Computation

Modifier and Type	Class	Description
class	StreamAuditStorageWriter.AuditStorageLogWriterComputation

Uses of Computation in org.nuxeo.drive.action

Classes in org.nuxeo.drive.action that implement Computation

Modifier and Type	Class	Description
static class	FireGroupUpdatedEventAction.FireGroupUpdatedEventComputation

Uses of Computation in org.nuxeo.ecm.automation.core.operations.services.bulk

Classes in org.nuxeo.ecm.automation.core.operations.services.bulk that implement Computation

Modifier and Type	Class	Description
static class	AbstractAutomationBulkAction.AutomationComputation

Uses of Computation in org.nuxeo.ecm.automation.core.operations.services.workmanager

Classes in org.nuxeo.ecm.automation.core.operations.services.workmanager that implement Computation

Modifier and Type	Class	Description
protected class	WorkManagerRunWorkInFailure.WorkFailureComputation

Uses of Computation in org.nuxeo.ecm.core.action

Classes in org.nuxeo.ecm.core.action that implement Computation

Modifier and Type	Class	Description
static class	DeletionAction.DeletionComputation
static class	GarbageCollectOrphanBlobsAction.GarbageCollectOrphanBlobsComputation
static class	GarbageCollectOrphanVersionsAction.GarbageCollectOrphanVersionsComputation

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

Classes in org.nuxeo.ecm.core.blob.stream that implement Computation

Modifier and Type	Class	Description
static class	StreamOrphanBlobGC.BlobGCComputation

Uses of Computation in org.nuxeo.ecm.core.bulk

Classes in org.nuxeo.ecm.core.bulk that implement Computation

Modifier and Type	Class	Description
static class	S3SetBlobLengthAction.SetBlobLengthComputation

Uses of Computation in org.nuxeo.ecm.core.bulk.action

Classes in org.nuxeo.ecm.core.bulk.action that implement Computation

Modifier and Type	Class	Description
static class	RemoveProxyAction.RemoveProxyComputation
static class	SetPropertiesAction.SetPropertyComputation
static class	SetSystemPropertiesAction.SetSystemPropertyComputation
static class	TrashAction.TrashComputation

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

Classes in org.nuxeo.ecm.core.bulk.action.computation that implement Computation

Modifier and Type	Class	Description
class	AbstractBulkComputation	Base class for bulk action computation.
class	AbstractTransientBlobComputation
class	ExposeBlob
class	MakeBlob
class	SortBlob
class	ZipBlob

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

Classes in org.nuxeo.ecm.core.bulk.computation that implement Computation

Modifier and Type	Class	Description
class	BulkScrollerComputation	Materializes the document set for a command if scroller is not external.
class	BulkStatusComputation	Saves the status into a key value store.

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

Classes in org.nuxeo.ecm.core.bulk.introspection that implement Computation

Modifier and Type	Class	Description
class	StreamIntrospectionComputation	A computation that reads processor and metrics streams to build a representation of stream activities in the cluster.

Uses of Computation in org.nuxeo.ecm.core.migrator

Classes in org.nuxeo.ecm.core.migrator that implement Computation

Modifier and Type	Class	Description
static class	AbstractBulkMigrator.MigrationComputation

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

Classes in org.nuxeo.ecm.core.model.stream that implement Computation

Modifier and Type	Class	Description
static class	StreamDocumentGC.DocumentGCComputation

Uses of Computation in org.nuxeo.ecm.core.security

Classes in org.nuxeo.ecm.core.security that implement Computation

Modifier and Type	Class	Description
static class	RetentionExpiredAction.RetentionExpiredComputation

Uses of Computation in org.nuxeo.ecm.core.storage.action

Classes in org.nuxeo.ecm.core.storage.action that implement Computation

Modifier and Type	Class	Description
static class	ExtractBinaryFulltextAction.ExtractBinaryFulltextComputation

Uses of Computation in org.nuxeo.ecm.core.storage.dbs.action

Classes in org.nuxeo.ecm.core.storage.dbs.action that implement Computation

Modifier and Type	Class	Description
static class	UpdateReadAclsAction.UpdateReadAclsComputation

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

Classes in org.nuxeo.ecm.core.work that implement Computation

Modifier and Type	Class	Description
class	WorkComputation	A Stream computation that consumes works.

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

Classes in org.nuxeo.ecm.platform.audit.impl that implement Computation

Modifier and Type	Class	Description
static class	StreamAuditWriter.AuditLogWriterComputation

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

Classes in org.nuxeo.ecm.platform.csv.export.computation that implement Computation

Modifier and Type	Class	Description
class	CSVProjectionComputation	Inputs: i1: Reads BulkBucket Outputs o1: Writes Record containing csv lines

Uses of Computation in org.nuxeo.ecm.platform.picture.recompute

Classes in org.nuxeo.ecm.platform.picture.recompute that implement Computation

Modifier and Type	Class	Description
static class	RecomputeViewsAction.RecomputeViewsComputation

Uses of Computation in org.nuxeo.ecm.platform.routing.core.bulk

Classes in org.nuxeo.ecm.platform.routing.core.bulk that implement Computation

Modifier and Type	Class	Description
static class	DocumentRoutingEscalationAction.DocumentRoutingEscalationComputation
static class	GarbageCollectRoutesAction.GarbageCollectRoutesComputation

Uses of Computation in org.nuxeo.ecm.platform.thumbnail.action

Classes in org.nuxeo.ecm.platform.thumbnail.action that implement Computation

Modifier and Type	Class	Description
static class	RecomputeThumbnailsAction.RecomputeThumbnailsComputation

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

Classes in org.nuxeo.ecm.platform.video.computation that implement Computation

Modifier and Type	Class	Description
class	RecomputeTranscodedVideosComputation	Computation that fills the conversions in the VideoConstants.TRANSCODED_VIDEOS_PROPERTY videos property
class	RecomputeVideoInfoComputation	Computation that fills Video Info.

Uses of Computation in org.nuxeo.elasticsearch.bulk

Classes in org.nuxeo.elasticsearch.bulk that implement Computation

Modifier and Type	Class	Description
class	BulkIndexComputation	A computation that submits elasticsearch requests using the bulk API.
class	IndexCompletionComputation	On indexing completion, do extra tasks like refresh or update index alias.
class	IndexRequestComputation	Build elasticsearch requests to index documents.

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

Classes in org.nuxeo.lib.stream.computation that implement Computation

Modifier and Type	Class	Description
class	AbstractBatchComputation	An abstract Computation that processes records by batch.
class	AbstractComputation	An abstract Computation that manages the metadata init.

Fields in org.nuxeo.lib.stream.computation with type parameters of type Computation

Modifier and Type	Field	Description
protected Map<String,Supplier<Computation>>	Topology.supplierMap

Methods in org.nuxeo.lib.stream.computation that return types with arguments of type Computation

Modifier and Type	Method	Description
Supplier<Computation>	Topology.getSupplier(String name)

Method parameters in org.nuxeo.lib.stream.computation with type arguments of type Computation

Modifier and Type	Method	Description
Topology.Builder	Topology.Builder.addComputation(Supplier<Computation> supplier, List<String> mapping)

Uses of Computation in org.nuxeo.lib.stream.computation.log

Fields in org.nuxeo.lib.stream.computation.log declared as Computation

Modifier and Type	Field	Description
protected Computation	ComputationRunner.computation

Fields in org.nuxeo.lib.stream.computation.log with type parameters of type Computation

Modifier and Type	Field	Description
protected Supplier<Computation>	ComputationPool.supplier
protected Supplier<Computation>	ComputationRunner.supplier

Constructor parameters in org.nuxeo.lib.stream.computation.log with type arguments of type Computation

Constructor	Description
ComputationPool(Supplier<Computation> supplier, ComputationMetadataMapping metadata, List<List<LogPartition>> defaultAssignments, LogStreamManager streamManager, ComputationPolicy policy)
ComputationRunner(Supplier<Computation> supplier, ComputationMetadataMapping metadata, List<LogPartition> defaultAssignment, LogStreamManager streamManager, ComputationPolicy policy)

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

Classes in org.nuxeo.lib.stream.tools.command that implement Computation

Modifier and Type	Class	Description
class	LatencyDatadogComputation	A computation that sends periodically latencies to Datadog.
class	LatencyMonitorComputation	A computation that sends periodically latencies to graphite.
class	LatencyTrackerComputation	A computation that sends periodically latencies information into a Log.

Uses of Computation in org.nuxeo.runtime.stream

Classes in org.nuxeo.runtime.stream that implement Computation

Modifier and Type	Class	Description
class	StreamMetricsComputation	A computation that exposes Nuxeo Stream metrics as Dropwizard metrics.