org.nuxeo.lib.stream.computation

Class Settings

java.lang.Object

org.nuxeo.lib.stream.computation.Settings

public class Settings
extends Object

Settings defines stream's partitions and computation's concurrency.

Since:

9.3

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,Integer>	concurrencies
protected int	defaultConcurrency
protected int	defaultPartitions
protected Map<String,Integer>	partitions

Constructor Summary

Constructors

Constructor and Description
Settings(int defaultConcurrency, int defaultPartitions) Default concurrency and partition to use if not specified explicitly

Method Summary

Modifier and Type	Method and Description
int	getConcurrency(String computationName)
int	getPartitions(String streamName)
Settings	setConcurrency(String computationName, int concurrency) Set the computation thread pool size.
Settings	setPartitions(String streamName, int partitions) Set the number of partitions for a stream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

defaultConcurrency

protected final int defaultConcurrency

defaultPartitions

protected final int defaultPartitions

concurrencies

protected final Map<String,Integer> concurrencies

partitions

protected final Map<String,Integer> partitions

Constructor Detail

Settings

public Settings(int defaultConcurrency,
                int defaultPartitions)

Default concurrency and partition to use if not specified explicitly

Method Detail

setConcurrency

public Settings setConcurrency(String computationName,
                               int concurrency)

Set the computation thread pool size.

getConcurrency

public int getConcurrency(String computationName)

setPartitions

public Settings setPartitions(String streamName,
                              int partitions)

Set the number of partitions for a stream.

getPartitions

public int getPartitions(String streamName)