Uses of Interface
org.nuxeo.runtime.stream.StreamProcessorTopology

Packages that use StreamProcessorTopology

Package	Description
org.nuxeo.audit.storage.stream
org.nuxeo.drive.action
org.nuxeo.ecm.automation.core.operations.services.bulk
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.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.platform.audit.impl
org.nuxeo.ecm.platform.csv.export.action
org.nuxeo.ecm.platform.oauth2.bulk
org.nuxeo.ecm.platform.picture.recompute
org.nuxeo.ecm.platform.routing.core.bulk
org.nuxeo.ecm.platform.thumbnail.action
org.nuxeo.ecm.platform.video.action
org.nuxeo.elasticsearch.bulk
org.nuxeo.runtime.stream

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

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

Modifier and Type	Class	Description
class	StreamAuditStorageWriter	Computation that consumes a stream of Json log entries and write them to the Directory Audit Storage.

Uses of StreamProcessorTopology in org.nuxeo.drive.action

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

Modifier and Type	Class	Description
class	FireGroupUpdatedEventAction	Bulk Action processor that fires group updated events for Nuxeo Drive.

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

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

Modifier and Type	Class	Description
class	AbstractAutomationBulkAction	Bulk Action that runs an automation operation
class	AutomationBulkAction	Bulk Action that runs an automation operation
class	AutomationBulkActionUi	Bulk Action that runs an automation operation dedicated for UI

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

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

Modifier and Type	Class	Description
class	DeletionAction	Bulk Action to delete documents directly at storage level.
class	GarbageCollectOrphanBlobsAction	Removes the orphan document blobs.
class	GarbageCollectOrphanVersionsAction	Removes the orphan versions.

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

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

Modifier and Type	Class	Description
class	StreamOrphanBlobGC

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

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

Modifier and Type	Class	Description
class	BulkServiceProcessor
class	S3SetBlobLengthAction	Bulk Action to set blob length property using the length provided by the s3 binary store.

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

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

Modifier and Type	Class	Description
class	RemoveProxyAction	Removes documents which are proxies and whose id is contained in the given ids list.
class	SetPropertiesAction
class	SetSystemPropertiesAction
class	TrashAction

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

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

Modifier and Type	Class	Description
class	StreamIntrospectionProcessor	A processor to introspect Nuxeo Stream activities at the cluster level.

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

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

Modifier and Type	Class	Description
static class	AbstractBulkMigrator.MigrationAction

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

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

Modifier and Type	Class	Description
class	StreamDocumentGC	A Processor that clean repository on document deletion.

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

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

Modifier and Type	Class	Description
class	RetentionExpiredAction	Bulk action executed for documents whose retention has expired.

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

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

Modifier and Type	Class	Description
class	ExtractBinaryFulltextAction	Bulk Action to extract fulltext from blobs.
class	FixBinaryFulltextStorageAction	Bulk Action to fix the binary fulltext storage when switching storage from repository to blob using nuxeo.vcs.fulltext.storedInBlob=true on an existing instance.

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

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

Modifier and Type	Class	Description
class	UpdateReadAclsAction	Action to update the Read ACLs on a list of documents, without recursion.

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

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

Modifier and Type	Class	Description
class	StreamAuditWriter	Computation that consumes a stream of log entries and write them to the audit backend.

Uses of StreamProcessorTopology in org.nuxeo.ecm.platform.csv.export.action

Classes in org.nuxeo.ecm.platform.csv.export.action that implement StreamProcessorTopology

Modifier and Type	Class	Description
class	CSVExportAction

Uses of StreamProcessorTopology in org.nuxeo.ecm.platform.oauth2.bulk

Classes in org.nuxeo.ecm.platform.oauth2.bulk that implement StreamProcessorTopology

Modifier and Type	Class	Description
class	GarbageCollectExpiredOAuth2TokensAction

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

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

Modifier and Type	Class	Description
class	RecomputeViewsAction	BAF Computation that fills picture views for the blob property described by the given xpath.

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

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

Modifier and Type	Class	Description
class	DocumentRoutingEscalationAction	Computes the escalation rules to execute on given documents and then execute them.
class	GarbageCollectRoutesAction

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

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

Modifier and Type	Class	Description
class	RecomputeThumbnailsAction	Bulk Action processor that generates thumbnails from documents.

Uses of StreamProcessorTopology in org.nuxeo.ecm.platform.video.action

Classes in org.nuxeo.ecm.platform.video.action that implement StreamProcessorTopology

Modifier and Type	Class	Description
class	RecomputeVideoConversionsAction	BAF Computation that fills video renditions for the blob property described by the given xpath.

Uses of StreamProcessorTopology in org.nuxeo.elasticsearch.bulk

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

Modifier and Type	Class	Description
class	IndexAction	A Nuxeo Bulk Action to index documents. it decouples the document extraction to build the elasticsearch request and the indexing.

Uses of StreamProcessorTopology in org.nuxeo.runtime.stream

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

Modifier and Type	Class	Description
class	StreamMetricsProcessor	A processor fetching stream metrics populating Dropwizard metrics.

Fields in org.nuxeo.runtime.stream with type parameters of type StreamProcessorTopology

Modifier and Type	Field	Description
Class<? extends StreamProcessorTopology>	StreamProcessorDescriptor.klass