diff options
author | Tathagata Das <tathagata.das1565@gmail.com> | 2013-12-23 11:32:26 -0800 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2013-12-23 11:32:26 -0800 |
commit | f9771690a698b6ce5d29eb36b38bbeb498d1af0d (patch) | |
tree | 25e1e159304f05b4ef37d1989cfd2031597f179f /streaming | |
parent | dc3ee6b6122229cd99a133baf10a46dac2f7e9e2 (diff) | |
download | spark-f9771690a698b6ce5d29eb36b38bbeb498d1af0d.tar.gz spark-f9771690a698b6ce5d29eb36b38bbeb498d1af0d.tar.bz2 spark-f9771690a698b6ce5d29eb36b38bbeb498d1af0d.zip |
Minor formatting fixes.
Diffstat (limited to 'streaming')
-rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/scheduler/BatchInfo.scala | 9 |
1 files 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 } |