MINOR: Fix formatting in RelationalSmokeTest
Fixes formatting in RelationalSmokeTest.
Reviewers: Leah Thomas
@@ -278,7 +278,6 @@ public class RelationalSmokeTest extends SmokeTestUtil {
private final Comment[] comments;
private DataSet(final Article[] articles, final Comment[] comments) {
-
this.articles = articles;
this.comments = comments;
}
@@ -606,14 +605,18 @@ public class RelationalSmokeTest extends SmokeTestUtil {
final KTable<Integer, Long> commentCounts =
- comments.groupBy((key, value) -> new KeyValue<>(value.getArticleId(), (short) 1),
- Grouped.with(Serdes.Integer(), Serdes.Short()))
+ comments.groupBy(
+ (key, value) -> new KeyValue<>(value.getArticleId(), (short) 1),
+ Grouped.with(Serdes.Integer(), Serdes.Short())
+ )
.count();
articles
- .leftJoin(commentCounts,
+ .leftJoin(
+ commentCounts,
AugmentedArticle.joiner(),
- Materialized.with(null, new AugmentedArticle.AugmentedArticleSerde()))
+ Materialized.with(null, new AugmentedArticle.AugmentedArticleSerde())
+ )
.toStream()
.to(ARTICLE_RESULT_SINK);
@@ -698,7 +701,8 @@ public class RelationalSmokeTest extends SmokeTestUtil {
Stream.concat(
articlePartitions.stream().map(p -> new TopicPartition(p.topic(), p.partition())),
augmentedArticlePartitions.stream().map(p -> new TopicPartition(p.topic(), p.partition()))
- ), Stream.concat(
+ ),
+ Stream.concat(
commentPartitions.stream().map(p -> new TopicPartition(p.topic(), p.partition())),
augmentedCommentPartitions.stream().map(p -> new TopicPartition(p.topic(), p.partition()))
)
@@ -855,7 +859,8 @@ public class RelationalSmokeTest extends SmokeTestUtil {
for (final RelationalSmokeTest.AugmentedComment augmentedComment : consumedAugmentedComments.values()) {
final int key = augmentedComment.getKey();
- assertThat(pass,
+ assertThat(
+ pass,
report,
"comment missing, but found in augmentedComment: " + key,
consumedComments.containsKey(key)
