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 and policy.

Since:

9.3

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,Codec<Record>>	codecs
protected Map<String,Integer>	concurrencies
protected Codec<Record>	defaultCodec
protected int	defaultConcurrency
protected int	defaultPartitions
protected ComputationPolicy	defaultPolicy
protected Map<String,Integer>	partitions
protected Map<String,ComputationPolicy>	policies

Constructor Summary

Constructors

Constructor and Description
Settings(int defaultConcurrency, int defaultPartitions) Default concurrency and partition to use if not specified explicitly.
Settings(int defaultConcurrency, int defaultPartitions, Codec<Record> defaultCodec) Default concurrency and partition to use if not specified explicitly.
Settings(int defaultConcurrency, int defaultPartitions, Codec<Record> defaultCodec, ComputationPolicy defaultPolicy)
Settings(int defaultConcurrency, int defaultPartitions, ComputationPolicy defaultPolicy)

Method Summary

Modifier and Type	Method and Description
Codec<Record>	getCodec(String streamName) Gets the codec for a stream.
int	getConcurrency(String computationName)
int	getPartitions(String streamName)
ComputationPolicy	getPolicy(String computationName) Gets the policy for a computation.
Settings	setCodec(String streamName, Codec<Record> codec) Sets the codec for a stream.
Settings	setConcurrency(String computationName, int concurrency) Sets the computation thread pool size.
Settings	setPartitions(String streamName, int partitions) Sets the number of partitions for a stream.
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.

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

defaultCodec

protected final Codec<Record> defaultCodec

defaultPolicy

protected final ComputationPolicy defaultPolicy

concurrencies

protected final Map<String,Integer> concurrencies

partitions

protected final Map<String,Integer> partitions

codecs

protected final Map<String,Codec<Record>> codecs

policies

protected final Map<String,ComputationPolicy> policies

Constructor Detail

Settings

public Settings(int defaultConcurrency,
                int defaultPartitions)

Default concurrency and partition to use if not specified explicitly.

Settings

public Settings(int defaultConcurrency,
                int defaultPartitions,
                Codec<Record> defaultCodec)

Default concurrency and partition to use if not specified explicitly.

Settings

public Settings(int defaultConcurrency,
                int defaultPartitions,
                ComputationPolicy defaultPolicy)

Settings

public Settings(int defaultConcurrency,
                int defaultPartitions,
                Codec<Record> defaultCodec,
                ComputationPolicy defaultPolicy)

Method Detail

setConcurrency

public Settings setConcurrency(String computationName,
                               int concurrency)

Sets the computation thread pool size.

getConcurrency

public int getConcurrency(String computationName)

setPartitions

public Settings setPartitions(String streamName,
                              int partitions)

Sets the number of partitions for a stream.

getPartitions

public int getPartitions(String streamName)

setCodec

public Settings setCodec(String streamName,
                         Codec<Record> codec)

Sets the codec for a stream.

Since:

10.2

getCodec

public Codec<Record> getCodec(String streamName)

Gets the codec for a stream.

Since:

10.2

setPolicy

public 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.

Since:

10.3

getPolicy

public ComputationPolicy getPolicy(String computationName)

Gets the policy for a computation.

Since:

10.3