See: Description
| 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 | 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 ... |
| 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 | Description |
|---|---|
| Record.Flag | |
| Topology.VertexType |
Copyright © 2019 Nuxeo. All rights reserved.