public void process()

in docker/ops-playground-image/java/flink-playground-clickcountjob/src/main/java/org/apache/flink/playgrounds/ops/clickcount/functions/ClickEventStatisticsCollector.java [37:46]

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

	public void process(
			final String page,
			final Context context,
			final Iterable<Long> elements,
			final Collector<ClickEventStatistics> out) throws Exception {

		Long count = elements.iterator().next();

		out.collect(new ClickEventStatistics(new Date(context.window().getStart()), new Date(context.window().getEnd()), page, count));
	}