Package | Description |
---|---|
org.nuxeo.audit.storage.stream | |
org.nuxeo.ecm.automation.core.operations.services.bulk | |
org.nuxeo.ecm.core.bulk | |
org.nuxeo.ecm.core.bulk.action | |
org.nuxeo.ecm.core.work | |
org.nuxeo.ecm.platform.audit.impl | |
org.nuxeo.ecm.platform.csv.export.action | |
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 | |
org.nuxeo.runtime.stream |
Modifier and Type | Method and Description |
---|---|
Topology |
StreamAuditStorageWriter.getTopology(Map<String,String> options) |
Modifier and Type | Method and Description |
---|---|
Topology |
AutomationBulkAction.getTopology(Map<String,String> options) |
Modifier and Type | Method and Description |
---|---|
protected Topology |
BulkAdminServiceImpl.getTopology(int scrollBatchSize,
int scrollKeepAlive,
boolean scrollProduceImmediate) |
Modifier and Type | Method and Description |
---|---|
Topology |
TrashAction.getTopology(Map<String,String> options) |
Topology |
SetSystemPropertiesAction.getTopology(Map<String,String> options) |
Topology |
SetPropertiesAction.getTopology(Map<String,String> options) |
Topology |
RemoveProxyAction.getTopology(Map<String,String> options) |
Modifier and Type | Field and Description |
---|---|
protected Topology |
StreamWorkManager.topology |
Modifier and Type | Method and Description |
---|---|
Topology |
StreamAuditWriter.getTopology(Map<String,String> options) |
Modifier and Type | Method and Description |
---|---|
Topology |
CSVExportAction.getTopology(Map<String,String> options) |
Modifier and Type | Method and Description |
---|---|
Topology |
IndexAction.getTopology(Map<String,String> options) |
Modifier and Type | Method and Description |
---|---|
Topology |
Topology.Builder.build() |
Modifier and Type | Method and Description |
---|---|
StreamProcessor |
StreamProcessor.init(Topology topology,
Settings settings)
Initialize streams, but don't run the computations
|
Modifier and Type | Field and Description |
---|---|
protected Topology |
LogStreamProcessor.topology |
Modifier and Type | Method and Description |
---|---|
StreamProcessor |
LogStreamProcessor.init(Topology topology,
Settings settings) |
Modifier and Type | Field and Description |
---|---|
protected Topology |
TrackerCommand.topology |
protected Topology |
MonitorCommand.topology |
Modifier and Type | Method and Description |
---|---|
Topology |
StreamProcessorTopology.getTopology(Map<String,String> options)
Returns a Stream computation topology.
|
Copyright © 2019 Nuxeo. All rights reserved.