commit 290d67b71856b9f4a3f9c6901d2d6bf364094242
author Shivansh <shiv4nsh@gmail.com> Fri Nov 04 00:38:12 2016 +0530
committer Shivansh <shiv4nsh@gmail.com> Fri Nov 04 00:38:12 2016 +0530
tree dedb1586af5dace0f9dafbce572fff6006d7742d
parent 820f2b10d92d67a46efc0a19e619de5d16705cd2

Removed scalastyle in Ensemble

fey-core/src/main/scala/org/apache/iota/fey/Ensemble.scala

diff --git a/fey-core/src/main/scala/org/apache/iota/fey/Ensemble.scala b/fey-core/src/main/scala/org/apache/iota/fey/Ensemble.scala
index a606217..2ce13ff 100644
--- a/fey-core/src/main/scala/org/apache/iota/fey/Ensemble.scala
+++ b/fey-core/src/main/scala/org/apache/iota/fey/Ensemble.scala
@@ -33,6 +33,7 @@
   import Ensemble._
 
   val monitoring_actor = FEY_MONITOR.actorRef
+  val DEFAULT_NULL = null
   var performers_metadata: Map[String, Performer] = Map.empty[String, Performer]
   var connectors: Map[String,Array[String]] = Map.empty[String,Array[String]]
   var performer: Map[String,ActorRef] = Map.empty[String,ActorRef]
@@ -163,13 +164,13 @@
     */
   private def createFeyActor(performerID: String, connectionIDs: Array[String], tmpActors:HashMap[String, ActorRef]):(String, ActorRef) = {
     if(!tmpActors.contains(performerID)){
-      val performerInfo = performers_metadata.getOrElse(performerID, null)
-      if(performerInfo != null){
+      val performerInfo = performers_metadata.getOrElse(performerID, DEFAULT_NULL)
+      if (Option(performerInfo).isDefined) {
         val connections: Map[String, ActorRef] = connectionIDs.map(connID => {
           createFeyActor(connID, connectors.getOrElse(connID,Array.empty),tmpActors)
         }).toMap
 
-        var actor:ActorRef = null
+        var actor: ActorRef = DEFAULT_NULL
         val actorProps = getPerformer(performerInfo, connections)
         if(performerInfo.autoScale) {
 
@@ -204,6 +205,7 @@
 
   /**
     * Creates actor props based on JSON configuration
+    *
     * @param performerInfo Performer object
     * @param connections connections
     * @return Props of actor based on JSON config
@@ -271,11 +273,11 @@
     * @return map of connectors
     */
   def extractConnections(connectors: List[JsObject]): Map[String,Array[String]] = {
-    connectors.map(connector => {
+    connectors.flatMap(connector => {
       connector.keys.map(key => {
         (key, (connector \ key).as[List[String]].toArray)
       }).toMap
-    }).flatten.toMap
+    }).toMap
   }
 
   /**
@@ -296,12 +298,18 @@
       if(lowerBound > upperBound){
         throw new IllegalArgumentException(" Could not define performer. Autoscale param: Lower bound greater than upper bound")
       }
-      val threshold: Double = if (autoScale && (performer \ PERFORMER_AUTO_SCALE).as[JsObject].keys.contains(PERFORMER_BACKOFF_THRESHOLD))
-        (performer \ PERFORMER_AUTO_SCALE \ PERFORMER_BACKOFF_THRESHOLD).as[Double] else 0.3
-      val roundRobin: Boolean = if (autoScale && (performer \ PERFORMER_AUTO_SCALE).as[JsObject].keys.contains(PERFORMER_ROUND_ROBIN))
-        (performer \ PERFORMER_AUTO_SCALE \ PERFORMER_ROUND_ROBIN).as[Boolean] else false
-
-
+      val threshold: Double = if (autoScale && (performer \ PERFORMER_AUTO_SCALE).as[JsObject].keys.contains(PERFORMER_BACKOFF_THRESHOLD)) {
+        (performer \ PERFORMER_AUTO_SCALE \ PERFORMER_BACKOFF_THRESHOLD).as[Double]
+      }
+      else {
+        0.3
+      }
+      val roundRobin: Boolean = if (autoScale && (performer \ PERFORMER_AUTO_SCALE).as[JsObject].keys.contains(PERFORMER_ROUND_ROBIN)) {
+        (performer \ PERFORMER_AUTO_SCALE \ PERFORMER_ROUND_ROBIN).as[Boolean]
+      }
+      else {
+        false
+      }
       val jarName: String = (performer \ SOURCE \ SOURCE_NAME).as[String]
       val classPath: String = (performer \ SOURCE \ SOURCE_CLASSPATH).as[String]
       val params:Map[String,String] = getMapOfParams((performer \ SOURCE \ SOURCE_PARAMS).as[JsObject])