本文整理了Java中org.apache.spark.rdd.RDD.cache方法的一些代码示例，展示了RDD.cache的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。RDD.cache方法的具体详情如下：
包路径：org.apache.spark.rdd.RDD
类名称：RDD
方法名：cache

RDD.cache介绍

暂无

代码示例

代码示例来源：origin: OryxProject/oryx

trainingRatingDataRDD.cache();
MatrixFactorizationModel model = als.run(trainingRatingDataRDD);
trainingRatingDataRDD.unpersist(false);

代码示例来源：origin: apache/crunch

Set<Target> targets = outputTargets.get(e.getKey());
if (targets.size() > 1) {
 rdd.rdd().cache();

代码示例来源：origin: org.apache.crunch/crunch-spark

Set<Target> targets = outputTargets.get(e.getKey());
if (targets.size() > 1) {
 rdd.rdd().cache();

代码示例来源：origin: Stratio/deep-spark

Assert.assertEquals(WORD_COUNT_SPECTED.longValue(), ((Long) outputRDDEntity.cache().count()).longValue());

代码示例来源：origin: Stratio/deep-spark

Assert.assertEquals(((Long) outputRDDEntity.cache().count()).longValue(),
      WORD_COUNT_SPECTED.longValue());
} finally {

代码示例来源：origin: ai.h2o/sparkling-water-ml

);
RDD<LabeledPoint> training = points._1();
training.cache();