override def accept()

in scala-repl/src/main/scala/spark/handlers/RDDHandler.scala [26:39]


  override def accept(obj: Any): Boolean = obj.isInstanceOf[RDD[_]]

  override def handle(scalaInfo: ScalaVariableInfo, loopback: Loopback, depth: Int): mutable.Map[String, Any] = withJsonObject {
    json =>
      val obj = scalaInfo.value
      val rdd = obj.asInstanceOf[RDD[_]]
      json += (ResNames.VALUE -> withJsonObject { value =>
        value += ("getNumPartitions()" -> wrap(rdd.getNumPartitions, "Int"))
        value += ("name" -> wrap(rdd.name, "String"))
        value += ("id" -> wrap(rdd.id, "Int"))
        value += ("partitioner" -> wrap(rdd.partitioner.toString, "Option[org.apache.spark.Partitioner]"))
        value += ("getStorageLevel()" -> wrap(rdd.getStorageLevel.toString, "org.apache.spark.storage.StorageLevel"))
      })
  }