public static class Skyline.SkylineFilter extends DefaultBlockFilter
Constructor and Description |
---|
Skyline.SkylineFilter() |
Modifier and Type | Method and Description |
---|---|
void |
configure(JobConf job)
Configure the block filter the first time it is created.
|
void |
selectCells(GlobalIndex<Partition> gIndex,
ResultCollector<Partition> output)
Selects the blocks that need to be processed b a MapReduce job.
|
selectCellPairs
public void configure(JobConf job)
BlockFilter
configure
in interface BlockFilter
configure
in class DefaultBlockFilter
public void selectCells(GlobalIndex<Partition> gIndex, ResultCollector<Partition> output)
BlockFilter
selectCells
in interface BlockFilter
selectCells
in class DefaultBlockFilter