edu.umn.cs.spatialHadoop.mapred

Class DefaultBlockFilter

java.lang.Object

edu.umn.cs.spatialHadoop.mapred.DefaultBlockFilter

All Implemented Interfaces:

BlockFilter

Direct Known Subclasses:

ConvexHull.ConvexHullFilter, DistributedJoin.SpatialJoinFilter, FarthestPair.FarthestPairFilter, RangeQuery.RangeFilter, Skyline.SkylineFilter

public class DefaultBlockFilter
extends java.lang.Object
implements BlockFilter

A default implementation for BlockFilter that returns everything.

Author:

eldawy

Constructor Summary

Constructors

Constructor and Description
DefaultBlockFilter()

Method Summary

Methods

Modifier and Type	Method and Description
void	configure(JobConf job) Configure the block filter the first time it is created.
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.
void	selectCells(GlobalIndex<Partition> gIndex, ResultCollector<Partition> output) Selects the blocks that need to be processed b a MapReduce job.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultBlockFilter

public DefaultBlockFilter()

Method Detail

configure

public void configure(JobConf job)

Description copied from interface: BlockFilter

Configure the block filter the first time it is created.

Specified by:

configure in interface BlockFilter

selectCells

public void selectCells(GlobalIndex<Partition> gIndex,
               ResultCollector<Partition> output)

Description copied from interface: BlockFilter

Selects the blocks that need to be processed b a MapReduce job.

Specified by:

selectCells in interface BlockFilter

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