private Map<String, IRichBolt> _bolts = new HashMap<>();
private Map<String, IRichSpout> _spouts = new HashMap<>();

// 添加一个 Spout
public SpoutDeclarer setSpout(String id, IRichSpout spout, Number parallelism_hint) throws IllegalArgumentException {
	// spout 和 bolt 的 id 不能相同
	// 因为 spout 和 bolt 最终要使用 id 作为 key 放置到
	// 同一个 Map 中。
    validateUnusedId(id);
    initCommon(id, spout, parallelism_hint);
    _spouts.put(id, spout);
    return new SpoutGetter(id);
}

// 添加一个 Bolt
public BoltDeclarer setBolt(String id, IRichBolt bolt, Number parallelism_hint) throws IllegalArgumentException {
    validateUnusedId(id);
    initCommon(id, bolt, parallelism_hint);
    _bolts.put(id, bolt);
    return new BoltGetter(id);
}

// 初始化 ComponentCommon 对象
private void initCommon(String id, IComponent component, Number parallelism) throws IllegalArgumentException {
    ComponentCommon common = new ComponentCommon();
	// 1. 设置 inputs 字段
    common.set_inputs(new HashMap<GlobalStreamId, Grouping>());
    if(parallelism!=null) {
        int dop = parallelism.intValue();
        if(dop < 1) {
            throw new IllegalArgumentException("Parallelism must be positive.");
        }

		// 2. 设置 parallelism_hint 字段
        common.set_parallelism_hint(dop);
    }

	// 3. 设置 json_conf 字段
    Map conf = component.getComponentConfiguration();
    if(conf!=null) common.set_json_conf(JSONValue.toJSONString(conf));
    _commons.put(id, common);
}

// SpoutGetter 和 BoltGetter
// 用来设置有关 Spout 和 Bolt 的配置信息
// 所有的配置信息，最终都被添加到 ComponentCommon 的 json_conf 字段中，
// 所以在 SpoutDeclarer 和 BoltDeclarer 的所有配置，最终被设置到
String currConf = _commons.get(_id).get_json_conf();
_commons.get(_id).set_json_conf(mergeIntoJson(parseJson(currConf), conf));