Added comment

src/main/scala/com/rklick/graphx/context/GraphXProcess.scala

@@ -19,6 +19,7 @@ trait GraphXProcess {
 
 
   /**
+    * Create edges from dataframe
     *
     * @param df
     * @param graph
@@ -35,6 +36,7 @@ trait GraphXProcess {
   }
 
   /**
+    * Create vertices from dataframe
     *
     * @param df    The DataFrame
     * @param graph The domain.GraphComponent
@@ -48,6 +50,7 @@ trait GraphXProcess {
   }
 
   /**
+    * Process graph
     *
     * @param df             The DataFrame
     * @param graphComponent The domain.GraphComponent
@@ -67,6 +70,7 @@ trait GraphXProcess {
   }
 
   /**
+    * Apply graph algorithm & find the output
     *
     * @param graph
     * @param primaryIndex
@@ -75,20 +79,16 @@ trait GraphXProcess {
   def applyGraphAlgorithm(graph: Graph[String, String], primaryIndex: String): Either[String, GraphRDD] = {
     try {
       //Page rank Algorithm
-      //val pageRankStart = System.currentTimeMillis()
       val pageRankGraph = PageRank.run(graph, 1, 0.001)
-      //println(s"End Page Rank GraphX at :::::${System.currentTimeMillis() - pageRankStart}") */
       // Page Rank join with graph object
       val graphWithPageRank = graph.outerJoinVertices(pageRankGraph.vertices) {
         case (id, attr, Some(pr)) => (pr, attr)
         case (id, attr, None) => (0.0, attr)
       }
 
       //Triangle Count Algorithm
-      //val triangleStart = System.currentTimeMillis()
       val triangleComponent = graph.partitionBy(PartitionStrategy.RandomVertexCut)
         .triangleCount().vertices
-      //println(s"End triangleComponent GraphX at :::::${System.currentTimeMillis() - triangleStart}") */
 
       //Triangle Count join with page rank graph object
       val triByGraph = graphWithPageRank.outerJoinVertices(triangleComponent) {
@@ -97,9 +97,7 @@ trait GraphXProcess {
       }
 
       //Connected Component Algorithm
-      //val connectedStart = System.currentTimeMillis()
       val cComponent = ConnectedComponents.run(graph).vertices
-      //println(s"End cComponent GraphX at :::::${System.currentTimeMillis() - connectedStart}")
       //Connected Component join with triangle component graph object
       val ccByGraph = triByGraph.outerJoinVertices(cComponent) {
         case (id, (rank, tri, attr), Some(cc)) => (rank, tri, cc, attr)

src/main/scala/com/rklick/graphx/process/GraphTest.scala

@@ -0,0 +1,8 @@
+package com.rklick.graphx.process
+
+/**
+  * Created by supriya on 23/2/16.
+  */
+object GraphTest {
+
+}

src/main/scala/com/rklick/graphx/process/GraphXMainProcess.scala

@@ -12,7 +12,7 @@ import scala.util.{Left, Right}
   */
 object GraphXMainProcess extends GraphXProcess {
 
-  val sqlContext = SparkCommon.sparkSqlContext
+  val sqlContext = SparkCommon.sqlContext
 
   /**
     *
@@ -24,9 +24,9 @@ object GraphXMainProcess extends GraphXProcess {
     val df = sqlContext.read.format("csv").options(SCHEMA_OPTIONS).load(path)
     val graphComponent = GraphComponent("ID", "User", "Relationship", "RelationId")
     processGraph(df, graphComponent) match {
-      case Right(data) => logger.info(s"GraphX process successfully completed.")
+      case Right(data) => println(s"GraphX process successfully completed.")
         sqlContext.sparkContext.stop()
-      case Left(error) => logger.error(s"Error during graphX:::${error}")
+      case Left(error) => println(s"Error during graphX:::${error}")
         sqlContext.sparkContext.stop()
     }
   }

src/main/scala/com/rklick/graphx/utils/SparkCommon.scala

@@ -15,6 +15,6 @@ object SparkCommon {
   }
 
   lazy val sparkContext = new SparkContext(conf)
-  lazy val sparkSqlContext = SQLContext.getOrCreate(sparkContext)
+  lazy val sqlContext = SQLContext.getOrCreate(sparkContext)
 
 }