edu.umn.cs.spatialHadoop.mapreduce

Class SpatialRecordReader3<V extends Shape>

java.lang.Object

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

public class SpatialRecordReader3<V extends Shape>
extends 

Author:

Ahmed Eldawy

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SpatialRecordReader3.ShapeIterator<V extends Shape> An iterator that iterates over all shapes in the input file

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
SpatialRecordReader3()

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)
protected boolean	isMatched(Shape shape)
boolean	nextKeyValue()
protected boolean	nextLine(Text value) Reads the next line from input and return true if a line was read.
protected boolean	nextShape(V s) Reads next shape from input and returns true.

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

SpatialRecordReader3

public SpatialRecordReader3()

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

getPos

public long getPos()
            throws java.io.IOException

Throws:

java.io.IOException

nextLine

protected boolean nextLine(Text value)
                    throws java.io.IOException

Reads the next line from input and return true if a line was read. If no more lines are available in this split, a false is returned.

Parameters:

value -

Returns:

Throws:

java.io.IOException

isMatched

protected boolean isMatched(Shape shape)

nextShape

protected boolean nextShape(V s)
                     throws java.io.IOException

Reads next shape from input and returns true. If no more shapes are left in the split, a false is returned. This function first reads a line by calling the method nextLine(Text) then parses the returned line by calling TextSerializable.fromText(Text) on that line. If no stock shape is set, a NullPointerException is thrown.

Parameters:

s -

Returns:

Throws:

java.io.IOException

nextKeyValue

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

Throws:

java.io.IOException

java.lang.InterruptedException

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