Skip to content

Commit 2820d1a

Browse files
author
Michael G. Noll
committed
Simplify Scala example
1 parent cd5639c commit 2820d1a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/test/scala/io/confluent/examples/streams/StreamToTableJoinScalaIntegrationTest.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -162,7 +162,7 @@ class StreamToTableJoinScalaIntegrationTest extends AssertionsForJUnit {
162162
val clicksPerRegion: KTable[String, Long] = clicksByRegion
163163
// Compute the total per region by summing the individual click counts per region.
164164
.groupByKey(Serialized.`with`(stringSerde, longSerde))
165-
.reduce((firstClicks: Long, secondClicks: Long) => firstClicks + secondClicks: Long)
165+
.reduce(_ + _)
166166

167167
// Write the (continuously updating) results to the output topic.
168168
clicksPerRegion.toStream().to(outputTopic, Produced.`with`(stringSerde, longSerde))

0 commit comments

Comments
 (0)