Constructor and Description |
---|
Settings(int defaultConcurrency,
int defaultPartitions) |
Modifier and Type | Method and Description |
---|---|
int |
getConcurrency(String computationName) |
int |
getPartitions(String streamName) |
Settings |
setConcurrency(String computationName,
int concurrency) |
Settings |
setPartitions(String streamName,
int 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)
Copyright © 2017 Nuxeo. All rights reserved.