Package | Description |
---|---|
org.nuxeo.ecm.platform.importer.mqueues.computation | |
org.nuxeo.ecm.platform.importer.mqueues.computation.mqueue |
Computation pattern with an implementation using MQueue.
|
org.nuxeo.ecm.platform.importer.mqueues.workmanager |
Modifier and Type | Class and Description |
---|---|
class |
AbstractComputation
An abstract
Computation that manage the metadata init. |
Modifier and Type | Method and Description |
---|---|
Supplier<Computation> |
Topology.getSupplier(String name) |
Modifier and Type | Method and Description |
---|---|
Topology.Builder |
Topology.Builder.addComputation(Supplier<Computation> supplier,
List<String> mapping) |
Constructor and Description |
---|
MQComputationPool(Supplier<Computation> supplier,
ComputationMetadataMapping metadata,
List<List<MQPartition>> defaultAssignments,
MQManager<Record> manager) |
MQComputationRunner(Supplier<Computation> supplier,
ComputationMetadataMapping metadata,
List<MQPartition> defaultAssignment,
MQManager<Record> mqManager) |
Modifier and Type | Class and Description |
---|---|
class |
ComputationWork |
Copyright © 2017 Nuxeo. All rights reserved.