栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

Spark Transformation算子->subtract

Spark Transformation算子->subtract

取两个数据集的差集,结果 RDD 的分区数与 subtract 前面的 RDD 的 分区数一致。

  1. java
package transformations;

import org.apache.spark.SparkConf;
import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.JavaSparkContext;

import java.util.Arrays;


public class SubtractTest {
    public static void main(String[] args) {
        JavaSparkContext context = new JavaSparkContext(
                new SparkConf()
                        .setMaster("local")
                        .setAppName("subtract")
        );
        context.setLogLevel("Error");
        JavaRDD rdd = context.parallelize(Arrays.asList("a", "b", "c", "e", "f"),2);
        JavaRDD rdd1 = context.parallelize(Arrays.asList("a", "b", "g", "h", "f"),3);
        JavaRDD subtract = rdd.subtract(rdd1);
        System.out.println("rdd partition length = "+rdd.getNumPartitions());
        System.out.println("rdd1 partition length = "+rdd1.getNumPartitions());
        System.out.println("subtract partition length = "+subtract.getNumPartitions());
        subtract.foreach(e-> System.out.print(e+"t"));
    }
}


2. scala

package transformation

import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}


object SubtractTest {
  def main(args: Array[String]): Unit = {
    val context = new SparkContext(
      new SparkConf()
        .setMaster("local")
        .setAppName("subtract")
    )
    context.setLogLevel("Error")
    val rdd: RDD[String] = context.parallelize(Array[String]("a", "b", "c", "e", "f"))
    val rdd1: RDD[String] = context.parallelize(Array[String]("a", "b", "g", "h", "f"))
    val value: RDD[String] = rdd.subtract(rdd1)
    value.foreach(print)
  }
}

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/650777.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号