Package | Description |
---|---|
org.nuxeo.ecm.platform.importer.mqueues.computation | |
org.nuxeo.ecm.platform.importer.mqueues.computation.internals | |
org.nuxeo.ecm.platform.importer.mqueues.computation.mqueue |
Computation pattern with an implementation using MQueue.
|
org.nuxeo.ecm.platform.importer.mqueues.workmanager |
Class and Description |
---|
Computation
Computation receive record from input streams one at a time, it can produce record on its output streams.
|
ComputationContext |
ComputationMetadata |
ComputationMetadataMapping |
Record |
Record.Flag |
Settings
Enable to configure the stream partitioning and computation concurrency.
|
Topology |
Topology.Builder |
Topology.Vertex |
Watermark
Watermark represents a point in time.
|
Class and Description |
---|
ComputationContext |
ComputationMetadataMapping |
Record |
Watermark
Watermark represents a point in time.
|
Class and Description |
---|
Computation
Computation receive record from input streams one at a time, it can produce record on its output streams.
|
ComputationManager |
ComputationMetadataMapping |
Record |
Settings
Enable to configure the stream partitioning and computation concurrency.
|
Topology |
Watermark
Watermark represents a point in time.
|
Class and Description |
---|
AbstractComputation
An abstract
Computation that manage the metadata init. |
Computation
Computation receive record from input streams one at a time, it can produce record on its output streams.
|
ComputationContext |
Record |
Settings
Enable to configure the stream partitioning and computation concurrency.
|
Topology |
Copyright © 2017 Nuxeo. All rights reserved.