diff --git a/src/main/java/org/dataalgorithms/bonus/anagram/spark/SparkAnagram.java b/src/main/java/org/dataalgorithms/bonus/anagram/spark/SparkAnagram.java
index 0b5034a4..81dbcc92 100755
--- a/src/main/java/org/dataalgorithms/bonus/anagram/spark/SparkAnagram.java
+++ b/src/main/java/org/dataalgorithms/bonus/anagram/spark/SparkAnagram.java
@@ -22,7 +22,10 @@
*/
public class SparkAnagram {
- public static void main(String[] args) throws Exception {
+ private SparkAnagram() {
+ }
+
+ public static void main(String[] args) throws Exception {
// STEP-1: handle input parameters
if (args.length != 3) {
diff --git a/src/main/java/org/dataalgorithms/bonus/cartesian/spark/TestCartesian.java b/src/main/java/org/dataalgorithms/bonus/cartesian/spark/TestCartesian.java
index a94300c4..19d8a586 100644
--- a/src/main/java/org/dataalgorithms/bonus/cartesian/spark/TestCartesian.java
+++ b/src/main/java/org/dataalgorithms/bonus/cartesian/spark/TestCartesian.java
@@ -15,7 +15,10 @@
*/
public class TestCartesian {
- static JavaSparkContext createJavaSparkContext() throws Exception {
+ private TestCartesian() {
+ }
+
+ static JavaSparkContext createJavaSparkContext() throws Exception {
SparkConf conf = new SparkConf();
conf.set("spark.serializer", "org.apache.spark.serializer.KryoSerializer");
//JavaSparkContext ctx = new JavaSparkContext("yarn-cluster", "mytestprogram", conf); // yarn-specific
diff --git a/src/main/java/org/dataalgorithms/bonus/charcount/spark/basic/CharCount.java b/src/main/java/org/dataalgorithms/bonus/charcount/spark/basic/CharCount.java
index 06129f0a..689907c0 100644
--- a/src/main/java/org/dataalgorithms/bonus/charcount/spark/basic/CharCount.java
+++ b/src/main/java/org/dataalgorithms/bonus/charcount/spark/basic/CharCount.java
@@ -20,7 +20,10 @@
*
*/
public class CharCount {
-
+
+ private CharCount() {
+ }
+
static void printArguments(String[] args) {
if ((args == null) || (args.length == 0)) {
System.out.println("no arguments passed...");
diff --git a/src/main/java/org/dataalgorithms/bonus/charcount/spark/inmapper/CharCountInMapperCombiner.java b/src/main/java/org/dataalgorithms/bonus/charcount/spark/inmapper/CharCountInMapperCombiner.java
index bc1e7b10..41ecbe00 100644
--- a/src/main/java/org/dataalgorithms/bonus/charcount/spark/inmapper/CharCountInMapperCombiner.java
+++ b/src/main/java/org/dataalgorithms/bonus/charcount/spark/inmapper/CharCountInMapperCombiner.java
@@ -21,6 +21,9 @@
*/
public class CharCountInMapperCombiner {
+ private CharCountInMapperCombiner() {
+ }
+
public static void main(String[] args) throws Exception {
if (args.length != 2) {
System.err.println("Usage: SparkCharCount