override def accept()

in scala-repl/src/main/scala/spark/ztools.sc [843:856]


    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"))
        })
    }