/* Mappers are initialized with GoraMapper.initMapper() or
* GoraInputFormat.setInput()*/
GoraMapper.initMapperJob(job, inStore, TextLong.class, LongWritable.class
, LogAnalyticsMapper.class, true);
/* Reducers are initialized with GoraReducer#initReducer().
* If the output is not to be persisted via Gora, any reducer
* can be used instead. */
GoraReducer.initReducerJob(job, outStore, LogAnalyticsReducer.class);
1条答案
按热度按时间8wigbo561#
我从来没有按你的要求做过,但你可能会在gora教程的“构建工作”部分看到答案。这里有一个减速机配置的例子,上面说:
然后,不用
GoraReducer.initReducerJob()
您只需配置自己的减速机,如下链接所示(如果答案正确):要知道在前面的示例中,Map器发出
(TextLong, LongWritable)
键值,所以你的减速机应该是这样的,从你写的链接和答案:再说一次,我从来没有这样做过。。。所以也许行不通:\