我被困了几天,因为我想根据我对hive的查询创建一个自定义地图缩减程序,我发现谷歌搜索后没有很多例子,我仍然对规则感到困惑.
创建自定义mapreduce程序的规则是什么,mapper和reducer类怎么样?
谁能提供任何解决方案?
我想用Java开发这个程序,但是我仍然卡住了,然后在收集器中格式化输出时,如何在mapper和reducer类中格式化结果?
有人想给我一些关于这种东西的例子和解释吗?
hadoop hive mapreduce
hadoop ×1
hive ×1
mapreduce ×1