Searched refs:nodeIdsForInstances (Results 1 – 2 of 2) sorted by relevance
65 var nodeIdsForInstances: RDD[Array[Int]], variable78 private val canCheckpoint = nodeIdsForInstances.sparkContext.getCheckpointDir.nonEmpty81 private val hadoopConf = nodeIdsForInstances.sparkContext.hadoopConfiguration101 prevNodeIdsForInstances = nodeIdsForInstances102 nodeIdsForInstances = data.zip(nodeIdsForInstances).map { case (point, ids) =>119 nodeIdsForInstances.persist(StorageLevel.MEMORY_AND_DISK)146 nodeIdsForInstances.checkpoint()147 checkpointQueue.enqueue(nodeIdsForInstances)
516 input.zip(nodeIdCache.get.nodeIdsForInstances).mapPartitions { points =>