Simplify Scala example

jukkakarvanen · Jan 31, 2018 · 2820d1a · 2820d1a
1 parent cd5639c
commit 2820d1a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/test/scala/io/confluent/examples/streams/StreamToTableJoinScalaIntegrationTest.scala b/src/test/scala/io/confluent/examples/streams/StreamToTableJoinScalaIntegrationTest.scala
@@ -162,7 +162,7 @@ class StreamToTableJoinScalaIntegrationTest extends AssertionsForJUnit {
     val clicksPerRegion: KTable[String, Long] = clicksByRegion
         // Compute the total per region by summing the individual click counts per region.
         .groupByKey(Serialized.`with`(stringSerde, longSerde))
-        .reduce((firstClicks: Long, secondClicks: Long) => firstClicks + secondClicks: Long)
+        .reduce(_ + _)
 
     // Write the (continuously updating) results to the output topic.
     clicksPerRegion.toStream().to(outputTopic, Produced.`with`(stringSerde, longSerde))