Home
last modified time | relevance | path

Searched refs:nodeIdsForInstances (Results 1 – 2 of 2) sorted by relevance

/dports/devel/spark/spark-2.1.1/mllib/src/main/scala/org/apache/spark/ml/tree/impl/
H A DNodeIdCache.scala65 var nodeIdsForInstances: RDD[Array[Int]], variable
78 private val canCheckpoint = nodeIdsForInstances.sparkContext.getCheckpointDir.nonEmpty
81 private val hadoopConf = nodeIdsForInstances.sparkContext.hadoopConfiguration
101 prevNodeIdsForInstances = nodeIdsForInstances
102 nodeIdsForInstances = data.zip(nodeIdsForInstances).map { case (point, ids) =>
119 nodeIdsForInstances.persist(StorageLevel.MEMORY_AND_DISK)
146 nodeIdsForInstances.checkpoint()
147 checkpointQueue.enqueue(nodeIdsForInstances)
H A DRandomForest.scala516 input.zip(nodeIdCache.get.nodeIdsForInstances).mapPartitions { points =>