From 610d0ce869f81391aa3032c66e49203fe8abb1a0 Mon Sep 17 00:00:00 2001
From: DomWos <blind.van@gmail.com>
Date: Sat, 18 Aug 2018 20:20:29 +0200
Subject: [PATCH] BAEL-1994: Moved the code to libraries module

---
 apache-flink/pom.xml                          | 37 -------------------
 libraries/pom.xml                             | 18 ++++++++-
 .../baeldung/flink}/FlinkDataPipeline.java    |  0
 .../baeldung/flink/connector}/Consumers.java  |  0
 .../baeldung/flink/connector}/Producers.java  |  0
 .../com/baeldung/flink}/model/Backup.java     |  0
 .../baeldung/flink}/model/InputMessage.java   |  0
 .../flink/operator}/BackupAggregator.java     |  0
 .../InputMessageTimestampAssigner.java        |  0
 .../flink/operator}/WordsCapitalizer.java     |  0
 .../schema/BackupSerializationSchema.java     |  0
 .../InputMessageDeserializationSchema.java    |  0
 12 files changed, 17 insertions(+), 38 deletions(-)
 delete mode 100644 apache-flink/pom.xml
 rename {apache-flink/src/main/java/com/baeldung => libraries/src/main/java/com/baeldung/flink}/FlinkDataPipeline.java (100%)
 rename {apache-flink/src/main/java/com/baeldung/flink => libraries/src/main/java/com/baeldung/flink/connector}/Consumers.java (100%)
 rename {apache-flink/src/main/java/com/baeldung/flink => libraries/src/main/java/com/baeldung/flink/connector}/Producers.java (100%)
 rename {apache-flink/src/main/java/com/baeldung => libraries/src/main/java/com/baeldung/flink}/model/Backup.java (100%)
 rename {apache-flink/src/main/java/com/baeldung => libraries/src/main/java/com/baeldung/flink}/model/InputMessage.java (100%)
 rename {apache-flink/src/main/java/com/baeldung/flink => libraries/src/main/java/com/baeldung/flink/operator}/BackupAggregator.java (100%)
 rename {apache-flink/src/main/java/com/baeldung/flink => libraries/src/main/java/com/baeldung/flink/operator}/InputMessageTimestampAssigner.java (100%)
 rename {apache-flink/src/main/java/com/baeldung/flink => libraries/src/main/java/com/baeldung/flink/operator}/WordsCapitalizer.java (100%)
 rename {apache-flink/src/main/java/com/baeldung => libraries/src/main/java/com/baeldung/flink}/schema/BackupSerializationSchema.java (100%)
 rename {apache-flink/src/main/java/com/baeldung => libraries/src/main/java/com/baeldung/flink}/schema/InputMessageDeserializationSchema.java (100%)

diff --git a/apache-flink/pom.xml b/apache-flink/pom.xml
deleted file mode 100644
index c93ea3ef77..0000000000
--- a/apache-flink/pom.xml
+++ /dev/null
@@ -1,37 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<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>
-
-    <groupId>groupId</groupId>
-    <artifactId>apache-flink</artifactId>
-    <version>1.0-SNAPSHOT</version>
-    <parent>
-        <groupId>com.baeldung</groupId>
-        <artifactId>parent-modules</artifactId>
-        <version>1.0.0-SNAPSHOT</version>
-    </parent>
-    <dependencies>
-        <dependency>
-            <groupId>org.apache.flink</groupId>
-            <artifactId>flink-core</artifactId>
-            <version>1.5.0</version>
-        </dependency>
-        <dependency>
-            <groupId>org.apache.flink</groupId>
-            <artifactId>flink-connector-kafka-0.11_2.11</artifactId>
-            <version>1.5.0</version>
-        </dependency>
-        <dependency>
-            <groupId>org.apache.flink</groupId>
-            <artifactId>flink-streaming-java_2.11</artifactId>
-            <version>1.5.0</version>
-        </dependency>
-        <dependency>
-            <groupId>com.fasterxml.jackson.datatype</groupId>
-            <artifactId>jackson-datatype-jsr310</artifactId>
-            <version>2.9.6</version>
-        </dependency>
-    </dependencies>
-</project>
\ No newline at end of file
diff --git a/libraries/pom.xml b/libraries/pom.xml
index b19a005d94..047b56dd01 100644
--- a/libraries/pom.xml
+++ b/libraries/pom.xml
@@ -169,6 +169,17 @@
             <artifactId>commons-dbutils</artifactId>
             <version>${commons.dbutils.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-connector-kafka-0.11_2.11</artifactId>
+            <version>${flink.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-streaming-java_2.11</artifactId>
+            <version>${flink.version}</version>
+        </dependency>
+
         <dependency>
             <groupId>org.apache.flink</groupId>
             <artifactId>flink-core</artifactId>
@@ -243,6 +254,11 @@
             <artifactId>jackson-databind</artifactId>
             <version>${jackson.version}</version>
         </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.datatype</groupId>
+            <artifactId>jackson-datatype-jsr310</artifactId>
+            <version>${jackson.version}</version>
+        </dependency>
         <!-- JDO -->
         <dependency>
             <groupId>org.datanucleus</groupId>
@@ -947,7 +963,7 @@
 
         <httpclient.version>4.5.3</httpclient.version>
         <commons.io.version>2.5</commons.io.version>
-        <flink.version>1.2.0</flink.version>
+        <flink.version>1.5.0</flink.version>
         <jackson.version>2.8.5</jackson.version>
         <neuroph.version>2.92</neuroph.version>
         <serenity.version>1.9.26</serenity.version>
diff --git a/apache-flink/src/main/java/com/baeldung/FlinkDataPipeline.java b/libraries/src/main/java/com/baeldung/flink/FlinkDataPipeline.java
similarity index 100%
rename from apache-flink/src/main/java/com/baeldung/FlinkDataPipeline.java
rename to libraries/src/main/java/com/baeldung/flink/FlinkDataPipeline.java
diff --git a/apache-flink/src/main/java/com/baeldung/flink/Consumers.java b/libraries/src/main/java/com/baeldung/flink/connector/Consumers.java
similarity index 100%
rename from apache-flink/src/main/java/com/baeldung/flink/Consumers.java
rename to libraries/src/main/java/com/baeldung/flink/connector/Consumers.java
diff --git a/apache-flink/src/main/java/com/baeldung/flink/Producers.java b/libraries/src/main/java/com/baeldung/flink/connector/Producers.java
similarity index 100%
rename from apache-flink/src/main/java/com/baeldung/flink/Producers.java
rename to libraries/src/main/java/com/baeldung/flink/connector/Producers.java
diff --git a/apache-flink/src/main/java/com/baeldung/model/Backup.java b/libraries/src/main/java/com/baeldung/flink/model/Backup.java
similarity index 100%
rename from apache-flink/src/main/java/com/baeldung/model/Backup.java
rename to libraries/src/main/java/com/baeldung/flink/model/Backup.java
diff --git a/apache-flink/src/main/java/com/baeldung/model/InputMessage.java b/libraries/src/main/java/com/baeldung/flink/model/InputMessage.java
similarity index 100%
rename from apache-flink/src/main/java/com/baeldung/model/InputMessage.java
rename to libraries/src/main/java/com/baeldung/flink/model/InputMessage.java
diff --git a/apache-flink/src/main/java/com/baeldung/flink/BackupAggregator.java b/libraries/src/main/java/com/baeldung/flink/operator/BackupAggregator.java
similarity index 100%
rename from apache-flink/src/main/java/com/baeldung/flink/BackupAggregator.java
rename to libraries/src/main/java/com/baeldung/flink/operator/BackupAggregator.java
diff --git a/apache-flink/src/main/java/com/baeldung/flink/InputMessageTimestampAssigner.java b/libraries/src/main/java/com/baeldung/flink/operator/InputMessageTimestampAssigner.java
similarity index 100%
rename from apache-flink/src/main/java/com/baeldung/flink/InputMessageTimestampAssigner.java
rename to libraries/src/main/java/com/baeldung/flink/operator/InputMessageTimestampAssigner.java
diff --git a/apache-flink/src/main/java/com/baeldung/flink/WordsCapitalizer.java b/libraries/src/main/java/com/baeldung/flink/operator/WordsCapitalizer.java
similarity index 100%
rename from apache-flink/src/main/java/com/baeldung/flink/WordsCapitalizer.java
rename to libraries/src/main/java/com/baeldung/flink/operator/WordsCapitalizer.java
diff --git a/apache-flink/src/main/java/com/baeldung/schema/BackupSerializationSchema.java b/libraries/src/main/java/com/baeldung/flink/schema/BackupSerializationSchema.java
similarity index 100%
rename from apache-flink/src/main/java/com/baeldung/schema/BackupSerializationSchema.java
rename to libraries/src/main/java/com/baeldung/flink/schema/BackupSerializationSchema.java
diff --git a/apache-flink/src/main/java/com/baeldung/schema/InputMessageDeserializationSchema.java b/libraries/src/main/java/com/baeldung/flink/schema/InputMessageDeserializationSchema.java
similarity index 100%
rename from apache-flink/src/main/java/com/baeldung/schema/InputMessageDeserializationSchema.java
rename to libraries/src/main/java/com/baeldung/flink/schema/InputMessageDeserializationSchema.java