Class and Description |
---|
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 ... |
Computation
Computation receives records from input streams one at a time, it can produce record on its output streams.
|
ComputationContext |
Record
Basic data object that contains: key, watermark, flag and data.
|
Topology
Represent a Directed Acyclic Graph (DAG) of computations.
|
Class and Description |
---|
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 ... |
Computation
Computation receives records from input streams one at a time, it can produce record on its output streams.
|
Topology
Represent a Directed Acyclic Graph (DAG) of computations.
|
Class and Description |
---|
StreamProcessor
Run a topology of computations according to some settings.
|
Topology
Represent a Directed Acyclic Graph (DAG) of computations.
|
Class and Description |
---|
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 ... |
Computation
Computation receives records from input streams one at a time, it can produce record on its output streams.
|
Topology
Represent a Directed Acyclic Graph (DAG) of computations.
|
Class and Description |
---|
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 ... |
Computation
Computation receives records from input streams one at a time, it can produce record on its output streams.
|
ComputationContext |
Record
Basic data object that contains: key, watermark, flag and data.
|
Class and Description |
---|
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 ... |
Computation
Computation receives records from input streams one at a time, it can produce record on its output streams.
|
ComputationContext |
Record
Basic data object that contains: key, watermark, flag and data.
|
Class and Description |
---|
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 ... |
Computation
Computation receives records from input streams one at a time, it can produce record on its output streams.
|
ComputationContext |
Record
Basic data object that contains: key, watermark, flag and data.
|
Settings
Settings defines stream's partitions and computation's concurrency and policy.
|
StreamProcessor
Run a topology of computations according to some settings.
|
Topology
Represent a Directed Acyclic Graph (DAG) of computations.
|
Class and 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 ... |
Computation
Computation receives records from input streams one at a time, it can produce record on its output streams.
|
ComputationContext |
Record
Basic data object that contains: key, watermark, flag and data.
|
Topology
Represent a Directed Acyclic Graph (DAG) of computations.
|
Class and Description |
---|
Record
Basic data object that contains: key, watermark, flag and data.
|
Class and Description |
---|
Topology
Represent a Directed Acyclic Graph (DAG) of computations.
|
Class and Description |
---|
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 ... |
Computation
Computation receives records from input streams one at a time, it can produce record on its output streams.
|
ComputationContext |
Class and Description |
---|
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 ... |
Computation
Computation receives records from input streams one at a time, it can produce record on its output streams.
|
ComputationContext |
Record
Basic data object that contains: key, watermark, flag and data.
|
Topology
Represent a Directed Acyclic Graph (DAG) of computations.
|
Class and Description |
---|
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 ... |
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 |
Settings
Settings defines stream's partitions and computation's concurrency and policy.
|
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.
|
Class and Description |
---|
ComputationContext |
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.
|
Record
Basic data object that contains: key, watermark, flag and data.
|
Watermark
Watermark represents a point in time.
|
Class and Description |
---|
Computation
Computation receives records from input streams one at a time, it can produce record on its output streams.
|
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.
|
Record
Basic data object that contains: key, watermark, flag and data.
|
Settings
Settings defines stream's partitions and computation's concurrency and policy.
|
StreamProcessor
Run a topology of computations according to some settings.
|
Topology
Represent a Directed Acyclic Graph (DAG) of computations.
|
Watermark
Watermark represents a point in time.
|
Class and Description |
---|
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 ... |
Computation
Computation receives records from input streams one at a time, it can produce record on its output streams.
|
ComputationContext |
Record
Basic data object that contains: key, watermark, flag and data.
|
Topology
Represent a Directed Acyclic Graph (DAG) of computations.
|
Class and Description |
---|
Record
Basic data object that contains: key, watermark, flag and data.
|
Class and Description |
---|
Record
Basic data object that contains: key, watermark, flag and data.
|
Class and Description |
---|
ComputationPolicy
Defines how a computation should handle the retries, fallback and batching if any.
|
Settings
Settings defines stream's partitions and computation's concurrency and policy.
|
StreamProcessor
Run a topology of computations according to some settings.
|
Topology
Represent a Directed Acyclic Graph (DAG) of computations.
|
Copyright © 2019 Nuxeo. All rights reserved.