edu.umn.cs.spatialHadoop.operations

Class DistributedJoin.DJInputFormatArray.DJRecordReader

java.lang.Object

edu.umn.cs.spatialHadoop.mapred.BinaryRecordReader<Rectangle,ArrayWritable>

edu.umn.cs.spatialHadoop.operations.DistributedJoin.DJInputFormatArray.DJRecordReader

Enclosing class:

DistributedJoin.DJInputFormatArray

public static class DistributedJoin.DJInputFormatArray.DJRecordReader
extends BinaryRecordReader<Rectangle,ArrayWritable>

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.DJInputFormatArray.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.DJInputFormatArray.DJRecordReader

public DistributedJoin.DJInputFormatArray.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,ArrayWritable>

Returns:

Throws:

java.io.IOException