From 2d1aca64e14fc2b762c0cbdd41cd4cc4551e2a33 Mon Sep 17 00:00:00 2001 From: Krzysiek Date: Tue, 21 Jan 2020 20:41:44 +0100 Subject: [PATCH 01/13] BAEL-3694: Refactor Mockito unit tests --- .../MockitoVoidMethodsUnitTest.java | 39 ++++++++++--------- 1 file changed, 21 insertions(+), 18 deletions(-) diff --git a/testing-modules/mockito/src/test/java/com/baeldung/mockito/voidmethods/MockitoVoidMethodsUnitTest.java b/testing-modules/mockito/src/test/java/com/baeldung/mockito/voidmethods/MockitoVoidMethodsUnitTest.java index dd41d98b57..9dd98f184b 100644 --- a/testing-modules/mockito/src/test/java/com/baeldung/mockito/voidmethods/MockitoVoidMethodsUnitTest.java +++ b/testing-modules/mockito/src/test/java/com/baeldung/mockito/voidmethods/MockitoVoidMethodsUnitTest.java @@ -16,48 +16,51 @@ public class MockitoVoidMethodsUnitTest { @Test public void whenAddCalledVerified() { - MyList mockVoid = mock(MyList.class); - mockVoid.add(0, ""); - verify(mockVoid, times(1)).add(0, ""); + MyList myList = mock(MyList.class); + myList.add(0, ""); + + verify(myList, times(1)).add(0, ""); } @Test(expected = Exception.class) public void givenNull_addThrows() { - MyList mockVoid = mock(MyList.class); - doThrow().when(mockVoid).add(isA(Integer.class), isNull()); - mockVoid.add(0, null); + MyList myList = mock(MyList.class); + doThrow().when(myList).add(isA(Integer.class), isNull()); + + myList.add(0, null); } @Test public void whenAddCalledValueCaptured() { - MyList mockVoid = mock(MyList.class); + MyList myList = mock(MyList.class); ArgumentCaptor valueCapture = ArgumentCaptor.forClass(String.class); - doNothing().when(mockVoid).add(any(Integer.class), valueCapture.capture()); - mockVoid.add(0, "captured"); + doNothing().when(myList).add(any(Integer.class), valueCapture.capture()); + myList.add(0, "captured"); + assertEquals("captured", valueCapture.getValue()); } @Test public void whenAddCalledAnswered() { - MyList mockVoid = mock(MyList.class); - doAnswer((Answer) invocation -> { + MyList myList = mock(MyList.class); + doAnswer(invocation -> { Object arg0 = invocation.getArgument(0); Object arg1 = invocation.getArgument(1); //do something with the arguments here assertEquals(3, arg0); assertEquals("answer me", arg1); - return null; - }).when(mockVoid).add(any(Integer.class), any(String.class)); - mockVoid.add(3, "answer me"); + }).when(myList).add(any(Integer.class), any(String.class)); + myList.add(3, "answer me"); } @Test public void whenAddCalledRealMethodCalled() { - MyList mockVoid = mock(MyList.class); - doCallRealMethod().when(mockVoid).add(any(Integer.class), any(String.class)); - mockVoid.add(1, "real"); - verify(mockVoid, times(1)).add(1, "real"); + MyList myList = mock(MyList.class); + doCallRealMethod().when(myList).add(any(Integer.class), any(String.class)); + myList.add(1, "real"); + + verify(myList, times(1)).add(1, "real"); } } From 46765cf410196a629a54ee83befc741525b6cfdc Mon Sep 17 00:00:00 2001 From: pazis Date: Wed, 19 Feb 2020 21:28:48 +0000 Subject: [PATCH 02/13] init --- apache-beam/.gitignore | 1 + apache-beam/pom.xml | 44 ++++++++++++ .../com/baeldung/apache/beam/WordCount.java | 71 +++++++++++++++++++ .../apache/beam/WordCountUnitTest.java | 17 +++++ apache-beam/src/test/resources/wordcount.txt | 16 +++++ 5 files changed, 149 insertions(+) create mode 100644 apache-beam/.gitignore create mode 100644 apache-beam/pom.xml create mode 100644 apache-beam/src/main/java/com/baeldung/apache/beam/WordCount.java create mode 100644 apache-beam/src/test/java/com/baeldung/apache/beam/WordCountUnitTest.java create mode 100644 apache-beam/src/test/resources/wordcount.txt diff --git a/apache-beam/.gitignore b/apache-beam/.gitignore new file mode 100644 index 0000000000..84c048a73c --- /dev/null +++ b/apache-beam/.gitignore @@ -0,0 +1 @@ +/build/ diff --git a/apache-beam/pom.xml b/apache-beam/pom.xml new file mode 100644 index 0000000000..1076d06e2a --- /dev/null +++ b/apache-beam/pom.xml @@ -0,0 +1,44 @@ + + 4.0.0 + + + com.baeldung + parent-modules + 1.0.0-SNAPSHOT + + + com.baeldung.apache + apache-beam + 0.0.1-SNAPSHOT + apache-beam + + + + org.apache.beam + beam-sdks-java-core + ${beam.version} + + + + org.apache.beam + beam-runners-direct-java + ${beam.version} + runtime + + + + org.assertj + assertj-core + ${assertj.version} + test + + + + + 2.19.0 + 3.6.1 + + + \ 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/WordCount.java new file mode 100644 index 0000000000..632cc97e6c --- /dev/null +++ b/apache-beam/src/main/java/com/baeldung/apache/beam/WordCount.java @@ -0,0 +1,71 @@ +package com.baeldung.apache.beam; + +import java.util.Arrays; + +import org.apache.beam.sdk.Pipeline; +import org.apache.beam.sdk.io.TextIO; +import org.apache.beam.sdk.options.PipelineOptions; +import org.apache.beam.sdk.options.PipelineOptionsFactory; +import org.apache.beam.sdk.transforms.Count; +import org.apache.beam.sdk.transforms.Filter; +import org.apache.beam.sdk.transforms.FlatMapElements; +import org.apache.beam.sdk.transforms.MapElements; +import org.apache.beam.sdk.values.KV; +import org.apache.beam.sdk.values.PCollection; +import org.apache.beam.sdk.values.TypeDescriptors; + +public class WordCount { + + public static boolean wordCount(String inputFilePath, String outputFilePath) { + // We use default options + PipelineOptions options = PipelineOptionsFactory.create(); + // to create the pipeline + Pipeline p = Pipeline.create(options); + // Here is our workflow graph + PCollection> wordCount = p + .apply("(1) Read all lines", TextIO.read().from(inputFilePath)) + .apply("(2) Flatmap to a list of words", FlatMapElements.into(TypeDescriptors.strings()) + .via(line -> Arrays.asList(line.split("\\s")))) + .apply("(3) Lowercase all", MapElements.into(TypeDescriptors.strings()) + .via(word -> word.toLowerCase())) + .apply("(4) Trim punctuations", MapElements.into(TypeDescriptors.strings()) + .via(word -> trim(word))) + .apply("(5) Filter stopwords", Filter.by(word -> !isStopWord(word))) + .apply("(6) Count words", Count.perElement()); + // We convert the PCollection to String so that we can write it to file + wordCount.apply(MapElements.into(TypeDescriptors.strings()) + .via(count -> count.getKey() + " --> " + count.getValue())) + .apply(TextIO.write().to(outputFilePath)); + // Finally we must run the pipeline, otherwise it's only a definition + p.run().waitUntilFinish(); + return true; + } + + public static boolean isStopWord(String word) { + String[] stopwords = {"am", "are", "is", "i", "you", "me", + "he", "she", "they", "them", "was", + "were", "from", "in", "of", "to", "be", + "him", "her", "us", "and", "or"}; + for (String stopword : stopwords) { + if (stopword.compareTo(word) == 0) { + return true; + } + } + return false; + } + + public static String trim(String word) { + return word.replace("(","") + .replace(")", "") + .replace(",", "") + .replace(".", "") + .replace("\"", "") + .replace("'", "") + .replace(":", "") + .replace(";", "") + .replace("-", "") + .replace("?", "") + .replace("!", ""); + } + +} diff --git a/apache-beam/src/test/java/com/baeldung/apache/beam/WordCountUnitTest.java b/apache-beam/src/test/java/com/baeldung/apache/beam/WordCountUnitTest.java new file mode 100644 index 0000000000..ff338a292c --- /dev/null +++ b/apache-beam/src/test/java/com/baeldung/apache/beam/WordCountUnitTest.java @@ -0,0 +1,17 @@ +package com.baeldung.apache.beam; + +import static org.junit.Assert.assertTrue; + +import org.junit.Ignore; +import org.junit.Test; + +public class WordCountUnitTest { + + @Test + @Ignore + public void givenInputFile_whenWordCountRuns_thenJobFinishWithoutError() { + boolean jobDone = WordCount.wordCount("src/test/resources/wordcount.txt", "target/output"); + assertTrue(jobDone); + } + +} diff --git a/apache-beam/src/test/resources/wordcount.txt b/apache-beam/src/test/resources/wordcount.txt new file mode 100644 index 0000000000..542385379b --- /dev/null +++ b/apache-beam/src/test/resources/wordcount.txt @@ -0,0 +1,16 @@ +We've all heard the scare stories about North Korea: the homemade nuclear arsenal built while their people starve and then aimed imprecisely at the rest of the world, a +leader so deluded he makes L Ron Hubbard look like a man excessively overburdened with self-doubt and their deep-seated belief that foreign capitalists will invade at any +moment and steal all their bauxite. +The popular portrayal of this Marxist nation is something like one of the more harrowing episodes of M*A*S*H, only with the cast of wacky characters replaced by twitchy, +heavily armed Stalinist meth addicts +Cracked would like to take a moment to celebrate the good things about North Korea though, the things that the country's enemies prefer to suppress as part of their politically +motivated jealousy. Like how no different to you and me, there's nothing every North Korean likes more after an 18 hour shift at the phosphorus plant than a nice beer to go with +his dried fish ration. Ever attentive to its people's needs and in the twinkling of a decade, North Korea's leadership bought, disassembled, transported and rebuilt a British +brewery in order to discover and reproduce the secrets of beer and then brew the sweet nectar for its hardworking people, up to 18 bottles at a time. And with minimal fatalities. +When was the last time YOUR leader got a beer for YOU, American? (NB do not answer this question if you are Henry Louis Gates). +Or how about the fried chicken restaurant that downtown Pyongyang boasts? Yes real chicken, fried and then delivered to your sleeping cube, with optional beer if you like! You +don't even have to remove the feathers or pull out the gizzard yourself. Mostly. Americans must eat their fried chicken from a bucket, like swine, sold by a company so secretive +that even the very blend of seasoning used is intentionally kept from them. And they call North Korea paranoid? +And how many nations would entertain the syphilitic, bourgeois ramblings of Bill Clinton let alone permit him anywhere near their proud womenfolk? Only wise Kim Jong Il could see +past Bill's many, many imperfections and treat him with the pity and kindness he deserves, accepting his feeble pleas to pardon the American spies rightly convicted of photographing +the nation's sensitive beetroot fields. From 43f74f9c47bdbf2e524596c42d0cdd159e2b3cc1 Mon Sep 17 00:00:00 2001 From: pazis Date: Wed, 26 Feb 2020 09:20:31 +0000 Subject: [PATCH 03/13] new package name --- apache-beam/pom.xml | 74 +++++++++---------- .../apache/beam/{ => intro}/WordCount.java | 2 +- .../beam/{ => intro}/WordCountUnitTest.java | 6 +- 3 files changed, 42 insertions(+), 40 deletions(-) rename apache-beam/src/main/java/com/baeldung/apache/beam/{ => intro}/WordCount.java (98%) rename apache-beam/src/test/java/com/baeldung/apache/beam/{ => intro}/WordCountUnitTest.java (77%) 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 @@ - 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"> + 4.0.0 - - com.baeldung - parent-modules - 1.0.0-SNAPSHOT - + + com.baeldung + parent-modules + 1.0.0-SNAPSHOT + - com.baeldung.apache - apache-beam - 0.0.1-SNAPSHOT - apache-beam + com.baeldung.apache + apache-beam + 0.0.1-SNAPSHOT + apache-beam - - - org.apache.beam - beam-sdks-java-core - ${beam.version} - - - - org.apache.beam - beam-runners-direct-java - ${beam.version} - runtime - - - - org.assertj - assertj-core - ${assertj.version} - test - - + + + org.apache.beam + beam-sdks-java-core + ${beam.version} + + + + org.apache.beam + beam-runners-direct-java + ${beam.version} + runtime + + + + org.assertj + assertj-core + ${assertj.version} + test + + - - 2.19.0 - 3.6.1 - + + 2.19.0 + 3.6.1 + \ 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); From e57dbf3c72c264f1622e6c1d3d8e672e47ccb160 Mon Sep 17 00:00:00 2001 From: Pazis Date: Wed, 26 Feb 2020 12:51:26 +0330 Subject: [PATCH 04/13] delete .gitignore --- apache-beam/.gitignore | 1 - 1 file changed, 1 deletion(-) delete mode 100644 apache-beam/.gitignore diff --git a/apache-beam/.gitignore b/apache-beam/.gitignore deleted file mode 100644 index 84c048a73c..0000000000 --- a/apache-beam/.gitignore +++ /dev/null @@ -1 +0,0 @@ -/build/ From 862e7a3f20d3e8e599b805413fa944d5d48f50b7 Mon Sep 17 00:00:00 2001 From: Pazis Date: Wed, 26 Feb 2020 12:53:01 +0330 Subject: [PATCH 05/13] update main pom.xml added apache-beam module --- pom.xml | 1 + 1 file changed, 1 insertion(+) diff --git a/pom.xml b/pom.xml index ca5331b287..63f7b1dcc4 100644 --- a/pom.xml +++ b/pom.xml @@ -350,6 +350,7 @@ antlr apache-avro + apache-beam apache-bval apache-curator apache-cxf From e4f3ba564899b207b5a3acb15c4a66f3bbb099ae Mon Sep 17 00:00:00 2001 From: Pazis Date: Wed, 26 Feb 2020 20:03:23 +0330 Subject: [PATCH 06/13] update main pom.xml again --- pom.xml | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/pom.xml b/pom.xml index 63f7b1dcc4..bf87ac0cbf 100644 --- a/pom.xml +++ b/pom.xml @@ -350,7 +350,6 @@ antlr apache-avro - apache-beam apache-bval apache-curator apache-cxf @@ -640,7 +639,6 @@ spring-batch spring-bom spring-boot-modules - spring-boot-parent spring-boot-rest spring-caching @@ -862,6 +860,7 @@ antlr apache-avro + apache-beam apache-bval apache-curator apache-cxf @@ -1142,7 +1141,6 @@ spring-batch spring-bom spring-boot-modules - spring-boot-parent spring-boot-rest spring-caching From 17852cfe6d0523c33bd448c6d73a38b34bfba707 Mon Sep 17 00:00:00 2001 From: Pazis Date: Thu, 5 Mar 2020 06:42:17 +0330 Subject: [PATCH 07/13] Update pom.xml --- apache-beam/pom.xml | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/apache-beam/pom.xml b/apache-beam/pom.xml index 355e5b32e6..7a714ac480 100644 --- a/apache-beam/pom.xml +++ b/apache-beam/pom.xml @@ -12,7 +12,6 @@ com.baeldung.apache apache-beam 0.0.1-SNAPSHOT - apache-beam @@ -41,4 +40,4 @@ 3.6.1 - \ No newline at end of file + From 7a2c9410249efb879bc37f28eb0b373713be1d1b Mon Sep 17 00:00:00 2001 From: Sampada <46674082+sampada07@users.noreply.github.com> Date: Fri, 6 Mar 2020 21:19:00 +0530 Subject: [PATCH 08/13] BAEL-3883: Boruvka's Algorithm for Minimum-Spanning Trees (#8816) * BAEL-3883: Boruvka's Algorithm for Minimum-Spanning Trees * BAEL-3883: checking in pom.xml --- algorithms-miscellaneous-5/pom.xml | 12 ++++ .../algorithms/boruvka/BoruvkaMST.java | 61 +++++++++++++++++ .../algorithms/boruvka/DisjointSet.java | 49 ++++++++++++++ .../com/baeldung/algorithms/boruvka/Edge.java | 40 ++++++++++++ .../baeldung/algorithms/boruvka/Graph.java | 64 ++++++++++++++++++ .../baeldung/algorithms/boruvka/Input.java | 65 +++++++++++++++++++ .../com/baeldung/algorithms/boruvka/Tree.java | 63 ++++++++++++++++++ .../algorithms/boruvka/BoruvkaUnitTest.java | 48 ++++++++++++++ .../src/test/resources/input.json | 41 ++++++++++++ 9 files changed, 443 insertions(+) create mode 100644 algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/BoruvkaMST.java create mode 100644 algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/DisjointSet.java create mode 100644 algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/Edge.java create mode 100644 algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/Graph.java create mode 100644 algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/Input.java create mode 100644 algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/Tree.java create mode 100644 algorithms-miscellaneous-5/src/test/java/com/baeldung/algorithms/boruvka/BoruvkaUnitTest.java create mode 100644 algorithms-miscellaneous-5/src/test/resources/input.json diff --git a/algorithms-miscellaneous-5/pom.xml b/algorithms-miscellaneous-5/pom.xml index 4f9cc8b711..2799c39971 100644 --- a/algorithms-miscellaneous-5/pom.xml +++ b/algorithms-miscellaneous-5/pom.xml @@ -39,6 +39,16 @@ guava ${guava.version} + + com.fasterxml.jackson.core + jackson-databind + ${jackson.version} + + + org.junit.platform + junit-platform-commons + ${junit.platform.version} + org.assertj @@ -66,6 +76,8 @@ 1.11 3.6.1 28.1-jre + 2.10.2 + 1.6.0 \ No newline at end of file diff --git a/algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/BoruvkaMST.java b/algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/BoruvkaMST.java new file mode 100644 index 0000000000..0f8bc5b296 --- /dev/null +++ b/algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/BoruvkaMST.java @@ -0,0 +1,61 @@ +package com.baeldung.algorithms.boruvka; + +public class BoruvkaMST { + + private static Tree mst = new Tree(); + private static int totalWeight; + + public BoruvkaMST(Graph graph) { + DisjointSet dSet = new DisjointSet(graph.getNodes()); + + // repeat at most log N times or until we have N-1 edges + for (int t = 1; t < graph.getNodes() && mst.getEdgeCount() < graph.getNodes() - 1; t = t + t) { + + // foreach tree in forest, find closest edge + Edge[] closestEdgeArray = new Edge[graph.getNodes()]; + for (Edge edge : graph.getAllEdges()) { + int first = edge.getFirst(); + int second = edge.getSecond(); + int firstParent = dSet.getParent(first); + int secondParent = dSet.getParent(second); + if (firstParent == secondParent) { + continue; // same tree + } + if (closestEdgeArray[firstParent] == null || edge.getWeight() < closestEdgeArray[firstParent].getWeight()) { + closestEdgeArray[firstParent] = edge; + } + if (closestEdgeArray[secondParent] == null || edge.getWeight() < closestEdgeArray[secondParent].getWeight()) { + closestEdgeArray[secondParent] = edge; + } + } + + // add newly discovered edges to MST + for (int i = 0; i < graph.getNodes(); i++) { + Edge edge = closestEdgeArray[i]; + if (edge != null) { + int first = edge.getFirst(); + int second = edge.getSecond(); + // don't add the same edge twice + if (dSet.getParent(first) != dSet.getParent(second)) { + mst.addEdge(edge); + totalWeight += edge.getWeight(); + dSet.union(first, second); + } + } + } + } + } + + public Iterable getMST() { + return mst; + } + + public int getTotalWeight() { + return totalWeight; + } + + public String toString() { + return "MST: " + mst.toString() + " | Total Weight: " + totalWeight; + } + +} diff --git a/algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/DisjointSet.java b/algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/DisjointSet.java new file mode 100644 index 0000000000..7769686e36 --- /dev/null +++ b/algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/DisjointSet.java @@ -0,0 +1,49 @@ +package com.baeldung.algorithms.boruvka; + +import java.util.Arrays; + +public class DisjointSet { + + private int[] nodeParents; + private int[] nodeRanks; + + public DisjointSet(int n) { + nodeParents = new int[n]; + nodeRanks = new int[n]; + for (int i = 0; i < n; i++) { + nodeParents[i] = i; + nodeRanks[i] = 0; + } + } + + public int getParent(int node) { + while (node != nodeParents[node]) { + node = nodeParents[node]; + } + return node; + } + + public void union(int node1, int node2) { + int node1Parent = getParent(node1); + int node2Parent = getParent(node2); + if (node1Parent == node2Parent) { + return; + } + + if (nodeRanks[node1Parent] < nodeRanks[node2Parent]) { + nodeParents[node1Parent] = node2Parent; + } + else if (nodeRanks[node1Parent] > nodeRanks[node2Parent]) { + nodeParents[node2Parent] = node1Parent; + } + else { + nodeParents[node2Parent] = node1Parent; + nodeRanks[node1Parent]++; + } + } + + public String toString() { + return "Parent: " + Arrays.toString(nodeParents) + "Rank: " + Arrays.toString(nodeRanks); + } + +} diff --git a/algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/Edge.java b/algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/Edge.java new file mode 100644 index 0000000000..6ee136fc48 --- /dev/null +++ b/algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/Edge.java @@ -0,0 +1,40 @@ +package com.baeldung.algorithms.boruvka; + +public class Edge { + + private final int first; + private final int second; + private final int weight; + + public Edge(int first, int second, int weight) { + this.first = first; + this.second = second; + this.weight = weight; + } + + public double getWeight() { + return weight; + } + + public int getFirst() { + return first; + } + + public int getSecond() { + return second; + } + + public int getOtherNode(int firstNode) { + int secondNode = 0; + if (firstNode == first) + secondNode = second; + else if (firstNode == second) + secondNode = first; + return secondNode; + } + + public String toString() { + return String.format("%d-%d %d", first, second, weight); + } + +} diff --git a/algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/Graph.java b/algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/Graph.java new file mode 100644 index 0000000000..e899007dfa --- /dev/null +++ b/algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/Graph.java @@ -0,0 +1,64 @@ +package com.baeldung.algorithms.boruvka; + +import java.io.IOException; + +import com.fasterxml.jackson.core.JsonParseException; +import com.fasterxml.jackson.databind.JsonMappingException; + +public class Graph { + + private int nodes; + private int edges; + private Tree[] trees; + + public Graph(Input jsonGraph) throws JsonParseException, JsonMappingException, IOException { + nodes = jsonGraph.getNodes(); + trees = (Tree[]) new Tree[nodes]; + for (int i = 0; i < nodes; i++) { + trees[i] = new Tree(); + } + + int edgesFromInput = jsonGraph.getEdges(); + for (int i = 0; i < edgesFromInput; i++) { + int first = jsonGraph.getEdgeList() + .get(i) + .getFirst(); + int second = jsonGraph.getEdgeList() + .get(i) + .getSecond(); + int weight = jsonGraph.getEdgeList() + .get(i) + .getWeight(); + Edge edge = new Edge(first, second, weight); + + trees[first].addEdge(edge); + trees[second].addEdge(edge); + edges++; + } + + } + + public int getNodes() { + return nodes; + } + + public int getEdges() { + return edges; + } + + public Iterable iterableTree(int i) { + return trees[i]; + } + + public Iterable getAllEdges() { + Iterable list = new Tree(); + for (int i = 0; i < nodes; i++) { + for (Edge edge : iterableTree(i)) { + if (edge.getOtherNode(i) > i) { + ((Tree) list).addEdge(edge); + } + } + } + return list; + } +} diff --git a/algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/Input.java b/algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/Input.java new file mode 100644 index 0000000000..b52720d5e9 --- /dev/null +++ b/algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/Input.java @@ -0,0 +1,65 @@ +package com.baeldung.algorithms.boruvka; + +import java.util.List; + +public class Input { + private int nodes; + private int edges; + private List edgeList; + + public int getNodes() { + return nodes; + } + + public void setNodes(int nodes) { + this.nodes = nodes; + } + + public int getEdges() { + return edges; + } + + public void setEdges(int edges) { + this.edges = edges; + } + + public List getEdgeList() { + return edgeList; + } + + public void setEdgeList(List edgeList) { + this.edgeList = edgeList; + } + + static class E { + private int first; + private int second; + private int weight; + + public int getFirst() { + return first; + } + + public void setFirst(int first) { + this.first = first; + } + + public int getSecond() { + return second; + } + + public void setSecond(int second) { + this.second = second; + } + + public int getWeight() { + return weight; + } + + public void setWeight(int weight) { + this.weight = weight; + } + + } + +} diff --git a/algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/Tree.java b/algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/Tree.java new file mode 100644 index 0000000000..cc28233e07 --- /dev/null +++ b/algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/boruvka/Tree.java @@ -0,0 +1,63 @@ +package com.baeldung.algorithms.boruvka; + +import java.util.Iterator; + +public class Tree implements Iterable { + private Node root; + private int edgeCount; + + private static class Node { + private Edge edge; + private Node next; + + public String toString() { + String nextStr = next != null ? next.toString() : ""; + return edge.toString() + " | " + nextStr; + } + } + + public Tree() { + root = null; + edgeCount = 0; + } + + public int getEdgeCount() { + return edgeCount; + } + + public void addEdge(Edge edge) { + Node oldRoot = root; + root = new Node(); + root.edge = edge; + root.next = oldRoot; + edgeCount++; + } + + public String toString() { + String rootStr = root != null ? root.toString() : ""; + return "Tree: " + rootStr + "Size: " + edgeCount; + } + + public Iterator iterator() { + return new LinkedIterator(root); + } + + private class LinkedIterator implements Iterator { + private Node current; + + public LinkedIterator(Node root) { + current = root; + } + + public boolean hasNext() { + return current != null; + } + + public Edge next() { + Edge edge = current.edge; + current = current.next; + return edge; + } + } + +} diff --git a/algorithms-miscellaneous-5/src/test/java/com/baeldung/algorithms/boruvka/BoruvkaUnitTest.java b/algorithms-miscellaneous-5/src/test/java/com/baeldung/algorithms/boruvka/BoruvkaUnitTest.java new file mode 100644 index 0000000000..1d03d2d4d9 --- /dev/null +++ b/algorithms-miscellaneous-5/src/test/java/com/baeldung/algorithms/boruvka/BoruvkaUnitTest.java @@ -0,0 +1,48 @@ +package com.baeldung.algorithms.boruvka; + +import static org.junit.jupiter.api.Assertions.assertEquals; + +import java.io.BufferedReader; +import java.io.IOException; +import java.io.InputStreamReader; + +import org.junit.Before; +import org.junit.Test; + +import com.fasterxml.jackson.core.JsonParseException; +import com.fasterxml.jackson.databind.JsonMappingException; +import com.fasterxml.jackson.databind.ObjectMapper; + +public class BoruvkaUnitTest { + + private Input input; + private static String INPUT_JSON = "/input.json"; + + @Before + public void convertInputJsonToObject() throws JsonParseException, JsonMappingException, IOException { + ObjectMapper mapper = new ObjectMapper(); + StringBuilder jsonStr = new StringBuilder(); + try (BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(BoruvkaMST.class.getResourceAsStream(INPUT_JSON)))) { + String line; + while ((line = bufferedReader.readLine()) != null) { + jsonStr.append(line) + .append("\n"); + } + } + + input = mapper.readValue(jsonStr.toString(), Input.class); + + } + + @Test + public void givenInputGraph_whenBoruvkaPerformed_thenMinimumSpanningTree() throws JsonParseException, JsonMappingException, IOException { + Graph graph = new Graph(input); + BoruvkaMST boruvkaMST = new BoruvkaMST(graph); + + Tree mst = (Tree) boruvkaMST.getMST(); + + assertEquals(30, boruvkaMST.getTotalWeight()); + assertEquals(4, mst.getEdgeCount()); + } + +} diff --git a/algorithms-miscellaneous-5/src/test/resources/input.json b/algorithms-miscellaneous-5/src/test/resources/input.json new file mode 100644 index 0000000000..0151f83618 --- /dev/null +++ b/algorithms-miscellaneous-5/src/test/resources/input.json @@ -0,0 +1,41 @@ +{ + "nodes": 5, + "edges": 7, + "edgeList": [ + { + "first": 0, + "second": 1, + "weight": 8 + }, + { + "first": 0, + "second": 2, + "weight": 5 + }, + { + "first": 1, + "second": 2, + "weight": 9 + }, + { + "first": 1, + "second": 3, + "weight": 11 + }, + { + "first": 2, + "second": 3, + "weight": 15 + }, + { + "first": 2, + "second": 4, + "weight": 10 + }, + { + "first": 3, + "second": 4, + "weight": 7 + } + ] +} \ No newline at end of file From 40a17f0f63fb0fed6549dc920922fa4b1c825f58 Mon Sep 17 00:00:00 2001 From: sergio41 Date: Fri, 6 Mar 2020 18:05:48 +0100 Subject: [PATCH 09/13] BAEL-3765: Code Upload (#8804) --- .../com/baeldung/version/VersionObtainer.java | 20 +++++++++++++ .../version/VersionObtainerUnitTest.java | 30 +++++++++++++++++++ 2 files changed, 50 insertions(+) create mode 100644 spring-5/src/main/java/com/baeldung/version/VersionObtainer.java create mode 100644 spring-5/src/test/java/com/baeldung/version/VersionObtainerUnitTest.java diff --git a/spring-5/src/main/java/com/baeldung/version/VersionObtainer.java b/spring-5/src/main/java/com/baeldung/version/VersionObtainer.java new file mode 100644 index 0000000000..392cc44a72 --- /dev/null +++ b/spring-5/src/main/java/com/baeldung/version/VersionObtainer.java @@ -0,0 +1,20 @@ +package com.baeldung.version; + +import org.springframework.boot.system.JavaVersion; +import org.springframework.boot.system.SystemProperties; +import org.springframework.core.SpringVersion; + +public class VersionObtainer { + + public String getSpringVersion() { + return SpringVersion.getVersion(); + } + + public String getJavaVersion() { + return JavaVersion.getJavaVersion().toString(); + } + + public String getJdkVersion() { + return SystemProperties.get("java.version"); + } +} diff --git a/spring-5/src/test/java/com/baeldung/version/VersionObtainerUnitTest.java b/spring-5/src/test/java/com/baeldung/version/VersionObtainerUnitTest.java new file mode 100644 index 0000000000..6d77cd1403 --- /dev/null +++ b/spring-5/src/test/java/com/baeldung/version/VersionObtainerUnitTest.java @@ -0,0 +1,30 @@ +package com.baeldung.version; + +import static org.assertj.core.api.Assertions.assertThat; + +import org.junit.Test; +import org.springframework.boot.test.context.SpringBootTest; + +@SpringBootTest(classes = VersionObtainer.class) +public class VersionObtainerUnitTest { + + public VersionObtainer version = new VersionObtainer(); + + @Test + public void testGetSpringVersion() { + String res = version.getSpringVersion(); + assertThat(res).isNotEmpty(); + } + + @Test + public void testGetJdkVersion() { + String res = version.getJdkVersion(); + assertThat(res).isNotEmpty(); + } + + @Test + public void testGetJavaVersion() { + String res = version.getJavaVersion(); + assertThat(res).isNotEmpty(); + } +} From 6600942cef5b1a567945b409bf4a33ac60c16a4d Mon Sep 17 00:00:00 2001 From: Somnath Musib <7885767+musibs@users.noreply.github.com> Date: Sat, 7 Mar 2020 04:12:06 +1100 Subject: [PATCH 10/13] BAEL-3838 Capturing a Java Thread Dump (#8780) Co-authored-by: Somnath Musib --- .../com/baeldung/threaddump/ThreadDump.java | 28 +++++++++++++++++++ 1 file changed, 28 insertions(+) create mode 100644 core-java-modules/core-java-perf/src/main/java/com/baeldung/threaddump/ThreadDump.java diff --git a/core-java-modules/core-java-perf/src/main/java/com/baeldung/threaddump/ThreadDump.java b/core-java-modules/core-java-perf/src/main/java/com/baeldung/threaddump/ThreadDump.java new file mode 100644 index 0000000000..17bc840b8d --- /dev/null +++ b/core-java-modules/core-java-perf/src/main/java/com/baeldung/threaddump/ThreadDump.java @@ -0,0 +1,28 @@ +package com.baeldung.threaddump; + +import java.io.IOException; +import java.lang.management.ManagementFactory; +import java.lang.management.ThreadInfo; +import java.lang.management.ThreadMXBean; +import java.nio.file.Files; +import java.nio.file.Path; +import java.nio.file.Paths; + +public class ThreadDump { + + public static void main(String[] args) throws IOException { + threadDump(true, true); + } + + private static void threadDump(boolean lockedMonitors, boolean lockedSynchronizers) throws IOException { + Path threadDumpFile = Paths.get("ThreadDump.txt"); + + StringBuffer threadDump = new StringBuffer(System.lineSeparator()); + ThreadMXBean threadMXBean = ManagementFactory.getThreadMXBean(); + for(ThreadInfo threadInfo : threadMXBean.dumpAllThreads(lockedMonitors, lockedSynchronizers)) { + threadDump.append(threadInfo.toString()); + } + Files.write(threadDumpFile, threadDump.toString().getBytes()); + } + +} From fb515ed6515e1d9989b01e95508961c142f70ab8 Mon Sep 17 00:00:00 2001 From: "amit.pandey" Date: Sat, 7 Mar 2020 16:25:11 +0530 Subject: [PATCH 11/13] fix relative path warning --- spring-boot-modules/spring-boot-logging-log4j2/pom.xml | 1 + 1 file changed, 1 insertion(+) diff --git a/spring-boot-modules/spring-boot-logging-log4j2/pom.xml b/spring-boot-modules/spring-boot-logging-log4j2/pom.xml index 6e709230dd..00f830830a 100644 --- a/spring-boot-modules/spring-boot-logging-log4j2/pom.xml +++ b/spring-boot-modules/spring-boot-logging-log4j2/pom.xml @@ -13,6 +13,7 @@ org.springframework.boot spring-boot-starter-parent 2.2.2.RELEASE + From aaa6b73c3fb028ab9b77228014a70e75475eba5b Mon Sep 17 00:00:00 2001 From: "amit.pandey" Date: Sat, 7 Mar 2020 16:40:44 +0530 Subject: [PATCH 12/13] fix relative path warning. removed tab characters --- spring-boot-modules/spring-boot-logging-log4j2/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-boot-modules/spring-boot-logging-log4j2/pom.xml b/spring-boot-modules/spring-boot-logging-log4j2/pom.xml index 00f830830a..4422405187 100644 --- a/spring-boot-modules/spring-boot-logging-log4j2/pom.xml +++ b/spring-boot-modules/spring-boot-logging-log4j2/pom.xml @@ -13,7 +13,7 @@ org.springframework.boot spring-boot-starter-parent 2.2.2.RELEASE - + From 72d0f14b6edc6da177495398ddbc7680f9b1642f Mon Sep 17 00:00:00 2001 From: George Haris <40850523+gecharita@users.noreply.github.com> Date: Sat, 7 Mar 2020 16:16:08 +0200 Subject: [PATCH 13/13] BAEL-3835: Inject a value to a static field (#8820) Co-authored-by: Georgios Charitakis --- .../static-value-injection/README.md | 22 ++++++++ spring-core-3/static-value-injection/pom.xml | 52 +++++++++++++++++++ .../main/java/com/baeldung/Application.java | 13 +++++ .../controller/PropertyController.java | 31 +++++++++++ .../src/main/resources/application.properties | 1 + .../java/com/baeldung/ApplicationTests.java | 13 +++++ 6 files changed, 132 insertions(+) create mode 100644 spring-core-3/static-value-injection/README.md create mode 100644 spring-core-3/static-value-injection/pom.xml create mode 100644 spring-core-3/static-value-injection/src/main/java/com/baeldung/Application.java create mode 100644 spring-core-3/static-value-injection/src/main/java/com/baeldung/controller/PropertyController.java create mode 100644 spring-core-3/static-value-injection/src/main/resources/application.properties create mode 100644 spring-core-3/static-value-injection/src/test/java/com/baeldung/ApplicationTests.java diff --git a/spring-core-3/static-value-injection/README.md b/spring-core-3/static-value-injection/README.md new file mode 100644 index 0000000000..06dfa29f80 --- /dev/null +++ b/spring-core-3/static-value-injection/README.md @@ -0,0 +1,22 @@ +# Inject a value to a static field + +## How to run +```sh +mvn clean install +mvn spring-boot:run +``` + +## Request + +**GET** +http://localhost:8080/properties + + +## Response +```json +[ + "Inject a value to a static field", + "Inject a value to a static field", + null +] +``` diff --git a/spring-core-3/static-value-injection/pom.xml b/spring-core-3/static-value-injection/pom.xml new file mode 100644 index 0000000000..aa45fde886 --- /dev/null +++ b/spring-core-3/static-value-injection/pom.xml @@ -0,0 +1,52 @@ + + + 4.0.0 + + org.springframework.boot + spring-boot-starter-parent + 2.2.4.RELEASE + + + com.baeldung + static.value.injection + 0.0.1-SNAPSHOT + static.value.injection + Demo project for Spring Boot + + + 1.8 + + + + + org.springframework.boot + spring-boot-starter + + + org.springframework.boot + spring-boot-starter-web + + + org.springframework.boot + spring-boot-starter-test + test + + + org.junit.vintage + junit-vintage-engine + + + + + + + + + org.springframework.boot + spring-boot-maven-plugin + + + + + diff --git a/spring-core-3/static-value-injection/src/main/java/com/baeldung/Application.java b/spring-core-3/static-value-injection/src/main/java/com/baeldung/Application.java new file mode 100644 index 0000000000..c1875216b5 --- /dev/null +++ b/spring-core-3/static-value-injection/src/main/java/com/baeldung/Application.java @@ -0,0 +1,13 @@ +package com.baeldung; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +@SpringBootApplication +public class Application { + + public static void main(String[] args) { + SpringApplication.run(Application.class, args); + } + +} diff --git a/spring-core-3/static-value-injection/src/main/java/com/baeldung/controller/PropertyController.java b/spring-core-3/static-value-injection/src/main/java/com/baeldung/controller/PropertyController.java new file mode 100644 index 0000000000..03a2518117 --- /dev/null +++ b/spring-core-3/static-value-injection/src/main/java/com/baeldung/controller/PropertyController.java @@ -0,0 +1,31 @@ +package com.baeldung.controller; + +import org.springframework.beans.factory.annotation.Value; +import org.springframework.stereotype.Component; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.RestController; + +import java.util.Arrays; +import java.util.List; + +@RestController +public class PropertyController { + + @Value("${name}") + private String name; + + @Value("${name}") + private static String NAME_NULL; + + private static String NAME_STATIC; + + @Value("${name}") + public void setNameStatic(String name){ + PropertyController.NAME_STATIC = name; + } + + @GetMapping("/properties") + public List getProperties(){ + return Arrays.asList(this.name, NAME_STATIC, NAME_NULL) ; + } +} diff --git a/spring-core-3/static-value-injection/src/main/resources/application.properties b/spring-core-3/static-value-injection/src/main/resources/application.properties new file mode 100644 index 0000000000..828fa9cd2a --- /dev/null +++ b/spring-core-3/static-value-injection/src/main/resources/application.properties @@ -0,0 +1 @@ +name = Inject a value to a static field diff --git a/spring-core-3/static-value-injection/src/test/java/com/baeldung/ApplicationTests.java b/spring-core-3/static-value-injection/src/test/java/com/baeldung/ApplicationTests.java new file mode 100644 index 0000000000..4ad83bc539 --- /dev/null +++ b/spring-core-3/static-value-injection/src/test/java/com/baeldung/ApplicationTests.java @@ -0,0 +1,13 @@ +package com.baeldung; + +import org.junit.jupiter.api.Test; +import org.springframework.boot.test.context.SpringBootTest; + +@SpringBootTest +class ApplicationTests { + + @Test + void contextLoads() { + } + +}