Searched refs:getCheckpointFile (Results 1 – 16 of 16) sorted by relevance
129 if (checkpointQueue(1).getCheckpointFile.isDefined) {133 val path = new Path(old.getCheckpointFile.get)157 if (old.getCheckpointFile.isDefined) {159 val path = new Path(old.getCheckpointFile.get)
131 rdd.getCheckpointFile.foreach { checkpointFile =>154 assert(rdd.getCheckpointFile.nonEmpty, "RDD should have 2 checkpoint files")161 assert(rdd.getCheckpointFile.isEmpty, "RDD should not have any checkpoint files")
78 assert(operatedRDD.getCheckpointFile.nonEmpty)79 val recoveredRDD = sparkContext.checkpointFile[U](operatedRDD.getCheckpointFile.get)287 assert(rddWithPartitioner.getCheckpointFile.get.nonEmpty,292 val checkpointDir = new Path(rddWithPartitioner.getCheckpointFile.get)303 val newRDD = sc.checkpointFile[(Int, Int)](rddWithPartitioner.getCheckpointFile.get)341 assert(sc.checkpointFile[Int](parCollection.getCheckpointFile.get).collect() === result)359 assert(sc.checkpointFile[String](blockRDD.getCheckpointFile.get).collect() === result)
53 val checkpointFiles = dstream.generatedRDDs.filter(_._2.getCheckpointFile.isDefined)54 .map(x => (x._1, x._2.getCheckpointFile.get))
84 override def getCheckpointFile: Option[String] = {85 partitionsRDD.getCheckpointFile
75 Seq(vertices.getCheckpointFile, replicatedVertexView.edges.getCheckpointFile).flatMap {
95 data.getCheckpointFile.map(x => x)
52 override val getCheckpointFile: Option[String] = Some(checkpointPath)
1639 def getCheckpointFile: Option[String] = { method
596 def getCheckpointFile(): Optional[String] = { method597 JavaUtils.optionToOptional(rdd.getCheckpointFile)
351 emptyStateRDD.getCheckpointFile.get)
367 self.assertTrue(flatMappedRDD.getCheckpointFile() is None)375 os.path.dirname(os.path.dirname(flatMappedRDD.getCheckpointFile())))382 self.assertTrue(flatMappedRDD.getCheckpointFile() is None)388 self.assertTrue(flatMappedRDD.getCheckpointFile() is not None)389 recovered = self.sc._checkpointFile(flatMappedRDD.getCheckpointFile(),
298 def getCheckpointFile(self): member in RDD304 checkpointFile = self._jrdd.rdd().getCheckpointFile()
738 previousCheckpointFile = itemFactors.getCheckpointFile752 previousCheckpointFile = itemFactors.getCheckpointFile
1476 assertTrue(rdd.getCheckpointFile().isPresent()); in checkpointAndRestore()1477 JavaRDD<Integer> recovered = sc.checkpointFile(rdd.getCheckpointFile().get()); in checkpointAndRestore()