public void apply()

in demo-apps/demo-kda-app/src/main/java/com/amazonaws/services/kinesisanalytics/operators/CountWindowFn.java [18:27]

• 8 lines of code
• 1 McCabe index (conditional complexity)

    public void apply(Tuple tuple,
                      TimeWindow timeWindow,
                      Iterable<EmployeeInfo> iterable,
                      Collector<Tuple2<Long, Long>> collector) throws Exception {

        long count = Iterables.size(iterable);
        EmployeeInfo employeeInfo = Iterables.get(iterable, 0);

        collector.collect(new Tuple2<>(employeeInfo.getCompanyid(), count));
    }