Package org.nuxeo.lib.stream.computation

The Computation pattern with a Log implementation.

See: Description

Interface Summary

Interface	Description
Computation	Computation receives records from input streams one at a time, it can produce record on its output streams.
ComputationContext
StreamProcessor	Run a topology of computations according to some settings.

Class Summary

Class	Description
AbstractComputation	An abstract Computation that manages the metadata init.
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.
Settings	Settings defines stream's partitions and computation's concurrency.
Topology	Represent a Directed Acyclic Graph (DAG) of computations.
Topology.Builder
Topology.Vertex
Watermark	Watermark represents a point in time.

Enum Summary

Enum	Description
Record.Flag
Topology.VertexType

Package org.nuxeo.lib.stream.computation Description

The Computation pattern with a Log implementation.