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

Config.setMaxTaskParallelism介绍

暂无

代码示例

代码示例来源：origin: apache/storm

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

代码示例来源：origin: apache/storm

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

代码示例来源：origin: apache/storm

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

代码示例来源：origin: apache/storm

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

代码示例来源：origin: apache/storm

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

代码示例来源：origin: apache/storm

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

代码示例来源：origin: apache/storm

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

代码示例来源：origin: apache/storm

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

代码示例来源：origin: apache/storm

/**
   * Get the component configuration.
   * @return the component configuration
   */
  @Override
  public Map<String, Object> getComponentConfiguration() {
    Config conf = new Config();
    conf.setMaxTaskParallelism(1);
    return conf;
  }
}

代码示例来源：origin: apache/storm

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

代码示例来源：origin: apache/storm

conf.setNumWorkers(1);
conf.setNumAckers(1);
conf.setMaxTaskParallelism(1);
conf.setDebug(true);
conf.registerMetricsConsumer(LoggingMetricsConsumer.class);

代码示例来源：origin: apache/storm

protected int run(String[] args) throws Exception {
  TopologyBuilder builder = new TopologyBuilder();
  builder.setSpout("spout", new RandomSentenceSpout(), 4);
  builder.setBolt("split", new SplitSentence(), 4).shuffleGrouping("spout");
  builder.setBolt("count", new WordCount(), 4).fieldsGrouping("split", new Fields("word"));
  Config conf = new Config();
  conf.setMaxTaskParallelism(3);
  String topologyName = "word-count";
  conf.setNumWorkers(3);
  if (args != null && args.length > 0) {
    topologyName = args[0];
  }
  return submit(topologyName, conf, builder);
}

代码示例来源：origin: apache/metron

@Override
 public Config apply(Arg arg) {
  if(arg.getArg() != null) {
   arg.getConfig().setMaxTaskParallelism(Integer.parseInt(arg.getArg()));
  }
  return arg.getConfig();
 }
}

代码示例来源：origin: org.apache.storm/storm-core

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

代码示例来源：origin: com.twitter.heron/heron-storm

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

代码示例来源：origin: org.apache.storm/storm-core

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

代码示例来源：origin: org.apache.storm/storm-core

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

代码示例来源：origin: org.apache.storm/storm-sql-runtime

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

代码示例来源：origin: org.apache.storm/storm-core

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

代码示例来源：origin: org.apache.storm/storm-core

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