Method run

example/E04-MapReduce.cpp:65–79

class ReduceGNode : public GNode {
public:
    CStatus run() override {
        int total = 0;
        auto param = CGRAPH_GET_GPARAM_WITH_NO_EMPTY(NumsGParam, PARAM_KEY);
        for (int j = 0; j < MAX_NUM; j++) {
            int num = 0;
            for (int i = 0; i < MAP_SIZE; i++) {
                num += param->map_results_[i][j];
            }
            total += num;
            printf("  num [%d] appear [%d] times\n", j, num);
        }

        printf("total num is [%d]. \n", total);
        return CStatus();
    }
};