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.ecm.automation.core.operations.services.bulk
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.work
org.nuxeo.ecm.platform.audit.impl
org.nuxeo.ecm.platform.audit.listener
org.nuxeo.ecm.platform.csv.export.action
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.computation.log	Computation pattern implemented with Log
org.nuxeo.lib.stream.tools.command
org.nuxeo.lib.stream.tools.renderer
org.nuxeo.runtime.pubsub
org.nuxeo.runtime.stream

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

Class and Description
AbstractComputation An abstract Computation that manages the metadata init. By convention the inputs streams are named internally: i1, i2 ... and the output streams are named: o1, o2 ...
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.automation.core.operations.services.bulk

Class and Description
AbstractComputation An abstract Computation that manages the metadata init. By convention the inputs streams are named internally: i1, i2 ... and the output streams are named: o1, o2 ...
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

Class and Description
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 and Description
AbstractComputation An abstract Computation that manages the metadata init. By convention the inputs streams are named internally: i1, i2 ... and the output streams are named: o1, o2 ...
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 and Description
AbstractComputation An abstract Computation that manages the metadata init. By convention the inputs streams are named internally: i1, i2 ... and the output streams are named: o1, o2 ...
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 and Description
AbstractComputation An abstract Computation that manages the metadata init. By convention the inputs streams are named internally: i1, i2 ... and the output streams are named: o1, o2 ...
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.work

Class and Description
AbstractComputation An abstract Computation that manages the metadata init. By convention the inputs streams are named internally: i1, i2 ... and the output streams are named: o1, o2 ...
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.
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.

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

Class and Description
AbstractBatchComputation An abstract Computation that processes records by batch.
AbstractComputation An abstract Computation that manages the metadata init. By convention the inputs streams are named internally: i1, i2 ... and the output streams are named: o1, o2 ...
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 and 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 and 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 and Description
AbstractComputation An abstract Computation that manages the metadata init. By convention the inputs streams are named internally: i1, i2 ... and the output streams are named: o1, o2 ...
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.elasticsearch.bulk

Class and Description
AbstractComputation An abstract Computation that manages the metadata init. By convention the inputs streams are named internally: i1, i2 ... and the output streams are named: o1, o2 ...
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 and Description
AbstractComputation An abstract Computation that manages the metadata init. By convention the inputs streams are named internally: i1, i2 ... and the output streams are named: o1, o2 ...
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
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 and 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.
Watermark Watermark represents a point in time.

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

Class and 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.
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.
Watermark Watermark represents a point in time.

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

Class and Description
AbstractComputation An abstract Computation that manages the metadata init. By convention the inputs streams are named internally: i1, i2 ... and the output streams are named: o1, o2 ...
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.tools.renderer

Class and 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 and 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 and Description
ComputationPolicy Defines how a computation should handle the retries, fallback and batching if any.
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.