Package | Description |
---|---|
org.nuxeo.audit.storage.stream | |
org.nuxeo.ecm.automation.core.operations.services.bulk | |
org.nuxeo.ecm.core.bulk.action | |
org.nuxeo.ecm.core.bulk.action.computation | |
org.nuxeo.ecm.core.bulk.computation | |
org.nuxeo.ecm.core.work | |
org.nuxeo.ecm.platform.audit.impl | |
org.nuxeo.ecm.platform.csv.export.computation | |
org.nuxeo.elasticsearch.bulk | |
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 |
AutomationBulkAction.AutomationComputation |
Modifier and Type | Class and Description |
---|---|
static class |
RemoveProxyAction.RemoveProxyComputation |
static class |
SetPropertiesAction.SetPropertyComputation |
static class |
SetSystemPropertiesAction.SetSystemPropertyComputation |
static class |
TrashAction.TrashComputation |
Modifier and Type | Class and Description |
---|---|
class |
AbstractBulkComputation
Base class for bulk action computation.
|
class |
AbstractTransientBlobComputation |
class |
ExposeBlob |
class |
MakeBlob |
class |
SortBlob |
class |
ZipBlob |
Modifier and Type | Class and Description |
---|---|
class |
BulkScrollerComputation
Materializes the document set for a command.
|
class |
BulkStatusComputation
Saves the status into a key value store.
|
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 |
CSVProjectionComputation
Outputs
o1: Writes
Record containing csv lines
|
Modifier and Type | Class and Description |
---|---|
class |
BulkIndexComputation
A computation that submits elasticsearch requests using the bulk API.
|
class |
IndexCompletionComputation
On indexing completion, do extra tasks like refresh or update index alias.
|
class |
IndexRequestComputation
Build elasticsearch requests to index documents.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractBatchComputation
An abstract
Computation that processes records by batch. |
class |
AbstractComputation
An abstract
Computation that manages the metadata init.By convention the inputs streams are named internally: i1, i2 ... and the output streams are named: o1, o2 ... |
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,
ComputationPolicy policy) |
ComputationRunner(Supplier<Computation> supplier,
ComputationMetadataMapping metadata,
List<LogPartition> defaultAssignment,
LogManager logManager,
Codec<Record> inputCodec,
Codec<Record> outputCodec,
ComputationPolicy policy) |
Modifier and Type | Class and Description |
---|---|
class |
LatencyMonitorComputation
A computation that sends periodically latencies to graphite.
|
class |
LatencyTrackerComputation
A computation that sends periodically latencies information into a Log.
|
Copyright © 2019 Nuxeo. All rights reserved.