一般是这样处理
javaDstream.foreachRDD(new VoidFunction<JavaRDD>() {
public void call(JavaRDD o) throws Exception {
System.out.println("自定义的处理逻辑");
}
});
- JavaDStream 转为 JavaRDD？
- JavaDStream 转为 JavaRDD？
- sparksql 读取 kafka 报错？
- spark jobserver 需要另外安装的吗，该怎么安装，它的作用是什么?
-
信息被删除或无权限查看
- 测试工具 TeraSort 如何支持可压缩？？
- cdh 集群 python3 用 pyhive 操作 hive，请问如何能够实现呢？
- cdh 集群 python3 用 pyhive 操作 hive，请问如何能够实现呢？
- Python3 操作 hive，pip 安装 sasl 失败，已经安装 gcc，请问如何能够完成第三方库的安装？
-
信息被删除或无权限查看
- 为什么 mapreduce 压缩失效？
- 执行命令 yum install -y gcc gcc-c++ pcre-devel zlib-devel 出现如下错误？求大佬解决
- hive 查询经过压缩后有 100GB 的.gz 格式的文件数据，使用 select * from 能够查询出来，为何不能做计算？
- storm topology 作业的监控和告警，有什么好的方案？
- spark Dataset.createTempView 作用是什么？