HBase MapReduce摘要到RDBMS

有時候給 RDBMS 生成摘要更為合適。對于這些情況，可以通過自定義減速器直接向 RDBMS 生成摘要。該 setup 方法可以連接到 RDBMS（連接信息可以通過上下文中的自定義參數(shù)傳遞），并且清理方法可以關(guān)閉連接。

重要的是，要了解工作中的減速器的數(shù)量會影響到摘要的實現(xiàn)，您必須將其設(shè)計到您的減速器中。具體而言，它是否被設(shè)計為以單例（一個減速器）或多個減速器運行。是或不是，這取決于你的用例。認識到分配給作業(yè)的減速者越多，同時建立到 RDBMS 的連接就會越多 - 這將會擴展，但僅限于某一點。

public static class MyRdbmsReducer extends Reducer<Text, IntWritable, Text, IntWritable>  {

  private Connection c = null;

  public void setup(Context context) {
    // create DB connection...
  }

  public void reduce(Text key, Iterable<IntWritable> values, Context context) throws IOException, InterruptedException {
    // do summarization
    // in this example the keys are Text, but this is just an example
  }

  public void cleanup(Context context) {
    // close db connection
  }

}

最后，摘要結(jié)果將寫入您的 RDBMS 表。