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

Packages that use org.nuxeo.lib.stream.computation

Package	Description
org.nuxeo.ecm.core.work
org.nuxeo.ecm.platform.audit.impl
org.nuxeo.ecm.platform.audit.listener
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.renderer
org.nuxeo.runtime.stream

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.
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.
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
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 and Description
Record Basic data object that contains: key, watermark, flag and data.

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

Class and Description
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.
Record Basic data object that contains: key, watermark, flag and data.
Record.Flag
Settings Settings defines stream's partitions and computation's concurrency.
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.
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.
Record Basic data object that contains: key, watermark, flag and data.
Settings Settings defines stream's partitions and computation's concurrency.
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.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.stream

Class and Description
Settings Settings defines stream's partitions and computation's concurrency.
StreamProcessor Run a topology of computations according to some settings.
Topology Represent a Directed Acyclic Graph (DAG) of computations.