Skip to content

Commit

Permalink
Type inference in scala examples (confluentinc#118)
Browse files Browse the repository at this point in the history
  • Loading branch information
guozhangwang authored May 22, 2018
1 parent bfd57a4 commit 210cdec
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -141,7 +141,7 @@ class StreamToTableJoinScalaIntegrationTest extends AssertionsForJUnit {
// fallback region "UNKNOWN"). In this specific example this is not really needed because
// we know, based on the test setup, that all users have appropriate region entries at the
// time we perform the join.
.leftJoin(userRegionsTable, (clicks: Long, region: String) => (if (region == null) "UNKNOWN" else region, clicks))
.leftJoin(userRegionsTable)((clicks, region) => (if (region == null) "UNKNOWN" else region, clicks))

val clicksByRegion: KStream[String, Long] = userClicksJoinRegion
.map { case (_, (region, clicks)) => (region, clicks) }
Expand Down

0 comments on commit 210cdec

Please sign in to comment.