java实现spark常用算子之Take
2024-08-31 07:16:46
import org.apache.spark.SparkConf;
import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.JavaSparkContext; import java.util.Arrays;
import java.util.List; /**
* take(n)
* 将RDD中的前多少数据返回过来,返回结果为数据形式
*
*/
public class TakeOperator {
public static void main(String[] args){
SparkConf conf = new SparkConf().setMaster("local").setAppName("take");
JavaSparkContext sc = new JavaSparkContext(conf);
List<String> list = Arrays.asList("w1","w2","w3","w4","w5","w6");
JavaRDD<String> listRdd = sc.parallelize(list);
List<String> result = listRdd.take(3);
System.err.println(result.toString());
}
}
微信扫描下图二维码加入博主知识星球,获取更多大数据、人工智能、算法等免费学习资料哦!
最新文章
- linux下ftp配置文件详解
- (原创)如何使用selenium 驱动chrome浏览器并且打开方式为手机模式-转载请注明出处
- LINUX 下Open cv练习使用小记(1)
- test python
- code manager tools TotoiseSVN安装及使用
- Android OpenGL ES(一)----必备知识
- Android 使用MediaRecorder录音
- 在 Ubuntu 16.04 中安装谷歌 Chrome 浏览器
- CSDN总结的面试中的十大算法
- AndroidUI 视图动画-缩放动画效果 (ScaleAnimation)
- HDU 3307 Description has only two Sentences
- 聊聊高并发(二十五)解析java.util.concurrent各个组件(七) 理解Semaphore
- Vim 配置Markdown
- 极光推送CTO黄鑫:技术人员要建立自己的知识图谱
- Ef+T4模板实现代码快速生成器
- 带着萌新看springboot源码04
- LOJ 10002 喷水装置 未完
- VMware 无法打开内核设备 \\.\Global\vmx86
- 一脸懵逼搭建Zookeeper分布式集群
- C_求两个日期相隔的天数(闰年)