edu.umn.cs.spatialHadoop.operations

Class DistributedJoin.DJInputFormatRTree.DJRecordReader<S extends Shape>

java.lang.Object

edu.umn.cs.spatialHadoop.mapred.BinaryRecordReader<Rectangle,RTree<S>>

edu.umn.cs.spatialHadoop.operations.DistributedJoin.DJInputFormatRTree.DJRecordReader<S>

Enclosing class:

DistributedJoin.DJInputFormatRTree<S extends Shape>

public static class DistributedJoin.DJInputFormatRTree.DJRecordReader<S extends Shape>
extends BinaryRecordReader<Rectangle,RTree<S>>

Reads a pair of arrays of shapes

Author:

Ahmed Eldawy

Field Summary

Fields inherited from class edu.umn.cs.spatialHadoop.mapred.BinaryRecordReader

conf, firstTime, internalReaders, progress1Before, split

Constructor Summary

Constructors

Constructor and Description
DistributedJoin.DJInputFormatRTree.DJRecordReader(Configuration conf, CombineFileSplit fileSplits)

Method Summary

Methods

Modifier and Type	Method and Description
protected	createRecordReader(Configuration conf, CombineFileSplit split, int i) Creates a record reader for one of the two splits parsed by this reader.

Methods inherited from class edu.umn.cs.spatialHadoop.mapred.BinaryRecordReader

close, createKey, createValue, getPos, getProgress, next

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedJoin.DJInputFormatRTree.DJRecordReader

public DistributedJoin.DJInputFormatRTree.DJRecordReader(Configuration conf,
                                                 CombineFileSplit fileSplits)
                                                  throws java.io.IOException

Throws:

java.io.IOException

Method Detail

createRecordReader

protected  createRecordReader(Configuration conf,
                       CombineFileSplit split,
                       int i)
                            throws java.io.IOException

Description copied from class: BinaryRecordReader

Creates a record reader for one of the two splits parsed by this reader.

Specified by:

createRecordReader in class BinaryRecordReader<Rectangle,RTree<S extends Shape>>

Returns:

Throws:

java.io.IOException