Skip to content

Commit 05e1700

Browse files
Wosinpivovarit
Wosin
authored and
pivovarit
committed
Moved Flink related code from libraries to libraries-data module. (eugenp#5253)
1 parent 33aa52a commit 05e1700

17 files changed

Lines changed: 71 additions & 49 deletions

‎libraries-data/pom.xml‎

Lines changed: 70 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -147,7 +147,6 @@
147147
<artifactId>jmapper-core</artifactId>
148148
<version>${jmapper.version}</version>
149149
</dependency>
150-
151150
<!-- crunch project -->
152151
<dependency>
153152
<groupId>org.apache.crunch</groupId>
@@ -185,7 +184,72 @@
185184
</exclusion>
186185
</exclusions>
187186
</dependency>
188-
187+
<dependency>
188+
<groupId>org.apache.flink</groupId>
189+
<artifactId>flink-connector-kafka-0.11_2.11</artifactId>
190+
<version>${flink.version}</version>
191+
</dependency>
192+
<dependency>
193+
<groupId>org.apache.flink</groupId>
194+
<artifactId>flink-streaming-java_2.11</artifactId>
195+
<version>${flink.version}</version>
196+
</dependency>
197+
<dependency>
198+
<groupId>com.fasterxml.jackson.datatype</groupId>
199+
<artifactId>jackson-datatype-jsr310</artifactId>
200+
<version>${jackson.version}</version>
201+
</dependency>
202+
<dependency>
203+
<groupId>com.fasterxml.jackson.core</groupId>
204+
<artifactId>jackson-databind</artifactId>
205+
<version>${jackson.version}</version>
206+
</dependency>
207+
<dependency>
208+
<groupId>org.apache.flink</groupId>
209+
<artifactId>flink-core</artifactId>
210+
<version>${flink.version}</version>
211+
<exclusions>
212+
<exclusion>
213+
<artifactId>commons-logging</artifactId>
214+
<groupId>commons-logging</groupId>
215+
</exclusion>
216+
</exclusions>
217+
</dependency>
218+
<dependency>
219+
<groupId>org.apache.flink</groupId>
220+
<artifactId>flink-java</artifactId>
221+
<version>${flink.version}</version>
222+
<exclusions>
223+
<exclusion>
224+
<artifactId>commons-logging</artifactId>
225+
<groupId>commons-logging</groupId>
226+
</exclusion>
227+
</exclusions>
228+
</dependency>
229+
<dependency>
230+
<groupId>org.apache.flink</groupId>
231+
<artifactId>flink-test-utils_2.11</artifactId>
232+
<version>${flink.version}</version>
233+
<scope>test</scope>
234+
</dependency>
235+
<dependency>
236+
<groupId>org.assertj</groupId>
237+
<artifactId>assertj-core</artifactId>
238+
<version>${assertj.version}</version>
239+
</dependency>
240+
<dependency>
241+
<groupId>org.awaitility</groupId>
242+
<artifactId>awaitility</artifactId>
243+
<version>${awaitility.version}</version>
244+
<scope>test</scope>
245+
</dependency>
246+
<dependency>
247+
<groupId>org.awaitility</groupId>
248+
<artifactId>awaitility-proxy</artifactId>
249+
<version>${awaitility.version}</version>
250+
<scope>test</scope>
251+
</dependency>
252+
189253
</dependencies>
190254

191255
<build>
@@ -336,6 +400,10 @@
336400
<ignite.version>2.4.0</ignite.version>
337401
<gson.version>2.8.2</gson.version>
338402
<cache.version>1.1.0</cache.version>
403+
<flink.version>1.5.0</flink.version>
404+
<jackson.version>2.8.5</jackson.version>
405+
<awaitility.version>3.0.0</awaitility.version>
406+
<assertj.version>3.6.2</assertj.version>
339407
<hazelcast.version>3.8.4</hazelcast.version>
340408
<maven-antrun-plugin.version>1.8</maven-antrun-plugin.version>
341409
<build-helper-maven-plugin.version>3.0.0</build-helper-maven-plugin.version>

libraries/src/main/java/com/baeldung/flink/FlinkDataPipeline.java renamed to libraries-data/src/main/java/com/baeldung/flink/FlinkDataPipeline.java

File renamed without changes.

libraries/src/main/java/com/baeldung/flink/LineSplitter.java renamed to libraries-data/src/main/java/com/baeldung/flink/LineSplitter.java

File renamed without changes.

libraries/src/main/java/com/baeldung/flink/WordCount.java renamed to libraries-data/src/main/java/com/baeldung/flink/WordCount.java

File renamed without changes.

libraries/src/main/java/com/baeldung/flink/connector/Consumers.java renamed to libraries-data/src/main/java/com/baeldung/flink/connector/Consumers.java

File renamed without changes.

libraries/src/main/java/com/baeldung/flink/connector/Producers.java renamed to libraries-data/src/main/java/com/baeldung/flink/connector/Producers.java

File renamed without changes.

libraries/src/main/java/com/baeldung/flink/model/Backup.java renamed to libraries-data/src/main/java/com/baeldung/flink/model/Backup.java

File renamed without changes.

libraries/src/main/java/com/baeldung/flink/model/InputMessage.java renamed to libraries-data/src/main/java/com/baeldung/flink/model/InputMessage.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@ public InputMessage() {
1818
public String getSender() {
1919
return sender;
2020
}
21-
2221
public void setSender(String sender) {
2322
this.sender = sender;
2423
}

libraries/src/main/java/com/baeldung/flink/operator/BackupAggregator.java renamed to libraries-data/src/main/java/com/baeldung/flink/operator/BackupAggregator.java

File renamed without changes.

libraries/src/main/java/com/baeldung/flink/operator/InputMessageTimestampAssigner.java renamed to libraries-data/src/main/java/com/baeldung/flink/operator/InputMessageTimestampAssigner.java

File renamed without changes.

0 commit comments

Comments
 (0)