oracle - 在这种情况下如何使用map-reduce？

Question

我以为可以通过此映射器代码获得输出，并得到一个oracle查询的结果。

outputkey.set(column[0] +","+column[1]){
 if(column[1].contains("ora-"))
   context.write(outputkey,outputvalue)
}

select record_id, message_text
from x$dbgalertext;

但是实际上，这些代码无法执行任何操作。

我想使用Hadoop和Oracle查询获得此结果。

date         error      sum of errors
column1     column2   column 3
07-26      ora-00000    10
07-26      ora-00001    20
07-27      ora-00008    12
...          ...         ...

我该怎么办？

Answer 1

仅使用映射器是无法实现的，还需要使用reducer代码。汇总所有相似的键以计算错误总和。

使用您当前的代码，您将获得如下输出

07-27,ora-00008 1
...
...

在化简器上，您将收到具有可迭代值的所有键。因此，仅计算出这就是您的错误总和。

context.write((key.split(,)[0]+" "+key.split(,)[1]),value.size());