Package org.nuxeo.lib.stream.computation

package org.nuxeo.lib.stream.computation

The Computation pattern with a Log implementation.

Related Packages

Package	Description
org.nuxeo.lib.stream
org.nuxeo.lib.stream.computation.internals
org.nuxeo.lib.stream.computation.log	Computation pattern implemented with Log
org.nuxeo.lib.stream.codec
org.nuxeo.lib.stream.log	The Log interface with In-Memory and Kafka implementation.
org.nuxeo.lib.stream.pattern	Here is a producer consumer pattern that relies on Log.
org.nuxeo.lib.stream.tools	Some tools for debugging on existing Log and Computations

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
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.
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.Builder
Topology.Vertex
Topology.VertexType
Watermark	Watermark represents a point in time.