From 891f0ba9814b6ca1d55f6af322abc5a4643ca70c Mon Sep 17 00:00:00 2001 From: Grzegorz Piwowarek Date: Thu, 13 Apr 2017 02:11:05 +0200 Subject: [PATCH] Assertj refactor (#1635) --- .../com/baeldung/flink/WordCountIntegrationTest.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/libraries/src/test/java/com/baeldung/flink/WordCountIntegrationTest.java b/libraries/src/test/java/com/baeldung/flink/WordCountIntegrationTest.java index 3190debef8..a5613e2406 100644 --- a/libraries/src/test/java/com/baeldung/flink/WordCountIntegrationTest.java +++ b/libraries/src/test/java/com/baeldung/flink/WordCountIntegrationTest.java @@ -22,7 +22,7 @@ import static org.assertj.core.api.Assertions.assertThat; public class WordCountIntegrationTest { - final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment(); + private final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment(); @Test public void givenDataSet_whenExecuteWordCount_thenReturnWordCount() throws Exception { @@ -65,8 +65,8 @@ public class WordCountIntegrationTest { List ages = personDataSource.map(p -> p.age).collect(); //then - assertThat(ages.size()).isEqualTo(2); - assertThat(ages.containsAll(Arrays.asList(23, 75))).isTrue(); + assertThat(ages).hasSize(2); + assertThat(ages).contains(23, 75); } @@ -110,8 +110,8 @@ public class WordCountIntegrationTest { .collect(); //then - assertThat(joined.size()).isEqualTo(1); - assertThat(joined.contains(new Tuple2<>(firstTransaction, address))); + assertThat(joined).hasSize(1); + assertThat(joined).contains(new Tuple2<>(firstTransaction, address)); }