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 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) |
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.
|
protected final int defaultConcurrency
protected final int defaultPartitions
protected final Codec<Record> defaultCodec
protected final ComputationPolicy defaultPolicy
protected final Map<String,Integer> concurrencies
protected final Map<String,Integer> partitions
protected final Map<String,ComputationPolicy> policies
public Settings(int defaultConcurrency, int defaultPartitions)
public Settings(int defaultConcurrency, int defaultPartitions, Codec<Record> defaultCodec)
public Settings(int defaultConcurrency, int defaultPartitions, ComputationPolicy defaultPolicy)
public Settings(int defaultConcurrency, int defaultPartitions, Codec<Record> defaultCodec, ComputationPolicy defaultPolicy)
public Settings setConcurrency(String computationName, int concurrency)
public int getConcurrency(String computationName)
public Settings setPartitions(String streamName, int partitions)
public int getPartitions(String streamName)
public Settings setCodec(String streamName, Codec<Record> codec)
public Settings setPolicy(String computationName, ComputationPolicy policy)
public ComputationPolicy getPolicy(String computationName)
Copyright © 2019 Nuxeo. All rights reserved.