[GAE-Java] GRAPE JDK support Spark local mode for graphx (#2216)

analytical_engine/java/grape-graphx/src/main/scala/org/apache/spark/scheduler/cluster/ExecutorInfoHelper.scala

@@ -42,9 +42,10 @@ object ExecutorInfoHelper extends Logging {
         val executorDataMap = getExecutorDataMapReflect(field, coarseGrainedSchedulerBackend)
         executorDatMapToId2Host(executorDataMap)
       }
+      // For local mode, there will be only one executor, i.e. driver & executor.
       case local: LocalSchedulerBackend => {
         val res = new mutable.HashMap[String, String]()
-        res.+=((InetAddress.getLocalHost.getHostName, "0"))
+        res.+=(("0", InetAddress.getLocalHost.getHostName))
         res
       }
     }
@@ -66,6 +67,13 @@ object ExecutorInfoHelper extends Logging {
         executorDataMapToHost2Id(executorDataMap)
       }
 
+      // For local mode, there will be only one executor, i.e. driver & executor.
+      case local: LocalSchedulerBackend => {
+        val res = new mutable.HashMap[String, ArrayBuffer[String]]()
+        res.+=((InetAddress.getLocalHost.getHostName, new ArrayBuffer[String].+=("driver")))
+        res
+      }
+
       case _ => throw new IllegalStateException("Unsupported backend")
     }
   }
@@ -87,6 +95,13 @@ object ExecutorInfoHelper extends Logging {
         executorDataMap.map(t => (t._1, t._2.freeCores))
       }
 
+      case localSchedulerBackend: LocalSchedulerBackend => {
+        val numCores = getNumCoresFromLocalBackend(localSchedulerBackend)
+        val res      = new mutable.HashMap[String, Int]
+        res.+=(("driver", numCores))
+        res
+      }
+
       case _ => throw new IllegalStateException("Unsupported backend")
     }
   }
@@ -107,6 +122,10 @@ object ExecutorInfoHelper extends Logging {
     field
   }
 
+  def getNumCoresFromLocalBackend(backend: LocalSchedulerBackend): Int = {
+    backend.totalCores
+  }
+
   def getExecutorDataMapReflect(
       field: Field,
       castedBackend: CoarseGrainedSchedulerBackend