public void flatMap()

in CustomMetrics/WordCount/src/main/java/com/amazonaws/services/kinesisanalytics/WordCountApplication.java [83:94]

• 9 lines of code
• 3 McCabe index (conditional complexity)

            public void flatMap(String value, Collector<Tuple2<String, Integer>> out) {
                // normalize and split the line
                String[] tokens = value.toLowerCase().split("\\W+");
     
                // emit the pairs
                for (String token : tokens) {
                    if (token.length() > 0) {
                        counter.inc();
                        out.collect(new Tuple2<>(token, 1));
                    }
                }
            }