scala syle

core/src/main/scala/org/apache/spark/executor/ExecutorMetrics.scala

@@ -43,7 +43,7 @@ class ExecutorMetrics extends Serializable {
   }
 
   // for test only
-  def metricsDetails = {
+  def metricsDetails: (String, Long, Long, Long) = {
     (hostname, transportMetrics.timeStamp, transportMetrics.onHeapSize,
       transportMetrics.offHeapSize)
   }

core/src/test/scala/org/apache/spark/ui/memory/MemoryListenerSuite.scala

@@ -226,12 +226,12 @@ class MemoryListenerSuite extends SparkFunSuite with LocalSparkContext {
 }
 
 object MemoryListenerSuite {
-  def createStageStartEvent(stageId: Int) = {
+  def createStageStartEvent(stageId: Int): SparkListenerStageSubmitted = {
     val stageInfo = new StageInfo(stageId, 0, stageId.toString, 0, Seq.empty, Seq.empty, "")
     SparkListenerStageSubmitted(stageInfo)
   }
 
-  def createStageEndEvent(stageId: Int, failed: Boolean = false) = {
+  def createStageEndEvent(stageId: Int, failed: Boolean = false): SparkListenerStageCompleted = {
     val stageInfo = new StageInfo(stageId, 0, stageId.toString, 0, Seq.empty, Seq.empty, "")
     if (failed) {
       stageInfo.failureReason = Some("Failed!")
@@ -241,7 +241,7 @@ object MemoryListenerSuite {
 
   def createExecutorMetricsUpdateEvent(
       execId: String,
-      executorMetrics: ExecutorMetrics) = {
+      executorMetrics: ExecutorMetrics): SparkListenerExecutorMetricsUpdate = {
     SparkListenerExecutorMetricsUpdate(execId, executorMetrics, Seq.empty)
   }
 
@@ -255,4 +255,4 @@ object MemoryListenerSuite {
     execMetrics.setTransportMetrics(TransportMetrics(timeStamp, onHeapSize, offHeapSize))
     execMetrics
   }
-}
+}