olafurpg · olafurpg · Dec 17, 2016
diff --git a/repos/PredictionIO/core/src/main/scala/io/prediction/core/BaseAlgorithm.scala b/repos/PredictionIO/core/src/main/scala/io/prediction/core/BaseAlgorithm.scala
@@ -120,8 +120,9 @@ abstract class BaseAlgorithm[PD, M, Q, P]
     * @return Type signature of query
     */
   def queryClass: Class[Q] = {
-    val types = TypeResolver
-      .resolveRawArguments(classOf[BaseAlgorithm[PD, M, Q, P]], getClass)
+    val types = TypeResolver.resolveRawArguments(
+      classOf[BaseAlgorithm[PD, M, Q, P]],
+      getClass)
     types(2).asInstanceOf[Class[Q]]
   }
 }
diff --git a/repos/PredictionIO/core/src/main/scala/io/prediction/workflow/CreateServer.scala b/repos/PredictionIO/core/src/main/scala/io/prediction/workflow/CreateServer.scala
@@ -447,8 +447,9 @@ class ServerActor[Q, P](val args: ServerConfig,
   def actorRefFactory: ActorContext = context
 
   implicit val timeout = Timeout(5, TimeUnit.SECONDS)
-  val pluginsActorRef = context
-    .actorOf(Props(classOf[PluginsActor], args.engineVariant), "PluginsActor")
+  val pluginsActorRef = context.actorOf(
+    Props(classOf[PluginsActor], args.engineVariant),
+    "PluginsActor")
   val pluginContext = EngineServerPluginContext(log, args.engineVariant)
 
   def receive: Actor.Receive = runRoute(myRoute)

diff --git a/repos/PredictionIO/core/src/main/scala/io/prediction/workflow/JsonExtractor.scala b/repos/PredictionIO/core/src/main/scala/io/prediction/workflow/JsonExtractor.scala
@@ -77,8 +77,9 @@ object JsonExtractor {
   def paramToJson(extractorOption: JsonExtractorOption,
                   param: (String, Params)): String = {
     // to be replaced JValue needs to be done by Json4s, otherwise the tuple JValue will be wrong
-    val toBeReplacedJValue = JsonExtractor
-      .toJValue(JsonExtractorOption.Json4sNative, (param._1, null))
+    val toBeReplacedJValue = JsonExtractor.toJValue(
+      JsonExtractorOption.Json4sNative,
+      (param._1, null))
     val paramJValue = JsonExtractor.toJValue(extractorOption, param._2)
 
     compact(render(toBeReplacedJValue.replace(param._1 :: Nil, paramJValue)))
@@ -134,8 +135,9 @@ object JsonExtractor {
     val jValues = params.map {
       case (name, param) =>
         // to be replaced JValue needs to be done by Json4s, otherwise the tuple JValue will be wrong
-        val toBeReplacedJValue = JsonExtractor
-          .toJValue(JsonExtractorOption.Json4sNative, (name, null))
+        val toBeReplacedJValue =
+          JsonExtractor.toJValue(JsonExtractorOption.Json4sNative,
+                                 (name, null))
         val paramJValue = JsonExtractor.toJValue(extractorOption, param)
 
         toBeReplacedJValue.replace(name :: Nil, paramJValue)

diff --git a/repos/PredictionIO/core/src/test/scala/io/prediction/controller/MetricEvaluatorTest.scala b/repos/PredictionIO/core/src/test/scala/io/prediction/controller/MetricEvaluatorTest.scala
@@ -41,7 +41,9 @@ class MetricEvaluatorDevSuite extends FunSuite with SharedSparkContext {
           (EngineParams(),
            Seq((EmptyParams(), sc.parallelize(Seq((1, 0, 0), (2, 0, 0)))))))
 
-    val r = metricEvaluator
-      .evaluateBase(sc, Evaluation0, engineEvalDataSet, WorkflowParams())
+    val r = metricEvaluator.evaluateBase(sc,
+                                         Evaluation0,
+                                         engineEvalDataSet,
+                                         WorkflowParams())
   }
 }
diff --git a/repos/PredictionIO/core/src/test/scala/io/prediction/workflow/JsonExtractorSuite.scala b/repos/PredictionIO/core/src/test/scala/io/prediction/workflow/JsonExtractorSuite.scala
@@ -36,8 +36,9 @@ class JsonExtractorSuite extends FunSuite with Matchers {
     val json =
       """{"string": "query string", "optional": "optional string", "default": "d"}"""
 
-    val query = JsonExtractor
-      .extract(JsonExtractorOption.Json4sNative, json, classOf[ScalaQuery])
+    val query = JsonExtractor.extract(JsonExtractorOption.Json4sNative,
+                                      json,
+                                      classOf[ScalaQuery])
 
     query should be(ScalaQuery("query string", Some("optional string"), "d"))
   }
@@ -48,8 +49,9 @@ class JsonExtractorSuite extends FunSuite with Matchers {
 
     val json = """{"string": "query string"}"""
 
-    val query = JsonExtractor
-      .extract(JsonExtractorOption.Json4sNative, json, classOf[ScalaQuery])
+    val query = JsonExtractor.extract(JsonExtractorOption.Json4sNative,
+                                      json,
+                                      classOf[ScalaQuery])
 
     query should be(ScalaQuery("query string", None, "default"))
   }
@@ -61,8 +63,9 @@ class JsonExtractorSuite extends FunSuite with Matchers {
     val json =
       """{"string": "query string", "optional": null, "default": null}"""
 
-    val query = JsonExtractor
-      .extract(JsonExtractorOption.Json4sNative, json, classOf[ScalaQuery])
+    val query = JsonExtractor.extract(JsonExtractorOption.Json4sNative,
+                                      json,
+                                      classOf[ScalaQuery])
 
     query should be(ScalaQuery("query string", None, "default"))
   }
@@ -73,8 +76,9 @@ class JsonExtractorSuite extends FunSuite with Matchers {
     val json =
       """{"string": "query string", "optional": "optional string", "default": "d"}"""
 
-    val query = JsonExtractor
-      .extract(JsonExtractorOption.Json4sNative, json, classOf[ScalaQuery])
+    val query = JsonExtractor.extract(JsonExtractorOption.Json4sNative,
+                                      json,
+                                      classOf[ScalaQuery])
 
     query should be(ScalaQuery("query string", Some("optional string"), "d"))
   }
@@ -85,8 +89,9 @@ class JsonExtractorSuite extends FunSuite with Matchers {
 
     val json = """{"string": "query string"}"""
 
-    val query = JsonExtractor
-      .extract(JsonExtractorOption.Json4sNative, json, classOf[ScalaQuery])
+    val query = JsonExtractor.extract(JsonExtractorOption.Json4sNative,
+                                      json,
+                                      classOf[ScalaQuery])
 
     query should be(ScalaQuery("query string", None, "default"))
   }
@@ -97,8 +102,9 @@ class JsonExtractorSuite extends FunSuite with Matchers {
     val json =
       """{"string": "query string", "optional": null, "default": null}"""
 
-    val query = JsonExtractor
-      .extract(JsonExtractorOption.Json4sNative, json, classOf[ScalaQuery])
+    val query = JsonExtractor.extract(JsonExtractorOption.Json4sNative,
+                                      json,
+                                      classOf[ScalaQuery])
 
     query should be(ScalaQuery("query string", None, "default"))
   }
@@ -108,8 +114,9 @@ class JsonExtractorSuite extends FunSuite with Matchers {
       " value") {
 
     val json = """{"string": "query string"}"""
-    val query = JsonExtractor
-      .extract(JsonExtractorOption.Gson, json, classOf[ScalaQuery])
+    val query = JsonExtractor.extract(JsonExtractorOption.Gson,
+                                      json,
+                                      classOf[ScalaQuery])
 
     query should be(ScalaQuery("query string", null, null))
   }

diff --git a/repos/PredictionIO/data/src/main/scala/io/prediction/data/storage/Storage.scala b/repos/PredictionIO/data/src/main/scala/io/prediction/data/storage/Storage.scala
@@ -357,8 +357,9 @@ object Storage extends Logging {
     info("Test writing to Event Store (App Id 0)...")
     // use appId=0 for testing purpose
     eventsDb.init(0)
-    eventsDb
-      .insert(Event(event = "test", entityType = "test", entityId = "test"), 0)
+    eventsDb.insert(
+      Event(event = "test", entityType = "test", entityId = "test"),
+      0)
     eventsDb.remove(0)
     eventsDb.close()
   }

diff --git a/...xamples/experimental/scala-parallel-friend-recommendation/src/main/scala/DataSource.scala b/...xamples/experimental/scala-parallel-friend-recommendation/src/main/scala/DataSource.scala
@@ -66,8 +66,10 @@ class ForestFireSamplingDataSource(val dsp: FFSamplingDSParams)
 
   override def readTraining(sc: SparkContext): TrainingData = {
     val g = GraphLoader.edgeListFile(sc, dsp.graphEdgelistPath)
-    val sampled = Sampling
-      .forestFireSamplingInduced(sc, g, dsp.sampleFraction, dsp.geoParam)
+    val sampled = Sampling.forestFireSamplingInduced(sc,
+                                                     g,
+                                                     dsp.sampleFraction,
+                                                     dsp.geoParam)
 
     val identity = DeltaSimRankRDD.identityMatrix(sc, g.vertices.count())
     new TrainingData(sampled, identity)

diff --git a/...s/experimental/scala-parallel-friend-recommendation/src/main/scala/SimRankAlgorithm.scala b/...s/experimental/scala-parallel-friend-recommendation/src/main/scala/SimRankAlgorithm.scala
@@ -15,8 +15,10 @@ class SimRankAlgorithm(val ap: SimRankParams)
 
   def train(td: TrainingData): RDD[(Long, Double)] = {
     td.g.edges.count()
-    val scores = DeltaSimRankRDD
-      .compute(td.g, ap.numIterations, td.identityMatrix, ap.decay)
+    val scores = DeltaSimRankRDD.compute(td.g,
+                                         ap.numIterations,
+                                         td.identityMatrix,
+                                         ap.decay)
     scores
   }
 

diff --git a/repos/PredictionIO/tools/src/main/scala/io/prediction/tools/RunServer.scala b/repos/PredictionIO/tools/src/main/scala/io/prediction/tools/RunServer.scala
@@ -176,7 +176,9 @@ object RunServer extends Logging {
         .getOrElse(Nil) ++ Seq("--json-extractor",
                                ca.common.jsonExtractor.toString)
 
-    Runner
-      .runOnSpark("io.prediction.workflow.CreateServer", args, ca, jarFiles)
+    Runner.runOnSpark("io.prediction.workflow.CreateServer",
+                      args,
+                      ca,
+                      jarFiles)
   }
 }
diff --git a/repos/PredictionIO/tools/src/main/scala/io/prediction/tools/RunWorkflow.scala b/repos/PredictionIO/tools/src/main/scala/io/prediction/tools/RunWorkflow.scala
@@ -210,7 +210,9 @@ object RunWorkflow extends Logging {
          else
            Seq()) ++ Seq("--json-extractor", ca.common.jsonExtractor.toString)
 
-    Runner
-      .runOnSpark("io.prediction.workflow.CreateWorkflow", args, ca, jarFiles)
+    Runner.runOnSpark("io.prediction.workflow.CreateWorkflow",
+                      args,
+                      ca,
+                      jarFiles)
   }
 }
diff --git a/repos/PredictionIO/tools/src/main/scala/io/prediction/tools/console/Console.scala b/repos/PredictionIO/tools/src/main/scala/io/prediction/tools/console/Console.scala
@@ -872,8 +872,9 @@ object Console extends Logging {
       info(s"Uber JAR enabled. Putting ${core.getName} in lib.")
       val dst = new File("lib")
       dst.mkdir()
-      FileUtils
-        .copyFileToDirectory(coreAssembly(ca.common.pioHome.get), dst, true)
+      FileUtils.copyFileToDirectory(coreAssembly(ca.common.pioHome.get),
+                                    dst,
+                                    true)
     } else {
       if (new File("engine.json").exists()) {
         info(s"Uber JAR disabled. Making sure lib/${core.getName} is absent.")

diff --git a/repos/akka/akka-actor-tests/src/test/scala/akka/actor/ActorCreationPerfSpec.scala b/repos/akka/akka-actor-tests/src/test/scala/akka/actor/ActorCreationPerfSpec.scala
@@ -50,8 +50,8 @@ object ActorCreationPerfSpec {
         sender() ! Created
       case WaitForChildren ⇒
         context.children.foreach(_ ! IsAlive)
-        context
-          .become(waiting(context.children.size, sender()), discardOld = false)
+        context.become(waiting(context.children.size, sender()),
+                       discardOld = false)
     }
 
     def waiting(number: Int, replyTo: ActorRef): Receive = {
@@ -80,8 +80,8 @@ object ActorCreationPerfSpec {
         sender() ! Created
       case WaitForChildren ⇒
         context.children.foreach(_ ! IsAlive)
-        context
-          .become(waiting(context.children.size, sender()), discardOld = false)
+        context.become(waiting(context.children.size, sender()),
+                       discardOld = false)
     }
 
     def waiting(number: Int, replyTo: ActorRef): Receive = {

diff --git a/repos/akka/akka-actor-tests/src/test/scala/akka/actor/ActorDSLSpec.scala b/repos/akka/akka-actor-tests/src/test/scala/akka/actor/ActorDSLSpec.scala
@@ -87,8 +87,7 @@ class ActorDSLSpec extends AkkaSpec {
       try {
         for (_ ← 1 to 1000) i.receiver ! 0
         expectNoMsg(1 second)
-        EventFilter
-          .warning(start = "dropping message", occurrences = 1) intercept {
+        EventFilter.warning(start = "dropping message", occurrences = 1) intercept {
           i.receiver ! 42
         }
         expectMsgType[Warning]

diff --git a/repos/akka/akka-actor-tests/src/test/scala/akka/actor/ActorLookupSpec.scala b/repos/akka/akka-actor-tests/src/test/scala/akka/actor/ActorLookupSpec.scala
@@ -175,8 +175,7 @@ class ActorLookupSpec extends AkkaSpec with DefaultTimeout {
 
     "find actors by looking up their path" in {
       def check(looker: ActorRef, pathOf: ActorRef, result: ActorRef) {
-        Await
-          .result(looker ? LookupPath(pathOf.path), timeout.duration) should ===(
+        Await.result(looker ? LookupPath(pathOf.path), timeout.duration) should ===(
           result)
       }
       for {
@@ -238,8 +237,7 @@ class ActorLookupSpec extends AkkaSpec with DefaultTimeout {
     "find system-generated actors" in {
       def check(target: ActorRef) {
         for (looker ← all) {
-          Await
-            .result(looker ? LookupPath(target.path), timeout.duration) should ===(
+          Await.result(looker ? LookupPath(target.path), timeout.duration) should ===(
             target)
           Await.result(looker ? LookupString(target.path.toString),
                        timeout.duration) should ===(target)
@@ -288,15 +286,13 @@ class ActorLookupSpec extends AkkaSpec with DefaultTimeout {
       val a = expectMsgType[ActorRef]
       a.path.elements.head should ===("temp")
       Await.result(c2 ? LookupPath(a.path), timeout.duration) should ===(a)
-      Await
-        .result(c2 ? LookupString(a.path.toString), timeout.duration) should ===(
+      Await.result(c2 ? LookupString(a.path.toString), timeout.duration) should ===(
         a)
       Await.result(c2 ? LookupString(a.path.toStringWithoutAddress),
                    timeout.duration) should ===(a)
       Await.result(c2 ? LookupString("../../" + a.path.elements.mkString("/")),
                    timeout.duration) should ===(a)
-      Await
-        .result(c2 ? LookupString(a.path.toString + "/"), timeout.duration) should ===(
+      Await.result(c2 ? LookupString(a.path.toString + "/"), timeout.duration) should ===(
         a)
       Await.result(c2 ? LookupString(a.path.toStringWithoutAddress + "/"),
                    timeout.duration) should ===(a)

diff --git a/repos/akka/akka-actor-tests/src/test/scala/akka/actor/ActorSelectionSpec.scala b/repos/akka/akka-actor-tests/src/test/scala/akka/actor/ActorSelectionSpec.scala
@@ -70,10 +70,11 @@ class ActorSelectionSpec
     asked.correlationId should ===(selection)
 
     implicit val ec = system.dispatcher
-    val resolved = Await
-      .result(selection.resolveOne(timeout.duration).mapTo[ActorRef] recover {
+    val resolved = Await.result(
+      selection.resolveOne(timeout.duration).mapTo[ActorRef] recover {
         case _ ⇒ null
-      }, timeout.duration)
+      },
+      timeout.duration)
     Option(resolved) should ===(result)
 
     result
@@ -323,8 +324,7 @@ class ActorSelectionSpec
     "resolve one actor with explicit timeout" in {
       val s = system.actorSelection(system / "c2")
       // Java and Scala API
-      Await
-        .result(s.resolveOne(1.second.dilated), timeout.duration) should ===(
+      Await.result(s.resolveOne(1.second.dilated), timeout.duration) should ===(
         c2)
     }
 

diff --git a/repos/akka/akka-actor-tests/src/test/scala/akka/actor/ActorSystemSpec.scala b/repos/akka/akka-actor-tests/src/test/scala/akka/actor/ActorSystemSpec.scala
@@ -121,8 +121,9 @@ object ActorSystemSpec {
           mbox: Mailbox,
           hasMessageHint: Boolean,
           hasSystemMessageHint: Boolean): Boolean = {
-        val ret = super
-          .registerForExecution(mbox, hasMessageHint, hasSystemMessageHint)
+        val ret = super.registerForExecution(mbox,
+                                             hasMessageHint,
+                                             hasSystemMessageHint)
         doneIt.switchOn {
           TestKit.awaitCond(mbox.actor.actor != null, 1.second)
           mbox.actor.actor match {
@@ -305,8 +306,7 @@ class ActorSystemSpec
       implicit val timeout = Timeout((20 seconds).dilated)
       val waves = for (i ← 1 to 3)
         yield system.actorOf(Props[ActorSystemSpec.Waves]) ? 50000
-      Await
-        .result(Future.sequence(waves), timeout.duration + 5.seconds) should ===(
+      Await.result(Future.sequence(waves), timeout.duration + 5.seconds) should ===(
         Vector("done", "done", "done"))
     }
 

diff --git a/repos/akka/akka-actor-tests/src/test/scala/akka/actor/ConsistencySpec.scala b/repos/akka/akka-actor-tests/src/test/scala/akka/actor/ConsistencySpec.scala
@@ -11,8 +11,7 @@ object ConsistencySpec {
   val maxThreads = 2000
   val factor = 1.5d
   val threads =
-    ThreadPoolConfig
-      .scaledPoolSize(minThreads, factor, maxThreads) // Make sure we have more threads than cores
+    ThreadPoolConfig.scaledPoolSize(minThreads, factor, maxThreads) // Make sure we have more threads than cores
 
   val config = s"""
       consistency-dispatcher {

diff --git a/repos/akka/akka-actor-tests/src/test/scala/akka/actor/DeadLetterSupressionSpec.scala b/repos/akka/akka-actor-tests/src/test/scala/akka/actor/DeadLetterSupressionSpec.scala
@@ -32,8 +32,8 @@ class DeadLetterSupressionSpec extends AkkaSpec with ImplicitSender {
     system.eventStream.subscribe(deadListener.ref, classOf[DeadLetter])
 
     val suppressedListener = TestProbe()
-    system.eventStream
-      .subscribe(suppressedListener.ref, classOf[SuppressedDeadLetter])
+    system.eventStream.subscribe(suppressedListener.ref,
+                                 classOf[SuppressedDeadLetter])
 
     val allListener = TestProbe()
     system.eventStream.subscribe(allListener.ref, classOf[AllDeadLetters])
@@ -60,8 +60,8 @@ class DeadLetterSupressionSpec extends AkkaSpec with ImplicitSender {
     system.eventStream.subscribe(deadListener.ref, classOf[DeadLetter])
 
     val suppressedListener = TestProbe()
-    system.eventStream
-      .subscribe(suppressedListener.ref, classOf[SuppressedDeadLetter])
+    system.eventStream.subscribe(suppressedListener.ref,
+                                 classOf[SuppressedDeadLetter])
 
     val allListener = TestProbe()
     system.eventStream.subscribe(allListener.ref, classOf[AllDeadLetters])

diff --git a/repos/akka/akka-actor-tests/src/test/scala/akka/actor/FSMActorSpec.scala b/repos/akka/akka-actor-tests/src/test/scala/akka/actor/FSMActorSpec.scala
@@ -143,8 +143,7 @@ class FSMActorSpec
       Await.ready(transitionCallBackLatch, timeout.duration)
       Await.ready(lockedLatch, timeout.duration)
 
-      EventFilter
-        .warning(start = "unhandled event", occurrences = 1) intercept {
+      EventFilter.warning(start = "unhandled event", occurrences = 1) intercept {
         lock ! "not_handled"
         Await.ready(unhandledLatch, timeout.duration)
       }
@@ -172,8 +171,7 @@ class FSMActorSpec
         }
       })
       val name = fsm.path.toString
-      EventFilter
-        .error("Next state 2 does not exist", occurrences = 1) intercept {
+      EventFilter.error("Next state 2 does not exist", occurrences = 1) intercept {
         system.eventStream.subscribe(testActor, classOf[Logging.Error])
         fsm ! "go"
         expectMsgPF(1 second, hint = "Next state 2 does not exist") {