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.setCodec(String streamName,
Codec<Record> codec)
Sets the codec for a stream.
|
Settings |
Settings.setConcurrency(String computationName,
int concurrency)
Sets the computation thread pool size.
|
Settings |
Settings.setPartitions(String streamName,
int partitions)
Sets the number of partitions for a stream.
|
Settings |
Settings.setPolicy(String computationName,
ComputationPolicy policy)
Sets the policy for a computation, when using default as computationName this sets the default policy for all
computations in the processor.
|
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 |
---|---|
protected Settings |
StreamServiceImpl.getSettings(StreamProcessorDescriptor descriptor) |
Copyright © 2019 Nuxeo. All rights reserved.