select 对应map
join对应union intersection 或join
group对应groupByKey
国内首批大数据从业者，就职于金山，担任大数据团队核心研发工程师
最近话题
- 海牛大数据 mapreduce 全套视频免费下载
- 海牛大数据 java 高级部分全套精品课程视频
- 海牛大数据 Linux 全套视频免费下载
- 海牛大数据 MySQL 全套视频
- 海牛大数据 ETL 项目实战视频
- 海牛大数据 hadoop 实战视频
- [公告] 社区表情包已到达
- scala 基础 5
- scala 基础 4
- scala 基础 3
- scala 基础 2
- scala 环境安装与基本语法
- 海牛部落 spark 系列教程（四十六）：kafka 介绍与安装、kafka-java-API、spark-streaming-kafka、cogroup
- 海牛部落 spark 系列教程（四十三）：spark-hbase
- 海牛部落 spark 系列教程（四十五）：Spark 的 updateStateByKey、Windows、checkpoint、updateStateByKey_...
- 海牛部落 spark 系列教程（四十四）：spark-hbase_bulkload、spark 程序集群运行、spark-streaming
- 海牛部落 spark 系列教程（四十二）：spark-sql 编程
- 海牛部落 spark 系列教程（四十一）：spark-sql
- 海牛部落 spark 系列教程（四十）：RDD 编程二次排序、mapjoin
- 海牛部落 spark 系列教程（三十九）：RDD 编程基础使用
最新评论
- sparksqlselect.join.group 是会对应生成什么样的 rdd.再划分 stage 的？
- spark-phoenix 一直出现一个 bug?
- scan 查出来的 row 是 rowkey 吗？
- spark 读取 MongoDB，进行计算，MongoDB 游标超时如何解决？
- 求 spark 大神帮忙看下，用 scala 操作 dataframe 转 rdd 的时候，row 对象的取值问题？
- Hive 为什么不支持日期格式？
- kafka 的顺序读写到底是什么？
- flink job 的用户 jar 包是什么时候上传到 flink 集群的？
- spark dataframe coalesce 设置？
- 请教个问题 这是用 python 写的一个分词程序，截图里面红框是 熵值 得分 熵值是越大越好吗？
- 如何用 PYTHON 在不调用库的情况下实现 ping 命令?
- python 查找 dataframe 的目标索引，后利用 For 循环删除行为什么不好使？
- 请问我哪俩个地方出问题了？
- Error: module 'wave' has no attribute 'open'如何如何解决？
- Pycharm 中 tensorflow 无法运行？
- python 爬虫，使用 scrappy-Redis 框架中 RedisCrawlSpider 怎么登陆？
- python pivot_table 后，如何计算某一列长度？
- spark.shuffle.file.buffer 属于 spark 内存里面的哪一部分？
- phoenix 怎么做时间加减？类似于 MySQL 里面的 interval 1 day
- Phoenix 加盐表，sqoop 导入数据到 HBase 该表，数据是否可以自动加盐？