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.