Skip to content

Commit

Permalink
refactored
Browse files Browse the repository at this point in the history
  • Loading branch information
ajithme committed Mar 13, 2019
1 parent 66d96c6 commit 345c3f1
Showing 1 changed file with 2 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ import org.apache.spark.ui.UIUtils
private[v1] class SqlListResource extends BaseAppResource {

@GET
def sqlList(): ExecutionSummary = {
def sqlList(): Seq[ExecutionData] = {
withUI { ui =>
val sqlStore = new SQLAppStatusStore(ui.store.store)
var executions = List[ExecutionData]()
Expand Down Expand Up @@ -66,7 +66,7 @@ private[v1] class SqlListResource extends BaseAppResource {
if (executions.size > 0) {
executions = executions.sortBy(x => x.id)
}
new ExecutionSummary(executions)
executions
}
}
}
Expand All @@ -79,5 +79,3 @@ class ExecutionData (val id : Long,
val runningJobs: Seq[Int],
val successJobs: Seq[Int],
val failedJobs: Seq[Int])

class ExecutionSummary (val sql: Seq[ExecutionData])

0 comments on commit 345c3f1

Please sign in to comment.