regan

run! run! run! happy runner! 我是奔跑的小米~

始于: 2017-02-15

四川省 成都市

发私信

30

总声望

12

次被推荐

0

粉丝

他的回答
排序:

0
投票

请问这种问题应该如何解决呢?执行命令:bin/spark-shell -master yarn-client出错:

Diagnostics: Container [pid=8536,containerID=container1478169271979000102_000001...

2017-02-19 22:43 回复了该问题
0
投票

scala API说明

B,A ,T都是Scala里面的抽象类型声明,可以理解为Java里的类型型参数。op是一个function,[]是表达类型参数的地方,:前面是方法的声明,后面是...

2017-02-19 22:40 回复了该问题
0
投票

请问spark的一些通用参数,不限于某个模块的参数从哪里可以查询得到呢

从源代码里面去搜索,要找什么就搜什么~,当然最直接的方法就是通过Spark官网

2017-02-19 22:35 回复了该问题
0
投票

spark读取hive udf问题

不能放在HDFS上面,--jars指的是本地的jar包

2017-02-19 22:33 回复了该问题
0
投票

各位大神,我想问下,我用sparkStreaming要怎么实现对所有滑动窗口的 wordCount的top10进行累计?

用状态更新函数updateStateByKey      

2017-02-19 22:32 回复了该问题

改版

反馈