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) |
Modifier and Type | Field and Description |
---|---|
protected ComputationMetadataMapping |
ComputationContextImpl.metadata |
Constructor and Description |
---|
ComputationContextImpl(ComputationMetadataMapping metadata) |
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) |
ComputationRunner(Supplier<Computation> supplier,
ComputationMetadataMapping metadata,
List<LogPartition> defaultAssignment,
LogManager logManager,
Codec<Record> inputCodec,
Codec<Record> outputCodec) |
Copyright © 2018 Nuxeo. All rights reserved.