override def process()

in hourly-tips/src/solution/scala/org/apache/flink/training/solutions/hourlytips/scala/HourlyTipsSolution.scala [87:96]

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

    override def process(
        key: Long,
        context: Context,
        elements: Iterable[(Long, Float)],
        out: Collector[(Long, Long, Float)]
    ): Unit = {

      val sumOfTips = elements.iterator.next()._2
      out.collect((context.window.getEnd, key, sumOfTips))
    }