Package | Description |
---|---|
org.nuxeo.ecm.core.work | |
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.runtime.stream |
Modifier and Type | Field and Description |
---|---|
protected Settings |
StreamWorkManager.settings |
Modifier and Type | Method and Description |
---|---|
Settings |
Settings.setConcurrency(String computationName,
int concurrency)
Set the computation thread pool size.
|
Settings |
Settings.setPartitions(String streamName,
int partitions)
Set the number of partitions for a stream.
|
Modifier and Type | Method and Description |
---|---|
StreamProcessor |
StreamProcessor.init(Topology topology,
Settings settings)
Initialize streams, but don't run the computations
|
String |
Topology.toPlantuml(Settings settings) |
Modifier and Type | Field and Description |
---|---|
protected Settings |
LogStreamProcessor.settings |
Modifier and Type | Method and Description |
---|---|
StreamProcessor |
LogStreamProcessor.init(Topology topology,
Settings settings) |
Modifier and Type | Method and Description |
---|---|
Settings |
StreamProcessorDescriptor.getSettings() |
Copyright © 2018 Nuxeo. All rights reserved.