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

JavaRDD.treeReduce介绍

暂无

代码示例

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

@Test
public void treeReduce() {
 JavaRDD<Integer> rdd = sc.parallelize(Arrays.asList(-5, -4, -3, -2, -1, 1, 2, 3, 4), 10);
 Function2<Integer, Integer, Integer> add = (a, b) -> a + b;
 for (int depth = 1; depth <= 10; depth++) {
  int sum = rdd.treeReduce(add, depth);
  assertEquals(-5, sum);
 }
}

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

@Test
public void treeReduce() {
 JavaRDD<Integer> rdd = sc.parallelize(Arrays.asList(-5, -4, -3, -2, -1, 1, 2, 3, 4), 10);
 Function2<Integer, Integer, Integer> add = (a, b) -> a + b;
 for (int depth = 1; depth <= 10; depth++) {
  int sum = rdd.treeReduce(add, depth);
  assertEquals(-5, sum);
 }
}

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

@Test
public void treeReduce() {
 JavaRDD<Integer> rdd = sc.parallelize(Arrays.asList(-5, -4, -3, -2, -1, 1, 2, 3, 4), 10);
 Function2<Integer, Integer, Integer> add = (a, b) -> a + b;
 for (int depth = 1; depth <= 10; depth++) {
  int sum = rdd.treeReduce(add, depth);
  assertEquals(-5, sum);
 }
}