src/main/java/com/aliyun/emr/example/storm/benchmark/WindowedWordCount.java [62:81]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                        Integer number = counter.get(word);
                        if (number == null) {
                            number = 0;
                        }
                        number++;
                        counter.put(word, number);
                    }
                    collector.emit(new Values(eventTime, System.currentTimeMillis()));
                }
            }

        }

        @Override
        public void declareOutputFields(OutputFieldsDeclarer declarer) {
            declarer.declare(new Fields("eventTime", "finishTime"));
        }
    }

    public static void main(String[] args) throws Exception {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/aliyun/emr/example/storm/benchmark/WordCount.java [51:69]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                    Integer number = counter.get(word);
                    if (number == null) {
                        number = 0;
                    }
                    number++;
                    counter.put(word, number);
                }
                collector.emit(new Values(eventTime, System.currentTimeMillis()));
            }

        }

        @Override
        public void declareOutputFields(OutputFieldsDeclarer declarer) {
            declarer.declare(new Fields("eventTime", "finishTime"));
        }
    }

    public static void main(String[] args) throws Exception {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -