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 |
Modifier and Type | Method and Description |
---|---|
static Record |
Record.of(String key,
byte[] data) |
Modifier and Type | Method and Description |
---|---|
void |
Computation.processRecord(ComputationContext context,
String inputStreamName,
Record record)
Process an incoming record on one of the computation's input streams.
|
void |
ComputationContext.produceRecord(String streamName,
Record record) |
Modifier and Type | Method and Description |
---|---|
List<Record> |
ComputationContextImpl.getRecords(String streamName) |
Modifier and Type | Method and Description |
---|---|
void |
ComputationContextImpl.produceRecord(String streamName,
Record record) |
Constructor and Description |
---|
MQComputationManager(MQManager<Record> manager,
Topology topology,
Settings settings) |
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 | Field and Description |
---|---|
protected MQManager<Record> |
WorkManagerComputation.mqManager |
Modifier and Type | Method and Description |
---|---|
protected abstract MQManager<Record> |
WorkManagerComputation.initStream() |
protected MQManager<Record> |
WorkManagerComputationChronicle.initStream() |
protected MQManager<Record> |
WorkManagerComputationKafka.initStream() |
Modifier and Type | Method and Description |
---|---|
void |
ComputationWork.processRecord(ComputationContext context,
String inputStreamName,
Record record) |
Copyright © 2017 Nuxeo. All rights reserved.