Fun with Scala

fun.scala

  @GET
  @Path("/groupHttpTimeSeries")
  def getTimeSeriesForAllGroups(@QueryParam("startTime") startDateStr : String,
                                @QueryParam("endTime") endDateStr : String,
                                @QueryParam("type") typeStr : String,
                                @QueryParam("period") periodInt : Int) = {
    val buf = httpTimeSeriesDao.getTimeSeriesForAllGroups(startDateStr, endDateStr, typeStr, periodInt)    // Group by the unique fields
    val timeEntries = buf.map(x => scala.collection.mutable.Map[String,Any](
        "type" -> x.get("type"),
        "groupField" -> x.get("groupField"),
        "periodSeconds" -> x.get("periodSeconds"),
        "dateTime" -> x.get("dateTime"),
        "bitsInPerSecond" -> scala.math.BigDecimal(x.get("bitsInPerSecond").get.asInstanceOf[Double]).setScale(4, scala.math.BigDecimal.RoundingMode.HALF_UP).toDouble,
        "bitsOutPerSecond" ->scala.math.BigDecimal(x.get("bitsOutPerSecond").get.asInstanceOf[Double]).setScale(4, scala.math.BigDecimal.RoundingMode.HALF_UP).toDouble,
        "connectionsPerSecond" -> scala.math.BigDecimal(x.get("connectionsPerSecond").get.asInstanceOf[Double]).setScale(4, scala.math.BigDecimal.RoundingMode.HALF_UP).toDouble
      ))
    val groups = timeEntries.groupBy(x => scala.collection.immutable.Map[String, Option[Any]](
      "type" -> x.get("type"),
      "groupField" -> x.get("groupField"),
      "periodSeconds" -> x.get("periodSeconds")
    ))
    var finalGroups = ListBuffer[Map[String, Any]]()
    groups.foreach {
      case(jsonKey,group) =>
        finalGroups += Map("count" -> timeEntries.length, "group" -> jsonKey, "timeSeries" -> group.map(x => Option[Any](  scala.collection.mutable.Map[String,Any](
        "dateTime" -> x.get("dateTime"),
        "bitsInPerSecond" -> x.get("bitsInPerSecond"),
        "bitsOutPerSecond" -> x.get("bitsOutPerSecond"),
        "connectionsPerSecond" -> x.get("connectionsPerSecond")
        ))))
    }

    val a = mapper.writeValueAsString(finalGroups)
    Response.ok(a).build()
  }