public static class FarthestPair.FarthestPairFilter extends DefaultBlockFilter
Constructor and Description |
---|
FarthestPair.FarthestPairFilter() |
Modifier and Type | Method and Description |
---|---|
void |
selectCellPairs(GlobalIndex<Partition> gIndex1,
GlobalIndex<Partition> gIndex2,
ResultCollector2<Partition,Partition> output)
Selects block pairs that need to be processed together by a binary
MapReduce job.
|
configure, selectCells
public void selectCellPairs(GlobalIndex<Partition> gIndex1, GlobalIndex<Partition> gIndex2, ResultCollector2<Partition,Partition> output)
BlockFilter
selectCellPairs
in interface BlockFilter
selectCellPairs
in class DefaultBlockFilter