本文整理了Java中backtype.storm.Config.setMaxTaskParallelism()方法的一些代码示例，展示了Config.setMaxTaskParallelism()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Config.setMaxTaskParallelism()方法的具体详情如下：
包路径：backtype.storm.Config
类名称：Config
方法名：setMaxTaskParallelism

Config.setMaxTaskParallelism介绍

暂无

代码示例

代码示例来源：origin: alibaba/jstorm

public void setMaxTaskParallelism(int max) {
  setMaxTaskParallelism(this, max);
}

代码示例来源：origin: alibaba/jstorm

@Override
public Map<String, Object> getComponentConfiguration() {
  Config conf = new Config();
  conf.setMaxTaskParallelism(1);
  return conf;
}

代码示例来源：origin: alibaba/jstorm

@Override
public Map<String, Object> getComponentConfiguration() {
  Config conf = new Config();
  conf.setMaxTaskParallelism(1);
  return conf;
}

代码示例来源：origin: alibaba/jstorm

@Override
  public Map<String, Object> getComponentConfiguration() {
    Config ret = new Config();
    ret.setMaxTaskParallelism(1);
    return ret;
  }
}

代码示例来源：origin: alibaba/jstorm

@Override
public Map<String, Object> getComponentConfiguration() {
  Config ret = new Config();
  ret.setMaxTaskParallelism(1);
  return ret;
}

代码示例来源：origin: alibaba/mdrill

@Override
public Map<String, Object> getComponentConfiguration() {
  Config ret = new Config();
  ret.setMaxTaskParallelism(1);
  return ret;
}

代码示例来源：origin: alibaba/jstorm

@Override
public Map<String, Object> getComponentConfiguration() {
  Config ret = new Config();
  ret.setMaxTaskParallelism(1);
  ret.registerSerialization(TransactionAttempt.class);
  return ret;
}

代码示例来源：origin: alibaba/jstorm

} else {
  conf.setMaxTaskParallelism(3);
  LocalDRPC drpc = new LocalDRPC();
  LocalCluster cluster = new LocalCluster();

代码示例来源：origin: com.n3twork.storm/storm-core

@Override
public Map<String, Object> getComponentConfiguration() {
  Config ret = new Config();
  ret.setMaxTaskParallelism(1);
  return ret;
}

代码示例来源：origin: com.alibaba.jstorm/jstorm-core

@Override
  public Map<String, Object> getComponentConfiguration() {
    Config ret = new Config();
    ret.setMaxTaskParallelism(1);
    return ret;
  }
}

代码示例来源：origin: udacity/ud381

/**
 * Component specific configuration
 */
@Override
public Map<String, Object> getComponentConfiguration() 
{
 // create the component config 
 Config ret = new Config();
 // set the parallelism for this spout to be 1
 ret.setMaxTaskParallelism(1);
 return ret;
}

代码示例来源：origin: com.alibaba.jstorm/jstorm-core

@Override
public Map<String, Object> getComponentConfiguration() {
  Config ret = new Config();
  ret.setMaxTaskParallelism(1);
  return ret;
}

代码示例来源：origin: lmco/streamflow

@Override
public Map<String, Object> getComponentConfiguration() {
  Config config = new Config();
  config.setMaxTaskParallelism(1);
  return config;
}

代码示例来源：origin: com.n3twork.storm/storm-core

@Override
public Map getComponentConfiguration() {
  Config conf = new Config();
  conf.setMaxTaskParallelism(1);
  return conf;
}

代码示例来源：origin: com.n3twork.storm/storm-core

@Override
  public Map<String, Object> getComponentConfiguration() {
    Config ret = new Config();
    ret.setMaxTaskParallelism(1);
    return ret;
  }   
}

代码示例来源：origin: udacity/ud381

/**
 * Component specific configuration
 */
@Override
public Map<String, Object> getComponentConfiguration() 
{
 // create the component config 
 Config ret = new Config();
 // set the parallelism for this spout to be 1
 ret.setMaxTaskParallelism(1);
 return ret;
}

代码示例来源：origin: udacity/ud381

/**
 * Component specific configuration
 */
@Override
public Map<String, Object> getComponentConfiguration() 
{
 // create the component config 
 Config ret = new Config();
 // set the parallelism for this spout to be 1
 ret.setMaxTaskParallelism(1);
 return ret;
}

代码示例来源：origin: udacity/ud381

/**
 * Component specific configuration
 */
@Override
public Map<String, Object> getComponentConfiguration() 
{
 // create the component config 
 Config ret = new Config();
 // set the parallelism for this spout to be 1
 ret.setMaxTaskParallelism(1);
 return ret;
}

代码示例来源：origin: com.n3twork.storm/storm-core

@Override
public Map<String, Object> getComponentConfiguration() {
  Config ret = new Config();
  ret.setMaxTaskParallelism(1);
  ret.registerSerialization(TransactionAttempt.class);
  return ret;
}

代码示例来源：origin: com.alibaba.jstorm/jstorm-core

@Override
public Map<String, Object> getComponentConfiguration() {
  Config ret = new Config();
  ret.setMaxTaskParallelism(1);
  ret.registerSerialization(TransactionAttempt.class);
  return ret;
}