Merge pull request #9 from eugenp/master

update with origin
2019-09-09 10:57:44 +02:00
parent 8470319d13 27b5ddfb38
commit 72f692d735
838 changed files with 31376 additions and 6252 deletions
@@ -1,24 +0,0 @@
-language: java
-
-before_install: 
-  - echo "MAVEN_OPTS='-Xmx2048M -Xss128M -XX:+CMSClassUnloadingEnabled -XX:+UseG1GC -XX:-UseGCOverheadLimit'" > ~/.mavenrc
-
-install: skip
-script: travis_wait 60 mvn -q install -Pdefault-first,default-second -Dgib.enabled=true
-
-sudo: required
-
-jdk:
-  - oraclejdk8
-
-addons:
-  apt:
-    packages:
-      - oracle-java8-installer
-
-cache:
-  directories:
-  - .autoconf
-  - $HOME/.m2
-  
-
@@ -7,3 +7,4 @@
 - [Checking If a List Is Sorted in Java](https://www.baeldung.com/java-check-if-list-sorted)
 - [Checking if a Java Graph has a Cycle](https://www.baeldung.com/java-graph-has-a-cycle)
 - [A Guide to the Folding Technique in Java](https://www.baeldung.com/folding-hashing-technique)
+- [Creating a Triangle with for Loops in Java](https://www.baeldung.com/java-print-triangle)
@@ -0,0 +1,70 @@
+package com.baeldung.bucketsort;
+
+import java.util.ArrayList;
+import java.util.Comparator;
+import java.util.List;
+
+public class IntegerBucketSorter implements Sorter<Integer> {
+
+    private final Comparator<Integer> comparator;
+
+    public IntegerBucketSorter(Comparator<Integer> comparator) {
+        this.comparator = comparator;
+    }
+
+    public IntegerBucketSorter() {
+        comparator = Comparator.naturalOrder();
+    }
+
+    public List<Integer> sort(List<Integer> arrayToSort) {
+
+        List<List<Integer>> buckets = splitIntoUnsortedBuckets(arrayToSort);
+
+        for(List<Integer> bucket  : buckets){
+            bucket.sort(comparator);
+        }
+
+        return concatenateSortedBuckets(buckets);
+    }
+
+    private List<Integer> concatenateSortedBuckets(List<List<Integer>> buckets){
+        List<Integer> sortedArray = new ArrayList<>();
+        int index = 0;
+        for(List<Integer> bucket : buckets){
+            for(int number : bucket){
+                sortedArray.add(index++, number);
+            }
+        }
+        return sortedArray;
+    }
+
+    private List<List<Integer>> splitIntoUnsortedBuckets(List<Integer> initialList){
+
+        final int[] codes = createHashes(initialList);
+
+        List<List<Integer>> buckets = new ArrayList<>(codes[1]);
+        for(int i = 0; i < codes[1]; i++) buckets.add(new ArrayList<>());
+
+        //distribute the data
+        for (int i : initialList) {
+            buckets.get(hash(i, codes)).add(i);
+        }
+        return buckets;
+
+    }
+
+    private int[] createHashes(List<Integer> input){
+        int m = input.get(0);
+        for (int i = 1; i < input.size(); i++) {
+            if (m < input.get(i)) {
+                m = input.get(i);
+            }
+        }
+        return new int[]{m, (int) Math.sqrt(input.size())};
+    }
+
+    private static int hash(int i, int[] code) {
+        return (int) ((double) i / code[0] * (code[1] - 1));
+    }
+
+}
@@ -0,0 +1,8 @@
+package com.baeldung.bucketsort;
+
+import java.util.List;
+
+public interface Sorter<T> {
+
+    List<T> sort(List<T> arrayToSort);
+}
@@ -4,7 +4,7 @@ import org.apache.commons.lang3.StringUtils;

 public class PrintTriangleExamples {

-    public static String printARightAngledTriangle(int N) {
+    public static String printARightTriangle(int N) {
        StringBuilder result = new StringBuilder();
        for (int r = 1; r <= N; r++) {
            for (int j = 1; j <= r; j++) {
@@ -29,6 +29,17 @@ public class PrintTriangleExamples {
        return result.toString();
    }

+    public static String printAnIsoscelesTriangleUsingStringUtils(int N) {
+        StringBuilder result = new StringBuilder();
+
+        for (int r = 1; r <= N; r++) {
+            result.append(StringUtils.repeat(' ', N - r));
+            result.append(StringUtils.repeat('*', 2 * r - 1));
+            result.append(System.lineSeparator());
+        }
+        return result.toString();
+    }
+
    public static String printAnIsoscelesTriangleUsingSubstring(int N) {
        StringBuilder result = new StringBuilder();
        String helperString = StringUtils.repeat(' ', N - 1) + StringUtils.repeat('*', N * 2 - 1);
@@ -41,8 +52,9 @@ public class PrintTriangleExamples {
    }

    public static void main(String[] args) {
-        System.out.println(printARightAngledTriangle(5));
+        System.out.println(printARightTriangle(5));
        System.out.println(printAnIsoscelesTriangle(5));
+        System.out.println(printAnIsoscelesTriangleUsingStringUtils(5));
        System.out.println(printAnIsoscelesTriangleUsingSubstring(5));
    }

@@ -0,0 +1,33 @@
+package com.baeldung.bucketsort;
+
+import com.baeldung.bucketsort.IntegerBucketSorter;
+import org.junit.Before;
+import org.junit.Test;
+
+import java.util.Arrays;
+import java.util.List;
+
+import static org.junit.Assert.assertEquals;
+
+public class IntegerBucketSorterUnitTest {
+
+    private IntegerBucketSorter sorter;
+
+    @Before
+    public void setUp() throws Exception {
+        sorter = new IntegerBucketSorter();
+    }
+
+    @Test
+    public void givenUnsortedList_whenSortedUsingBucketSorter_checkSortingCorrect() {
+
+        List<Integer> unsorted = Arrays.asList(80,50,60,30,20,10,70,0,40,500,600,602,200,15);
+        List<Integer> expected = Arrays.asList(0,10,15,20,30,40,50,60,70,80,200,500,600,602);
+
+        List<Integer> actual = sorter.sort(unsorted);
+
+        assertEquals(expected, actual);
+
+
+    }
+}
@@ -9,9 +9,9 @@ import static org.junit.Assert.assertEquals;

@RunWith(JUnitParamsRunner.class)
 public class PrintTriangleExamplesUnitTest {
-    
-    private static Object[][] rightAngledTriangles() {
-        String expected0 = ""; 
+
+    private static Object[][] rightTriangles() {
+        String expected0 = "";
        
        String expected2 = "*" + System.lineSeparator() 
                         + "**" + System.lineSeparator();
@@ -39,9 +39,9 @@ public class PrintTriangleExamplesUnitTest {
    }

    @Test
-    @Parameters(method = "rightAngledTriangles")
-    public void whenPrintARightAngledTriangleIsCalled_ThenTheCorrectStringIsReturned(int nrOfRows, String expected) {
-        String actual = PrintTriangleExamples.printARightAngledTriangle(nrOfRows);
+    @Parameters(method = "rightTriangles")
+    public void whenPrintARightTriangleIsCalled_ThenTheCorrectStringIsReturned(int nrOfRows, String expected) {
+        String actual = PrintTriangleExamples.printARightTriangle(nrOfRows);

        assertEquals(expected, actual);
    }
@@ -81,6 +81,14 @@ public class PrintTriangleExamplesUnitTest {

        assertEquals(expected, actual);
    }
+
+    @Test
+    @Parameters(method = "isoscelesTriangles")
+    public void whenPrintAnIsoscelesTriangleUsingStringUtilsIsCalled_ThenTheCorrectStringIsReturned(int nrOfRows, String expected) {
+        String actual = PrintTriangleExamples.printAnIsoscelesTriangleUsingStringUtils(nrOfRows);
+
+        assertEquals(expected, actual);
+    }
    
    @Test
    @Parameters(method = "isoscelesTriangles")
@@ -6,3 +6,4 @@
 - [Insertion Sort in Java](https://www.baeldung.com/java-insertion-sort)
 - [Heap Sort in Java](https://www.baeldung.com/java-heap-sort)
 - [Shell Sort in Java](https://www.baeldung.com/java-shell-sort)
+- [Counting Sort in Java](https://www.baeldung.com/java-counting-sort)
@@ -0,0 +1,48 @@
+package com.baeldung.algorithms.counting;
+
+import java.util.Arrays;
+import java.util.stream.IntStream;
+
+public class CountingSort {
+
+    public static int[] sort(int[] input, int k) {
+        verifyPreconditions(input, k);
+        if (input.length == 0) return input;
+
+        int[] c = countElements(input, k);
+        int[] sorted = new int[input.length];
+        for (int i = input.length - 1; i >= 0; i--) {
+            int current = input[i];
+            sorted[c[current] - 1] = current;
+            c[current] -= 1;
+        }
+
+        return sorted;
+    }
+
+    static int[] countElements(int[] input, int k) {
+        int[] c = new int[k + 1];
+        Arrays.fill(c, 0);
+        for (int i : input) {
+            c[i] += 1;
+        }
+
+        for (int i = 1; i < c.length; i++) {
+            c[i] += c[i - 1];
+        }
+        return c;
+    }
+
+    private static void verifyPreconditions(int[] input, int k) {
+        if (input == null) {
+            throw new IllegalArgumentException("Input is required");
+        }
+
+        int min = IntStream.of(input).min().getAsInt();
+        int max = IntStream.of(input).max().getAsInt();
+
+        if (min < 0 || max > k) {
+            throw new IllegalArgumentException("The input numbers should be between zero and " + k);
+        }
+    }
+}
@@ -0,0 +1,53 @@
+package com.baeldung.algorithms.radixsort;
+
+import java.util.Arrays;
+
+public class RadixSort {
+
+    public static void sort(int numbers[]) {
+        int maximumNumber = findMaximumNumberIn(numbers);
+
+        int numberOfDigits = calculateNumberOfDigitsIn(maximumNumber);
+
+        int placeValue = 1;
+
+        while (numberOfDigits-- > 0) {
+            applyCountingSortOn(numbers, placeValue);
+            placeValue *= 10;
+        }
+    }
+
+    private static void applyCountingSortOn(int[] numbers, int placeValue) {
+        int range = 10; // radix or the base
+
+        int length = numbers.length;
+        int[] frequency = new int[range];
+        int[] sortedValues = new int[length];
+
+        for (int i = 0; i < length; i++) {
+            int digit = (numbers[i] / placeValue) % range;
+            frequency[digit]++;
+        }
+
+        for (int i = 1; i < 10; i++) {
+            frequency[i] += frequency[i - 1];
+        }
+
+        for (int i = length - 1; i >= 0; i--) {
+            int digit = (numbers[i] / placeValue) % range;
+            sortedValues[frequency[digit] - 1] = numbers[i];
+            frequency[digit]--;
+        }
+
+        System.arraycopy(sortedValues, 0, numbers, 0, length);
+    }
+
+    private static int calculateNumberOfDigitsIn(int number) {
+        return (int) Math.log10(number) + 1; // valid only if number > 0
+    }
+
+    private static int findMaximumNumberIn(int[] arr) {
+        return Arrays.stream(arr).max().getAsInt();
+    }
+
+}
@@ -1,4 +1,4 @@
-package com.baeldung.algorithms.stringsortingbynumber;
+package com.baeldung.algorithms.sort.bynumber;

 import java.util.Comparator;

@@ -0,0 +1,32 @@
+package com.baeldung.algorithms.counting;
+
+import java.util.Arrays;
+
+import static org.junit.jupiter.api.Assertions.assertArrayEquals;
+
+import org.junit.jupiter.api.Test;
+
+class CountingSortUnitTest {
+
+    @Test
+    void countElements_GivenAnArray_ShouldCalculateTheFrequencyArrayAsExpected() {
+        int k = 5;
+        int[] input = { 4, 3, 2, 5, 4, 3, 5, 1, 0, 2, 5 };
+
+        int[] c = CountingSort.countElements(input, k);
+        int[] expected = { 1, 2, 4, 6, 8, 11 };
+        assertArrayEquals(expected, c);
+    }
+
+    @Test
+    void sort_GivenAnArray_ShouldSortTheInputAsExpected() {
+        int k = 5;
+        int[] input = { 4, 3, 2, 5, 4, 3, 5, 1, 0, 2, 5 };
+
+        int[] sorted = CountingSort.sort(input, k);
+
+        // Our sorting algorithm and Java's should return the same result
+        Arrays.sort(input);
+        assertArrayEquals(input, sorted);
+    }
+}
@@ -0,0 +1,16 @@
+package com.baeldung.algorithms.radixsort;
+
+import static org.junit.Assert.assertArrayEquals;
+
+import org.junit.Test;
+
+public class RadixSortUnitTest {
+
+    @Test
+    public void givenUnsortedArrayWhenRadixSortThenArraySorted() {
+        int[] numbers = { 387, 468, 134, 123, 68, 221, 769, 37, 7 };
+        RadixSort.sort(numbers);
+        int[] numbersSorted = { 7, 37, 68, 123, 134, 221, 387, 468, 769 };
+        assertArrayEquals(numbersSorted, numbers);
+    }
+}
@@ -1,6 +1,6 @@
-package com.baeldung.algorithms.stringsortingbynumber;
+package com.baeldung.algorithms.sort.bynumber;

-import com.baeldung.algorithms.stringsortingbynumber.NaturalOrderComparators;
+import com.baeldung.algorithms.sort.bynumber.NaturalOrderComparators;
 import org.junit.Test;

 import java.util.ArrayList;
@@ -4,9 +4,9 @@
 	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>org.baeldung.examples.olingo2</groupId>
-	<artifactId>olingo2-sample</artifactId>
+	<artifactId>olingo2</artifactId>
 	<version>0.0.1-SNAPSHOT</version>
-	<name>olingo2-sample</name>
+	<name>olingo2</name>
 	<description>Sample Olingo 2 Project</description>

    <parent>
@@ -0,0 +1,150 @@
+5.1,3.5,1.4,0.2,Iris-setosa
+4.9,3.0,1.4,0.2,Iris-setosa
+4.7,3.2,1.3,0.2,Iris-setosa
+4.6,3.1,1.5,0.2,Iris-setosa
+5.0,3.6,1.4,0.2,Iris-setosa
+5.4,3.9,1.7,0.4,Iris-setosa
+4.6,3.4,1.4,0.3,Iris-setosa
+5.0,3.4,1.5,0.2,Iris-setosa
+4.4,2.9,1.4,0.2,Iris-setosa
+4.9,3.1,1.5,0.1,Iris-setosa
+5.4,3.7,1.5,0.2,Iris-setosa
+4.8,3.4,1.6,0.2,Iris-setosa
+4.8,3.0,1.4,0.1,Iris-setosa
+4.3,3.0,1.1,0.1,Iris-setosa
+5.8,4.0,1.2,0.2,Iris-setosa
+5.7,4.4,1.5,0.4,Iris-setosa
+5.4,3.9,1.3,0.4,Iris-setosa
+5.1,3.5,1.4,0.3,Iris-setosa
+5.7,3.8,1.7,0.3,Iris-setosa
+5.1,3.8,1.5,0.3,Iris-setosa
+5.4,3.4,1.7,0.2,Iris-setosa
+5.1,3.7,1.5,0.4,Iris-setosa
+4.6,3.6,1.0,0.2,Iris-setosa
+5.1,3.3,1.7,0.5,Iris-setosa
+4.8,3.4,1.9,0.2,Iris-setosa
+5.0,3.0,1.6,0.2,Iris-setosa
+5.0,3.4,1.6,0.4,Iris-setosa
+5.2,3.5,1.5,0.2,Iris-setosa
+5.2,3.4,1.4,0.2,Iris-setosa
+4.7,3.2,1.6,0.2,Iris-setosa
+4.8,3.1,1.6,0.2,Iris-setosa
+5.4,3.4,1.5,0.4,Iris-setosa
+5.2,4.1,1.5,0.1,Iris-setosa
+5.5,4.2,1.4,0.2,Iris-setosa
+4.9,3.1,1.5,0.1,Iris-setosa
+5.0,3.2,1.2,0.2,Iris-setosa
+5.5,3.5,1.3,0.2,Iris-setosa
+4.9,3.1,1.5,0.1,Iris-setosa
+4.4,3.0,1.3,0.2,Iris-setosa
+5.1,3.4,1.5,0.2,Iris-setosa
+5.0,3.5,1.3,0.3,Iris-setosa
+4.5,2.3,1.3,0.3,Iris-setosa
+4.4,3.2,1.3,0.2,Iris-setosa
+5.0,3.5,1.6,0.6,Iris-setosa
+5.1,3.8,1.9,0.4,Iris-setosa
+4.8,3.0,1.4,0.3,Iris-setosa
+5.1,3.8,1.6,0.2,Iris-setosa
+4.6,3.2,1.4,0.2,Iris-setosa
+5.3,3.7,1.5,0.2,Iris-setosa
+5.0,3.3,1.4,0.2,Iris-setosa
+7.0,3.2,4.7,1.4,Iris-versicolor
+6.4,3.2,4.5,1.5,Iris-versicolor
+6.9,3.1,4.9,1.5,Iris-versicolor
+5.5,2.3,4.0,1.3,Iris-versicolor
+6.5,2.8,4.6,1.5,Iris-versicolor
+5.7,2.8,4.5,1.3,Iris-versicolor
+6.3,3.3,4.7,1.6,Iris-versicolor
+4.9,2.4,3.3,1.0,Iris-versicolor
+6.6,2.9,4.6,1.3,Iris-versicolor
+5.2,2.7,3.9,1.4,Iris-versicolor
+5.0,2.0,3.5,1.0,Iris-versicolor
+5.9,3.0,4.2,1.5,Iris-versicolor
+6.0,2.2,4.0,1.0,Iris-versicolor
+6.1,2.9,4.7,1.4,Iris-versicolor
+5.6,2.9,3.6,1.3,Iris-versicolor
+6.7,3.1,4.4,1.4,Iris-versicolor
+5.6,3.0,4.5,1.5,Iris-versicolor
+5.8,2.7,4.1,1.0,Iris-versicolor
+6.2,2.2,4.5,1.5,Iris-versicolor
+5.6,2.5,3.9,1.1,Iris-versicolor
+5.9,3.2,4.8,1.8,Iris-versicolor
+6.1,2.8,4.0,1.3,Iris-versicolor
+6.3,2.5,4.9,1.5,Iris-versicolor
+6.1,2.8,4.7,1.2,Iris-versicolor
+6.4,2.9,4.3,1.3,Iris-versicolor
+6.6,3.0,4.4,1.4,Iris-versicolor
+6.8,2.8,4.8,1.4,Iris-versicolor
+6.7,3.0,5.0,1.7,Iris-versicolor
+6.0,2.9,4.5,1.5,Iris-versicolor
+5.7,2.6,3.5,1.0,Iris-versicolor
+5.5,2.4,3.8,1.1,Iris-versicolor
+5.5,2.4,3.7,1.0,Iris-versicolor
+5.8,2.7,3.9,1.2,Iris-versicolor
+6.0,2.7,5.1,1.6,Iris-versicolor
+5.4,3.0,4.5,1.5,Iris-versicolor
+6.0,3.4,4.5,1.6,Iris-versicolor
+6.7,3.1,4.7,1.5,Iris-versicolor
+6.3,2.3,4.4,1.3,Iris-versicolor
+5.6,3.0,4.1,1.3,Iris-versicolor
+5.5,2.5,4.0,1.3,Iris-versicolor
+5.5,2.6,4.4,1.2,Iris-versicolor
+6.1,3.0,4.6,1.4,Iris-versicolor
+5.8,2.6,4.0,1.2,Iris-versicolor
+5.0,2.3,3.3,1.0,Iris-versicolor
+5.6,2.7,4.2,1.3,Iris-versicolor
+5.7,3.0,4.2,1.2,Iris-versicolor
+5.7,2.9,4.2,1.3,Iris-versicolor
+6.2,2.9,4.3,1.3,Iris-versicolor
+5.1,2.5,3.0,1.1,Iris-versicolor
+5.7,2.8,4.1,1.3,Iris-versicolor
+6.3,3.3,6.0,2.5,Iris-virginica
+5.8,2.7,5.1,1.9,Iris-virginica
+7.1,3.0,5.9,2.1,Iris-virginica
+6.3,2.9,5.6,1.8,Iris-virginica
+6.5,3.0,5.8,2.2,Iris-virginica
+7.6,3.0,6.6,2.1,Iris-virginica
+4.9,2.5,4.5,1.7,Iris-virginica
+7.3,2.9,6.3,1.8,Iris-virginica
+6.7,2.5,5.8,1.8,Iris-virginica
+7.2,3.6,6.1,2.5,Iris-virginica
+6.5,3.2,5.1,2.0,Iris-virginica
+6.4,2.7,5.3,1.9,Iris-virginica
+6.8,3.0,5.5,2.1,Iris-virginica
+5.7,2.5,5.0,2.0,Iris-virginica
+5.8,2.8,5.1,2.4,Iris-virginica
+6.4,3.2,5.3,2.3,Iris-virginica
+6.5,3.0,5.5,1.8,Iris-virginica
+7.7,3.8,6.7,2.2,Iris-virginica
+7.7,2.6,6.9,2.3,Iris-virginica
+6.0,2.2,5.0,1.5,Iris-virginica
+6.9,3.2,5.7,2.3,Iris-virginica
+5.6,2.8,4.9,2.0,Iris-virginica
+7.7,2.8,6.7,2.0,Iris-virginica
+6.3,2.7,4.9,1.8,Iris-virginica
+6.7,3.3,5.7,2.1,Iris-virginica
+7.2,3.2,6.0,1.8,Iris-virginica
+6.2,2.8,4.8,1.8,Iris-virginica
+6.1,3.0,4.9,1.8,Iris-virginica
+6.4,2.8,5.6,2.1,Iris-virginica
+7.2,3.0,5.8,1.6,Iris-virginica
+7.4,2.8,6.1,1.9,Iris-virginica
+7.9,3.8,6.4,2.0,Iris-virginica
+6.4,2.8,5.6,2.2,Iris-virginica
+6.3,2.8,5.1,1.5,Iris-virginica
+6.1,2.6,5.6,1.4,Iris-virginica
+7.7,3.0,6.1,2.3,Iris-virginica
+6.3,3.4,5.6,2.4,Iris-virginica
+6.4,3.1,5.5,1.8,Iris-virginica
+6.0,3.0,4.8,1.8,Iris-virginica
+6.9,3.1,5.4,2.1,Iris-virginica
+6.7,3.1,5.6,2.4,Iris-virginica
+6.9,3.1,5.1,2.3,Iris-virginica
+5.8,2.7,5.1,1.9,Iris-virginica
+6.8,3.2,5.9,2.3,Iris-virginica
+6.7,3.3,5.7,2.5,Iris-virginica
+6.7,3.0,5.2,2.3,Iris-virginica
+6.3,2.5,5.0,1.9,Iris-virginica
+6.5,3.0,5.2,2.0,Iris-virginica
+6.2,3.4,5.4,2.3,Iris-virginica
+5.9,3.0,5.1,1.8,Iris-virginica
@@ -0,0 +1 @@
+{"class":"org.apache.spark.mllib.classification.LogisticRegressionModel","version":"1.0","numFeatures":4,"numClasses":3}
@@ -1,31 +1,32 @@
-<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>com.baeldung</groupId>
-    <artifactId>apache-spark</artifactId>
-    <version>1.0-SNAPSHOT</version>
-    <name>apache-spark</name>
-    <packaging>jar</packaging>
-    <url>http://maven.apache.org</url>
+<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>com.baeldung</groupId>
+	<artifactId>apache-spark</artifactId>
+	<version>1.0-SNAPSHOT</version>
+	<name>apache-spark</name>
+	<packaging>jar</packaging>
+	<url>http://maven.apache.org</url>

-    <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>

-    <dependencies>
-        <dependency>
-            <groupId>org.apache.spark</groupId>
-            <artifactId>spark-core_2.11</artifactId>
-            <version>${org.apache.spark.spark-core.version}</version>
-            <scope>provided</scope>
-        </dependency>
+	<dependencies>
 		<dependency>
-    		<groupId>org.apache.spark</groupId>
-    		<artifactId>spark-sql_2.11</artifactId>
-    		<version>${org.apache.spark.spark-sql.version}</version>
-    		<scope>provided</scope>
+			<groupId>org.apache.spark</groupId>
+			<artifactId>spark-core_2.11</artifactId>
+			<version>${org.apache.spark.spark-core.version}</version>
+			<scope>provided</scope>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.spark</groupId>
+			<artifactId>spark-sql_2.11</artifactId>
+			<version>${org.apache.spark.spark-sql.version}</version>
+			<scope>provided</scope>
 		</dependency>
 		<dependency>
 			<groupId>org.apache.spark</groupId>
@@ -33,6 +34,12 @@
 			<version>${org.apache.spark.spark-streaming.version}</version>
 			<scope>provided</scope>
 		</dependency>
+		<dependency>
+			<groupId>org.apache.spark</groupId>
+			<artifactId>spark-mllib_2.11</artifactId>
+			<version>${org.apache.spark.spark-mllib.version}</version>
+			<scope>provided</scope>
+		</dependency>
 		<dependency>
 			<groupId>org.apache.spark</groupId>
 			<artifactId>spark-streaming-kafka-0-10_2.11</artifactId>
@@ -48,46 +55,47 @@
 			<artifactId>spark-cassandra-connector-java_2.11</artifactId>
 			<version>${com.datastax.spark.spark-cassandra-connector-java.version}</version>
 		</dependency>
-    </dependencies>
+	</dependencies>

 	<build>
-    	<plugins>
-    	  	<plugin>
-    			<groupId>org.apache.maven.plugins</groupId>
-    			<artifactId>maven-compiler-plugin</artifactId>
-    			<version>${maven-compiler-plugin.version}</version>
-    			<configuration>
-      				<source>${java.version}</source>
-      				<target>${java.version}</target>
-    			</configuration>
-  			</plugin>
-      		<plugin>
-        		<artifactId>maven-assembly-plugin</artifactId>
-        		<executions>
-          			<execution>
-            			<phase>package</phase>
-            			<goals>
-              				<goal>single</goal>
-            			</goals>
-          			</execution>
-        		</executions>
-        		<configuration>
-          			<descriptorRefs>
-            			<descriptorRef>jar-with-dependencies</descriptorRef>
-          			</descriptorRefs>
-        		</configuration>
-      		</plugin>
-   		</plugins>
-  	</build>
+		<plugins>
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-compiler-plugin</artifactId>
+				<version>${maven-compiler-plugin.version}</version>
+				<configuration>
+					<source>${java.version}</source>
+					<target>${java.version}</target>
+				</configuration>
+			</plugin>
+			<plugin>
+				<artifactId>maven-assembly-plugin</artifactId>
+				<executions>
+					<execution>
+						<phase>package</phase>
+						<goals>
+							<goal>single</goal>
+						</goals>
+					</execution>
+				</executions>
+				<configuration>
+					<descriptorRefs>
+						<descriptorRef>jar-with-dependencies</descriptorRef>
+					</descriptorRefs>
+				</configuration>
+			</plugin>
+		</plugins>
+	</build>

-    <properties>
-        <org.apache.spark.spark-core.version>2.3.0</org.apache.spark.spark-core.version>
-        <org.apache.spark.spark-sql.version>2.3.0</org.apache.spark.spark-sql.version>
-        <org.apache.spark.spark-streaming.version>2.3.0</org.apache.spark.spark-streaming.version>
-        <org.apache.spark.spark-streaming-kafka.version>2.3.0</org.apache.spark.spark-streaming-kafka.version>
-        <com.datastax.spark.spark-cassandra-connector.version>2.3.0</com.datastax.spark.spark-cassandra-connector.version>
-        <com.datastax.spark.spark-cassandra-connector-java.version>1.5.2</com.datastax.spark.spark-cassandra-connector-java.version>
+	<properties>
+		<org.apache.spark.spark-core.version>2.3.0</org.apache.spark.spark-core.version>
+		<org.apache.spark.spark-sql.version>2.3.0</org.apache.spark.spark-sql.version>
+		<org.apache.spark.spark-streaming.version>2.3.0</org.apache.spark.spark-streaming.version>
+		<org.apache.spark.spark-mllib.version>2.3.0</org.apache.spark.spark-mllib.version>
+		<org.apache.spark.spark-streaming-kafka.version>2.3.0</org.apache.spark.spark-streaming-kafka.version>
+		<com.datastax.spark.spark-cassandra-connector.version>2.3.0</com.datastax.spark.spark-cassandra-connector.version>
+		<com.datastax.spark.spark-cassandra-connector-java.version>1.5.2</com.datastax.spark.spark-cassandra-connector-java.version>
 		<maven-compiler-plugin.version>3.2</maven-compiler-plugin.version>
-    </properties>
+	</properties>

 </project>
@@ -0,0 +1,111 @@
+package com.baeldung.ml;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.apache.log4j.Level;
+import org.apache.log4j.Logger;
+import org.apache.spark.SparkConf;
+import org.apache.spark.api.java.JavaPairRDD;
+import org.apache.spark.api.java.JavaRDD;
+import org.apache.spark.api.java.JavaSparkContext;
+import org.apache.spark.mllib.classification.LogisticRegressionModel;
+import org.apache.spark.mllib.classification.LogisticRegressionWithLBFGS;
+import org.apache.spark.mllib.evaluation.MulticlassMetrics;
+import org.apache.spark.mllib.linalg.Matrix;
+import org.apache.spark.mllib.linalg.Vector;
+import org.apache.spark.mllib.linalg.Vectors;
+import org.apache.spark.mllib.regression.LabeledPoint;
+import org.apache.spark.mllib.stat.MultivariateStatisticalSummary;
+import org.apache.spark.mllib.stat.Statistics;
+
+import scala.Tuple2;
+
+public class MachineLearningApp {
+
+    public static void main(String[] args) {
+
+        // 1. Setting the Spark Context
+        SparkConf conf = new SparkConf().setAppName("Main")
+            .setMaster("local[2]")
+            .set("spark.executor.memory", "3g")
+            .set("spark.driver.memory", "3g");
+        JavaSparkContext sc = new JavaSparkContext(conf);
+        Logger.getLogger("org")
+            .setLevel(Level.OFF);
+        Logger.getLogger("akka")
+            .setLevel(Level.OFF);
+
+        // 2. Loading the Data-set
+        String dataFile = "data\\iris.data";
+        JavaRDD<String> data = sc.textFile(dataFile);
+
+        // 3. Exploratory Data Analysis
+        // 3.1. Creating Vector of Input Data
+        JavaRDD<Vector> inputData = data.map(line -> {
+            String[] parts = line.split(",");
+            double[] v = new double[parts.length - 1];
+            for (int i = 0; i < parts.length - 1; i++) {
+                v[i] = Double.parseDouble(parts[i]);
+            }
+            return Vectors.dense(v);
+        });
+        // 3.2. Performing Statistical Analysis
+        MultivariateStatisticalSummary summary = Statistics.colStats(inputData.rdd());
+        System.out.println("Summary Mean:");
+        System.out.println(summary.mean());
+        System.out.println("Summary Variance:");
+        System.out.println(summary.variance());
+        System.out.println("Summary Non-zero:");
+        System.out.println(summary.numNonzeros());
+        // 3.3. Performing Correlation Analysis
+        Matrix correlMatrix = Statistics.corr(inputData.rdd(), "pearson");
+        System.out.println("Correlation Matrix:");
+        System.out.println(correlMatrix.toString());
+
+        // 4. Data Preparation
+        // 4.1. Creating Map for Textual Output Labels
+        Map<String, Integer> map = new HashMap<String, Integer>();
+        map.put("Iris-setosa", 0);
+        map.put("Iris-versicolor", 1);
+        map.put("Iris-virginica", 2);
+        // 4.2. Creating LabeledPoint of Input and Output Data
+        JavaRDD<LabeledPoint> parsedData = data.map(line -> {
+            String[] parts = line.split(",");
+            double[] v = new double[parts.length - 1];
+            for (int i = 0; i < parts.length - 1; i++) {
+                v[i] = Double.parseDouble(parts[i]);
+            }
+            return new LabeledPoint(map.get(parts[parts.length - 1]), Vectors.dense(v));
+        });
+
+        // 5. Data Splitting into 80% Training and 20% Test Sets
+        JavaRDD<LabeledPoint>[] splits = parsedData.randomSplit(new double[] { 0.8, 0.2 }, 11L);
+        JavaRDD<LabeledPoint> trainingData = splits[0].cache();
+        JavaRDD<LabeledPoint> testData = splits[1];
+
+        // 6. Modeling
+        // 6.1. Model Training
+        LogisticRegressionModel model = new LogisticRegressionWithLBFGS().setNumClasses(3)
+            .run(trainingData.rdd());
+        // 6.2. Model Evaluation
+        JavaPairRDD<Object, Object> predictionAndLabels = testData.mapToPair(p -> new Tuple2<>(model.predict(p.features()), p.label()));
+        MulticlassMetrics metrics = new MulticlassMetrics(predictionAndLabels.rdd());
+        double accuracy = metrics.accuracy();
+        System.out.println("Model Accuracy on Test Data: " + accuracy);
+
+        // 7. Model Saving and Loading
+        // 7.1. Model Saving
+        model.save(sc.sc(), "model\\logistic-regression");
+        // 7.2. Model Loading
+        LogisticRegressionModel sameModel = LogisticRegressionModel.load(sc.sc(), "model\\logistic-regression");
+        // 7.3. Prediction on New Data
+        Vector newData = Vectors.dense(new double[] { 1, 1, 1, 1 });
+        double prediction = sameModel.predict(newData);
+        System.out.println("Model Prediction on New Data = " + prediction);
+
+        // 8. Clean-up
+        sc.close();
+    }
+
+}
@@ -0,0 +1,3 @@
+## Relevant Articles:
+
+- [Building Java Applications with Bazel](https://www.baeldung.com/bazel-build-tool)
@@ -0,0 +1,31 @@
+
+load("@bazel_tools//tools/build_defs/repo:http.bzl", "http_jar")
+load("@bazel_tools//tools/build_defs/repo:http.bzl", "http_archive")
+
+
+RULES_JVM_EXTERNAL_TAG = "2.0.1"
+RULES_JVM_EXTERNAL_SHA = "55e8d3951647ae3dffde22b4f7f8dee11b3f70f3f89424713debd7076197eaca"
+
+http_archive(
+    name = "rules_jvm_external",
+    strip_prefix = "rules_jvm_external-%s" % RULES_JVM_EXTERNAL_TAG,
+    sha256 = RULES_JVM_EXTERNAL_SHA,
+    url = "https://github.com/bazelbuild/rules_jvm_external/archive/%s.zip" % RULES_JVM_EXTERNAL_TAG,
+)
+
+load("@rules_jvm_external//:defs.bzl", "maven_install")
+
+maven_install(
+    artifacts = [
+        "org.apache.commons:commons-lang3:3.9"
+    ],
+    repositories = [
+        "https://repo1.maven.org/maven2",
+    ]
+)
+
+http_jar (
+    name = "apache-commons-lang",
+    url = "https://repo1.maven.org/maven2/org/apache/commons/commons-lang3/3.9/commons-lang3-3.9.jar"
+)
+
@@ -0,0 +1,7 @@
+
+java_binary (
+    name = "BazelApp",
+    srcs = glob(["src/main/java/com/baeldung/*.java"]),
+    main_class = "com.baeldung.BazelApp",
+    deps = ["//bazelgreeting:greeter", "@maven//:org_apache_commons_commons_lang3"]
+)
@@ -0,0 +1,29 @@
+<?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>
+    <artifactId>bazelapp</artifactId>
+    <name>bazelapp</name>
+	
+    <parent>
+        <artifactId>bazel</artifactId>
+        <groupId>com.baeldung</groupId>
+        <version>1.0.0-SNAPSHOT</version>
+    </parent>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.baeldung</groupId>
+            <artifactId>bazelgreeting</artifactId>
+            <version>1.0.0-SNAPSHOT</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>3.9</version>
+        </dependency>
+    </dependencies>
+
+
+</project>
--- a/Show More
+++ b/Show More
				`@@ -0,0 +1 @@`
				`{"class":"org.apache.spark.mllib.classification.LogisticRegressionModel","version":"1.0","numFeatures":4,"numClasses":3}`