oracle.spatial.hadoop.vector.mapred.input

Class InputSplitInputFormat.InputSplitRecordReader<V extends org.apache.hadoop.mapred.InputSplit>

java.lang.Object

oracle.spatial.hadoop.vector.mapred.input.InputSplitInputFormat.InputSplitRecordReader<V>

All Implemented Interfaces:

org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,V>

Enclosing class:

InputSplitInputFormat

public static class InputSplitInputFormat.InputSplitRecordReader<V extends org.apache.hadoop.mapred.InputSplit>
extends java.lang.Object
implements org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,V>

Constructor Summary

Constructors

Constructor and Description
InputSplitRecordReader(org.apache.hadoop.mapred.InputSplit split)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
org.apache.hadoop.io.NullWritable	createKey()
V	createValue()
long	getPos()
float	getProgress()
boolean	next(org.apache.hadoop.io.NullWritable key, V value)

Methods inherited from class java.lang.Object

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

Constructor Detail

InputSplitRecordReader

public InputSplitRecordReader(org.apache.hadoop.mapred.InputSplit split)

Method Detail

close

public void close()
           throws java.io.IOException

Specified by:

close in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,V extends org.apache.hadoop.mapred.InputSplit>

Throws:

java.io.IOException

getProgress

public float getProgress()
                  throws java.io.IOException

Specified by:

getProgress in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,V extends org.apache.hadoop.mapred.InputSplit>

Throws:

java.io.IOException

createKey

public org.apache.hadoop.io.NullWritable createKey()

Specified by:

createKey in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,V extends org.apache.hadoop.mapred.InputSplit>

createValue

public V createValue()

Specified by:

createValue in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,V extends org.apache.hadoop.mapred.InputSplit>

getPos

public long getPos()
            throws java.io.IOException

Specified by:

getPos in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,V extends org.apache.hadoop.mapred.InputSplit>

Throws:

java.io.IOException

next

public boolean next(org.apache.hadoop.io.NullWritable key,
                    V value)
             throws java.io.IOException

Specified by:

next in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.NullWritable,V extends org.apache.hadoop.mapred.InputSplit>

Throws:

java.io.IOException