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 Map<String,Integer> |
partitions |
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
|
Modifier and Type | Method and Description |
---|---|
Codec<Record> |
getCodec(String streamName)
Get a codec for a stream
|
int |
getConcurrency(String computationName) |
int |
getPartitions(String streamName) |
Settings |
setCodec(String streamName,
Codec<Record> codec)
Set the codec for a stream
|
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.
|
protected final int defaultConcurrency
protected final int defaultPartitions
protected final Codec<Record> defaultCodec
protected final Map<String,Integer> concurrencies
protected final Map<String,Integer> partitions
public Settings(int defaultConcurrency, int defaultPartitions)
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)
Copyright © 2018 Nuxeo. All rights reserved.