new package name
This commit is contained in:
parent
46765cf410
commit
43f74f9c47
|
@ -1,44 +1,44 @@
|
||||||
<project xmlns="http://maven.apache.org/POM/4.0.0"
|
<project xmlns="http://maven.apache.org/POM/4.0.0"
|
||||||
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
||||||
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||||
<modelVersion>4.0.0</modelVersion>
|
<modelVersion>4.0.0</modelVersion>
|
||||||
|
|
||||||
<parent>
|
<parent>
|
||||||
<groupId>com.baeldung</groupId>
|
<groupId>com.baeldung</groupId>
|
||||||
<artifactId>parent-modules</artifactId>
|
<artifactId>parent-modules</artifactId>
|
||||||
<version>1.0.0-SNAPSHOT</version>
|
<version>1.0.0-SNAPSHOT</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<groupId>com.baeldung.apache</groupId>
|
<groupId>com.baeldung.apache</groupId>
|
||||||
<artifactId>apache-beam</artifactId>
|
<artifactId>apache-beam</artifactId>
|
||||||
<version>0.0.1-SNAPSHOT</version>
|
<version>0.0.1-SNAPSHOT</version>
|
||||||
<name>apache-beam</name>
|
<name>apache-beam</name>
|
||||||
|
|
||||||
<dependencies>
|
<dependencies>
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.apache.beam</groupId>
|
<groupId>org.apache.beam</groupId>
|
||||||
<artifactId>beam-sdks-java-core</artifactId>
|
<artifactId>beam-sdks-java-core</artifactId>
|
||||||
<version>${beam.version}</version>
|
<version>${beam.version}</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
<!-- runtime scoped -->
|
<!-- runtime scoped -->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.apache.beam</groupId>
|
<groupId>org.apache.beam</groupId>
|
||||||
<artifactId>beam-runners-direct-java</artifactId>
|
<artifactId>beam-runners-direct-java</artifactId>
|
||||||
<version>${beam.version}</version>
|
<version>${beam.version}</version>
|
||||||
<scope>runtime</scope>
|
<scope>runtime</scope>
|
||||||
</dependency>
|
</dependency>
|
||||||
<!-- test scoped -->
|
<!-- test scoped -->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.assertj</groupId>
|
<groupId>org.assertj</groupId>
|
||||||
<artifactId>assertj-core</artifactId>
|
<artifactId>assertj-core</artifactId>
|
||||||
<version>${assertj.version}</version>
|
<version>${assertj.version}</version>
|
||||||
<scope>test</scope>
|
<scope>test</scope>
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
<properties>
|
<properties>
|
||||||
<beam.version>2.19.0</beam.version>
|
<beam.version>2.19.0</beam.version>
|
||||||
<assertj.version>3.6.1</assertj.version>
|
<assertj.version>3.6.1</assertj.version>
|
||||||
</properties>
|
</properties>
|
||||||
|
|
||||||
</project>
|
</project>
|
|
@ -1,4 +1,4 @@
|
||||||
package com.baeldung.apache.beam;
|
package com.baeldung.apache.beam.intro;
|
||||||
|
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
||||||
|
|
|
@ -1,14 +1,16 @@
|
||||||
package com.baeldung.apache.beam;
|
package com.baeldung.apache.beam.intro;
|
||||||
|
|
||||||
import static org.junit.Assert.assertTrue;
|
import static org.junit.Assert.assertTrue;
|
||||||
|
|
||||||
import org.junit.Ignore;
|
import org.junit.Ignore;
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
|
|
||||||
|
import com.baeldung.apache.beam.intro.WordCount;
|
||||||
|
|
||||||
public class WordCountUnitTest {
|
public class WordCountUnitTest {
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
@Ignore
|
// @Ignore
|
||||||
public void givenInputFile_whenWordCountRuns_thenJobFinishWithoutError() {
|
public void givenInputFile_whenWordCountRuns_thenJobFinishWithoutError() {
|
||||||
boolean jobDone = WordCount.wordCount("src/test/resources/wordcount.txt", "target/output");
|
boolean jobDone = WordCount.wordCount("src/test/resources/wordcount.txt", "target/output");
|
||||||
assertTrue(jobDone);
|
assertTrue(jobDone);
|
Loading…
Reference in New Issue