iSharkFly-Docs
/
java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Assertj refactor (#1635)

This commit is contained in:
Grzegorz Piwowarek 2017-04-13 02:11:05 +02:00 committed by KevinGilmore
parent 910826733c
commit 891f0ba981
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
libraries/src/test/java/com/baeldung/flink/WordCountIntegrationTest.java
View File

@ -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<Integer> 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));
}