Uses of Package
org.nuxeo.lib.stream.computation

Packages that use org.nuxeo.lib.stream.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.event.stream
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.transientstore.computation
org.nuxeo.ecm.core.work
org.nuxeo.ecm.platform.audit.impl
org.nuxeo.ecm.platform.audit.listener
org.nuxeo.ecm.platform.audit.stream
org.nuxeo.ecm.platform.csv.export.action
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.action
org.nuxeo.ecm.platform.video.computation
org.nuxeo.ecm.restapi.server.jaxrs.management
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.computation.log	Computation pattern implemented with Log
org.nuxeo.lib.stream.tools.command
org.nuxeo.lib.stream.tools.renderer
org.nuxeo.runtime.codec
org.nuxeo.runtime.pubsub
org.nuxeo.runtime.stream

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.audit.storage.stream

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
ComputationContext
Record	Basic data object that contains: key, watermark, flag and data.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.drive.action

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.automation.core.operations.services.bulk

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.automation.core.operations.services.workmanager

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
ComputationContext
ComputationPolicy	Defines how a computation should handle the retries, fallback and batching if any.
Record	Basic data object that contains: key, watermark, flag and data.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.action

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.blob.stream

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
ComputationContext
Record	Basic data object that contains: key, watermark, flag and data.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.bulk

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
StreamProcessor	Run a topology of computations according to some settings.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.bulk.action

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.bulk.action.computation

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
ComputationContext
Record	Basic data object that contains: key, watermark, flag and data.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.bulk.computation

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
ComputationContext
Record	Basic data object that contains: key, watermark, flag and data.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.bulk.introspection

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
ComputationContext
Record	Basic data object that contains: key, watermark, flag and data.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.event.stream

Class	Description
Record	Basic data object that contains: key, watermark, flag and data.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.migrator

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.model.stream

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
ComputationContext
Record	Basic data object that contains: key, watermark, flag and data.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.security

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.storage.action

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.storage.dbs.action

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.transientstore.computation

Class	Description
RecordFilter	Record filtering enables to modify/skip record while it is append or read from a stream.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.core.work

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
ComputationContext
Record	Basic data object that contains: key, watermark, flag and data.
RecordFilter	Record filtering enables to modify/skip record while it is append or read from a stream.
RecordFilterChain	A chain of record filters.
Settings	Settings defines stream's partitions and computation's concurrency and policy.
StreamManager	Gives access to StreamProcessor and appender for source provider.
StreamProcessor	Run a topology of computations according to some settings.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.platform.audit.impl

Class	Description
AbstractBatchComputation	An abstract Computation that processes records by batch.
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
ComputationContext
Record	Basic data object that contains: key, watermark, flag and data.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.platform.audit.listener

Class	Description
Record	Basic data object that contains: key, watermark, flag and data.
StreamManager	Gives access to StreamProcessor and appender for source provider.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.platform.audit.stream

Class	Description
Record	Basic data object that contains: key, watermark, flag and data.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.platform.csv.export.action

Class	Description
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.platform.csv.export.computation

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
ComputationContext

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.platform.picture.recompute

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.platform.routing.core.bulk

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.platform.thumbnail.action

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.platform.video.action

Class	Description
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.platform.video.computation

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
ComputationContext
Record	Basic data object that contains: key, watermark, flag and data.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.ecm.restapi.server.jaxrs.management

Class	Description
Record	Basic data object that contains: key, watermark, flag and data.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.elasticsearch.bulk

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
ComputationContext
Record	Basic data object that contains: key, watermark, flag and data.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.lib.stream.computation

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
ComputationContext
ComputationMetadata	The metadata defining a computation.
ComputationMetadataMapping	Extend the metadata to add a mapping for the input and output stream.
ComputationPolicy	Defines how a computation should handle the retries, fallback and batching if any.
ComputationPolicyBuilder	Builder to create a ComputationPolicy.
Record	Basic data object that contains: key, watermark, flag and data.
Record.Flag
RecordFilter	Record filtering enables to modify/skip record while it is append or read from a stream.
RecordFilterChain	A chain of record filters.
Settings	Settings defines stream's partitions and computation's concurrency and policy.
StreamProcessor	Run a topology of computations according to some settings.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.
Topology.Builder
Topology.Vertex
Topology.VertexType
Watermark	Watermark represents a point in time.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.lib.stream.computation.internals

Class	Description
ComputationContext
ComputationMetadataMapping	Extend the metadata to add a mapping for the input and output stream.
ComputationPolicy	Defines how a computation should handle the retries, fallback and batching if any.
Record	Basic data object that contains: key, watermark, flag and data.
RecordFilter	Record filtering enables to modify/skip record while it is append or read from a stream.
RecordFilterChain	A chain of record filters.
StreamManager	Gives access to StreamProcessor and appender for source provider.
Watermark	Watermark represents a point in time.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.lib.stream.computation.log

Class	Description
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
ComputationMetadataMapping	Extend the metadata to add a mapping for the input and output stream.
ComputationPolicy	Defines how a computation should handle the retries, fallback and batching if any.
Record	Basic data object that contains: key, watermark, flag and data.
RecordFilter	Record filtering enables to modify/skip record while it is append or read from a stream.
RecordFilterChain	A chain of record filters.
Settings	Settings defines stream's partitions and computation's concurrency and policy.
StreamManager	Gives access to StreamProcessor and appender for source provider.
StreamProcessor	Run a topology of computations according to some settings.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.
Topology.Vertex
Watermark	Watermark represents a point in time.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.lib.stream.tools.command

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
ComputationContext
Record	Basic data object that contains: key, watermark, flag and data.
StreamProcessor	Run a topology of computations according to some settings.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.lib.stream.tools.renderer

Class	Description
Record	Basic data object that contains: key, watermark, flag and data.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.runtime.codec

Class	Description
Record	Basic data object that contains: key, watermark, flag and data.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.runtime.pubsub

Class	Description
Record	Basic data object that contains: key, watermark, flag and data.

Classes in org.nuxeo.lib.stream.computation used by org.nuxeo.runtime.stream

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
ComputationContext
ComputationPolicy	Defines how a computation should handle the retries, fallback and batching if any.
ComputationPolicyBuilder	Builder to create a ComputationPolicy.
Record	Basic data object that contains: key, watermark, flag and data.
RecordFilter	Record filtering enables to modify/skip record while it is append or read from a stream.
Settings	Settings defines stream's partitions and computation's concurrency and policy.
StreamManager	Gives access to StreamProcessor and appender for source provider.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.