| Package | Description |
|---|---|
| org.nuxeo.lib.stream.computation |
The Computation pattern with a Log implementation.
|
| org.nuxeo.lib.stream.computation.internals | |
| org.nuxeo.lib.stream.computation.log |
Computation pattern implemented with Log
|
| Modifier and Type | Field and Description |
|---|---|
protected List<ComputationMetadataMapping> |
Topology.metadataList |
protected Map<String,ComputationMetadataMapping> |
Topology.metadataMap |
| Modifier and Type | Method and Description |
|---|---|
ComputationMetadataMapping |
Topology.getMetadata(String name) |
| Modifier and Type | Method and Description |
|---|---|
List<ComputationMetadataMapping> |
Topology.metadataList() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
Topology.generateDag(Set<ComputationMetadataMapping> metadataSet) |
protected void |
Topology.generateMetadataMapping(Set<ComputationMetadataMapping> metadataSet) |
| Modifier and Type | Field and Description |
|---|---|
protected ComputationMetadataMapping |
ComputationContextImpl.metadata |
| Constructor and Description |
|---|
ComputationContextImpl(ComputationMetadataMapping computationMetadataMapping) |
ComputationContextImpl(LogManager logManager,
ComputationMetadataMapping metadata) |
ComputationContextImpl(LogManager logManager,
ComputationMetadataMapping metadata,
ComputationPolicy policy) |
| Modifier and Type | Field and Description |
|---|---|
protected ComputationMetadataMapping |
ComputationRunner.metadata |
protected ComputationMetadataMapping |
ComputationPool.metadata |
| Modifier and Type | Method and Description |
|---|---|
protected List<List<LogPartition>> |
LogStreamProcessor.getDefaultAssignments(ComputationMetadataMapping meta) |
| Constructor and Description |
|---|
ComputationPool(Supplier<Computation> supplier,
ComputationMetadataMapping metadata,
List<List<LogPartition>> defaultAssignments,
LogManager manager,
Codec<Record> inputCodec,
Codec<Record> outputCodec,
ComputationPolicy policy) |
ComputationRunner(Supplier<Computation> supplier,
ComputationMetadataMapping metadata,
List<LogPartition> defaultAssignment,
LogManager logManager,
Codec<Record> inputCodec,
Codec<Record> outputCodec,
ComputationPolicy policy) |
Copyright © 2019 Nuxeo. All rights reserved.