Package | Description |
---|---|
org.nuxeo.audit.storage.stream | |
org.nuxeo.ecm.core.bulk | |
org.nuxeo.ecm.core.bulk.actions | |
org.nuxeo.ecm.core.work | |
org.nuxeo.ecm.platform.audit.impl | |
org.nuxeo.lib.stream.computation |
The Computation pattern with a Log implementation.
|
org.nuxeo.lib.stream.computation.log |
Computation pattern implemented with Log
|
org.nuxeo.lib.stream.tools.command |
Modifier and Type | Class and Description |
---|---|
class |
StreamAuditStorageWriter.AuditStorageLogWriterComputation |
Modifier and Type | Class and Description |
---|---|
static class |
StreamBulkProcessor.BulkDocumentScrollerComputation |
static class |
StreamBulkProcessor.CounterComputation |
static class |
StreamBulkProcessor.KeyValueWriterComputation |
Modifier and Type | Class and Description |
---|---|
static class |
SetPropertiesAction.SetPropertyComputation |
Modifier and Type | Class and Description |
---|---|
class |
WorkComputation
A Stream computation that consumes works.
|
Modifier and Type | Class and Description |
---|---|
static class |
StreamAuditWriter.AuditLogWriterComputation |
Modifier and Type | Class and Description |
---|---|
class |
AbstractComputation
An abstract
Computation that manages the metadata init. |
Modifier and Type | Field and Description |
---|---|
protected Map<String,Supplier<Computation>> |
Topology.supplierMap |
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) |
Modifier and Type | Field and Description |
---|---|
protected Computation |
ComputationRunner.computation |
Modifier and Type | Field and Description |
---|---|
protected Supplier<Computation> |
ComputationRunner.supplier |
protected Supplier<Computation> |
ComputationPool.supplier |
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) |
Modifier and Type | Class and Description |
---|---|
class |
LatencyTrackerComputation
A computation that sends periodically latencies information into a Log.
|
Copyright © 2018 Nuxeo. All rights reserved.