edu.umn.cs.spatialHadoop.operations

Class DistributedJoin.SpatialJoinFilter

java.lang.Object

edu.umn.cs.spatialHadoop.mapred.DefaultBlockFilter

edu.umn.cs.spatialHadoop.operations.DistributedJoin.SpatialJoinFilter

All Implemented Interfaces:

BlockFilter

Enclosing class:

DistributedJoin

public static class DistributedJoin.SpatialJoinFilter
extends DefaultBlockFilter

Constructor Summary

Constructors

Constructor and Description
DistributedJoin.SpatialJoinFilter()

Method Summary

Methods

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.

Methods inherited from class edu.umn.cs.spatialHadoop.mapred.DefaultBlockFilter

configure, selectCells

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedJoin.SpatialJoinFilter

public DistributedJoin.SpatialJoinFilter()

Method Detail

selectCellPairs

public void selectCellPairs(GlobalIndex<Partition> gIndex1,
                   GlobalIndex<Partition> gIndex2,
                   ResultCollector2<Partition,Partition> output)

Description copied from interface: BlockFilter

Selects block pairs that need to be processed together by a binary MapReduce job. A binary MapReduce job is a job that deals with two input files that need to be processed together (e.g., spatial join).

Specified by:

selectCellPairs in interface BlockFilter

Overrides:

selectCellPairs in class DefaultBlockFilter