Skip to content

Commit 1f53a66

Browse files
committed
style
1 parent b4a7863 commit 1f53a66

File tree

2 files changed

+9
-4
lines changed

2 files changed

+9
-4
lines changed

core/src/main/scala/org/apache/spark/status/api/v1/AllStagesResource.scala

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -146,7 +146,9 @@ private[v1] object AllStagesResource {
146146
)
147147
}
148148

149-
def taskMetricDistributions(allTaskData: Iterable[TaskUIData], quantiles: Array[Double]): TaskMetricDistributions = {
149+
def taskMetricDistributions(
150+
allTaskData: Iterable[TaskUIData],
151+
quantiles: Array[Double]): TaskMetricDistributions = {
150152

151153
val rawMetrics = allTaskData.flatMap{_.taskMetrics}.toSeq
152154

@@ -186,7 +188,8 @@ private[v1] object AllStagesResource {
186188
}.metricOption
187189

188190
val shuffleReadMetrics =
189-
new MetricHelper[InternalShuffleReadMetrics, ShuffleReadMetricDistributions](_.shuffleReadMetrics) {
191+
new MetricHelper[InternalShuffleReadMetrics, ShuffleReadMetricDistributions](
192+
_.shuffleReadMetrics) {
190193
def build: ShuffleReadMetricDistributions = new ShuffleReadMetricDistributions(
191194
readBytes = m(_.totalBytesRead),
192195
readRecords = m(_.recordsRead),
@@ -199,7 +202,8 @@ private[v1] object AllStagesResource {
199202
}.metricOption
200203

201204
val shuffleWriteMetrics =
202-
new MetricHelper[InternalShuffleWriteMetrics, ShuffleWriteMetricDistributions](_.shuffleWriteMetrics) {
205+
new MetricHelper[InternalShuffleWriteMetrics, ShuffleWriteMetricDistributions](
206+
_.shuffleWriteMetrics) {
203207
def build: ShuffleWriteMetricDistributions = new ShuffleWriteMetricDistributions(
204208
writeBytes = m(_.shuffleBytesWritten),
205209
writeRecords = m(_.shuffleRecordsWritten),

core/src/main/scala/org/apache/spark/status/api/v1/OneStageResource.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -178,7 +178,8 @@ object TaskSorting extends JerseyEnum[TaskSorting] {
178178
DecreasingRuntime
179179
)
180180

181-
val alternateNames: Map[String, TaskSorting] = values.flatMap{x => x.alternateNames.map{_ -> x}}.toMap
181+
val alternateNames: Map[String, TaskSorting] =
182+
values.flatMap{x => x.alternateNames.map{_ -> x}}.toMap
182183

183184
override def fromString(s: String): TaskSorting = {
184185
alternateNames.find { case (k, v) =>

0 commit comments

Comments
 (0)