Package org.nuxeo.lib.stream.computation
The Computation pattern with a Log implementation.
-
Interface Summary Interface Description Computation Computation receives records from input streams one at a time, it can produce record on its output streams.ComputationContext 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.StreamProcessor Run a topology of computations according to some settings. -
Class Summary Class Description AbstractBatchComputation An abstractComputation
that processes records by batch.AbstractComputation An abstractComputation
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.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.Settings Settings defines stream's partitions and computation's concurrency and policy.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