diff --git a/apache-beam/pom.xml b/apache-beam/pom.xml
index 1076d06e2a..355e5b32e6 100644
--- a/apache-beam/pom.xml
+++ b/apache-beam/pom.xml
@@ -1,44 +1,44 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0"
-	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">
-	<modelVersion>4.0.0</modelVersion>
+    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">
+    <modelVersion>4.0.0</modelVersion>
 
-	<parent>
-		<groupId>com.baeldung</groupId>
-		<artifactId>parent-modules</artifactId>
-		<version>1.0.0-SNAPSHOT</version>
-	</parent>
+    <parent>
+        <groupId>com.baeldung</groupId>
+        <artifactId>parent-modules</artifactId>
+        <version>1.0.0-SNAPSHOT</version>
+    </parent>
 
-	<groupId>com.baeldung.apache</groupId>
-	<artifactId>apache-beam</artifactId>
-	<version>0.0.1-SNAPSHOT</version>
-	<name>apache-beam</name>
+    <groupId>com.baeldung.apache</groupId>
+    <artifactId>apache-beam</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <name>apache-beam</name>
 
-	<dependencies>
-		<dependency>
-			<groupId>org.apache.beam</groupId>
-			<artifactId>beam-sdks-java-core</artifactId>
-			<version>${beam.version}</version>
-		</dependency>
-		<!-- runtime scoped -->
-		<dependency>
-			<groupId>org.apache.beam</groupId>
-			<artifactId>beam-runners-direct-java</artifactId>
-			<version>${beam.version}</version>
-			<scope>runtime</scope>
-		</dependency>
-		<!-- test scoped -->
-		<dependency>
-			<groupId>org.assertj</groupId>
-			<artifactId>assertj-core</artifactId>
-			<version>${assertj.version}</version>
-			<scope>test</scope>
-		</dependency>
-	</dependencies>
+    <dependencies>
+        <dependency>
+            <groupId>org.apache.beam</groupId>
+            <artifactId>beam-sdks-java-core</artifactId>
+            <version>${beam.version}</version>
+        </dependency>
+        <!-- runtime scoped -->
+        <dependency>
+            <groupId>org.apache.beam</groupId>
+            <artifactId>beam-runners-direct-java</artifactId>
+            <version>${beam.version}</version>
+            <scope>runtime</scope>
+        </dependency>
+        <!-- test scoped -->
+        <dependency>
+            <groupId>org.assertj</groupId>
+            <artifactId>assertj-core</artifactId>
+            <version>${assertj.version}</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
 
-	<properties>
-		<beam.version>2.19.0</beam.version>
-		<assertj.version>3.6.1</assertj.version>
-	</properties>
+    <properties>
+        <beam.version>2.19.0</beam.version>
+        <assertj.version>3.6.1</assertj.version>
+    </properties>
 
 </project>
\ No newline at end of file
diff --git a/apache-beam/src/main/java/com/baeldung/apache/beam/WordCount.java b/apache-beam/src/main/java/com/baeldung/apache/beam/intro/WordCount.java
similarity index 98%
rename from apache-beam/src/main/java/com/baeldung/apache/beam/WordCount.java
rename to apache-beam/src/main/java/com/baeldung/apache/beam/intro/WordCount.java
index 632cc97e6c..f2dfb47810 100644
--- a/apache-beam/src/main/java/com/baeldung/apache/beam/WordCount.java
+++ b/apache-beam/src/main/java/com/baeldung/apache/beam/intro/WordCount.java
@@ -1,4 +1,4 @@
-package com.baeldung.apache.beam;
+package com.baeldung.apache.beam.intro;
 
 import java.util.Arrays;
 
diff --git a/apache-beam/src/test/java/com/baeldung/apache/beam/WordCountUnitTest.java b/apache-beam/src/test/java/com/baeldung/apache/beam/intro/WordCountUnitTest.java
similarity index 77%
rename from apache-beam/src/test/java/com/baeldung/apache/beam/WordCountUnitTest.java
rename to apache-beam/src/test/java/com/baeldung/apache/beam/intro/WordCountUnitTest.java
index ff338a292c..f2558635dc 100644
--- a/apache-beam/src/test/java/com/baeldung/apache/beam/WordCountUnitTest.java
+++ b/apache-beam/src/test/java/com/baeldung/apache/beam/intro/WordCountUnitTest.java
@@ -1,14 +1,16 @@
-package com.baeldung.apache.beam;
+package com.baeldung.apache.beam.intro;
 
 import static org.junit.Assert.assertTrue;
 
 import org.junit.Ignore;
 import org.junit.Test;
 
+import com.baeldung.apache.beam.intro.WordCount;
+
 public class WordCountUnitTest {
     
     @Test
-    @Ignore
+    // @Ignore
     public void givenInputFile_whenWordCountRuns_thenJobFinishWithoutError() {
         boolean jobDone = WordCount.wordCount("src/test/resources/wordcount.txt", "target/output");
         assertTrue(jobDone);