org.apache.hadoop.hbase.mapreduce

Class IntegrationTestBulkLoad.LinkedListCheckingReducer

java.lang.Object

<any>

org.apache.hadoop.hbase.mapreduce.IntegrationTestBulkLoad.LinkedListCheckingReducer

Enclosing class:

IntegrationTestBulkLoad

public static class IntegrationTestBulkLoad.LinkedListCheckingReducer
extends <any>

Class that does the actual checking of the links. All links in the chain should be grouped and sorted when sent to this class. Then the chain will be traversed making sure that no link is missing and that the chain is the correct length. This will throw an exception if anything is not correct. That causes the job to fail if any data is corrupt.

Constructor Summary

Constructors

Constructor and Description
LinkedListCheckingReducer()

Method Summary

Modifier and Type	Method and Description
protected void	reduce(IntegrationTestBulkLoad.LinkKey key, Iterable<IntegrationTestBulkLoad.LinkChain> values, Context context)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LinkedListCheckingReducer

public LinkedListCheckingReducer()

Method Detail

reduce

protected void reduce(IntegrationTestBulkLoad.LinkKey key,
                      Iterable<IntegrationTestBulkLoad.LinkChain> values,
                      Context context)
               throws IOException,
                      InterruptedException

Throws:

IOException

InterruptedException