From f9771690a698b6ce5d29eb36b38bbeb498d1af0d Mon Sep 17 00:00:00 2001
From: Tathagata Das <tathagata.das1565@gmail.com>
Date: Mon, 23 Dec 2013 11:32:26 -0800
Subject: [PATCH] Minor formatting fixes.
---
.../org/apache/spark/streaming/scheduler/BatchInfo.scala | 9 ++++-----
1 file changed, 4 insertions(+), 5 deletions(-)
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/BatchInfo.scala b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/BatchInfo.scala
index e3fb07624e..4e8d07fe92 100644
--- a/streaming/src/main/scala/org/apache/spark/streaming/scheduler/BatchInfo.scala
+++ b/streaming/src/main/scala/org/apache/spark/streaming/scheduler/BatchInfo.scala
@@ -26,7 +26,6 @@ import org.apache.spark.streaming.Time
* the streaming scheduler queue
* @param processingStartTime Clock time of when the first job of this batch started processing
* @param processingEndTime Clock time of when the last job of this batch finished processing
- *
*/
case class BatchInfo(
batchTime: Time,
@@ -48,9 +47,9 @@ case class BatchInfo(
*/
def processingDelay = processingEndTime.zip(processingStartTime).map(x => x._1 - x._2).headOption
- /**
- * Time taken for all the jobs of this batch to finish processing from the time they
- * were submitted. Essentially, it is `processingDelay` + `schedulingDelay`.
- */
+ /**
+ * Time taken for all the jobs of this batch to finish processing from the time they
+ * were submitted. Essentially, it is `processingDelay` + `schedulingDelay`.
+ */
def totalDelay = schedulingDelay.zip(processingDelay).map(x => x._1 + x._2).headOption
}
--
GitLab