edu.umn.cs.spatialHadoop.mapred

Interface BlockFilter

All Known Implementing Classes:

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

public interface BlockFilter

An interface for filtering blocks before running map tasks.

Author:

Ahmed Eldawy

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.

Method Detail

configure

void configure(JobConf job)

Configure the block filter the first time it is created.

Parameters:

conf -

selectCells

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

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

Parameters:

gIndex -

output -

selectCellPairs

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. A binary MapReduce job is a job that deals with two input files that need to be processed together (e.g., spatial join).

Parameters:

gIndex1 -

gIndex2 -