edu.umn.cs.spatialHadoop.mapreduce

Class RTreeRecordReader3<V extends Shape>

java.lang.Object

edu.umn.cs.spatialHadoop.mapreduce.RTreeRecordReader3<V>

public class RTreeRecordReader3<V extends Shape>
extends 

Reads a file that contains R-trees.

Author:

Ahmed Eldawy

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RTreeRecordReader3.DuplicateAvoidanceIterator<V extends Shape>

Field Summary

Fields

Modifier and Type	Field and Description
protected Partition	cellMBR The boundary of the partition currently being read

Constructor Summary

Constructors

Constructor and Description
RTreeRecordReader3()

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
Partition	getCurrentKey()
java.lang.Iterable<V>	getCurrentValue()
long	getPos()
float	getProgress()
void	initialize(InputSplit split, Configuration conf)
void	initialize(InputSplit split, TaskAttemptContext context)
boolean	nextKeyValue()

Methods inherited from class java.lang.Object

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

Field Detail

cellMBR

protected Partition cellMBR

The boundary of the partition currently being read

Constructor Detail

RTreeRecordReader3

public RTreeRecordReader3()

Method Detail

initialize

public void initialize(InputSplit split,
              TaskAttemptContext context)
                throws java.io.IOException,
                       java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

initialize

public void initialize(InputSplit split,
              Configuration conf)
                throws java.io.IOException,
                       java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

nextKeyValue

public boolean nextKeyValue()
                     throws java.io.IOException,
                            java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

getPos

public long getPos()
            throws java.io.IOException

Throws:

java.io.IOException

getCurrentKey

public Partition getCurrentKey()
                        throws java.io.IOException,
                               java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

getCurrentValue

public java.lang.Iterable<V> getCurrentValue()
                                                    throws java.io.IOException,
                                                           java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

getProgress

public float getProgress()
                  throws java.io.IOException,
                         java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException