edu.umn.cs.spatialHadoop.operations

Class DistributedCopy.BlockRecordReader

java.lang.Object

edu.umn.cs.spatialHadoop.operations.DistributedCopy.BlockRecordReader

Enclosing class:

DistributedCopy

public static class DistributedCopy.BlockRecordReader
extends java.lang.Object

Reads blocks of binary arrays from input file.

Author:

Ahmed Eldawy

Constructor Summary

Constructors

Constructor and Description
DistributedCopy.BlockRecordReader(InputSplit split, JobConf job, Reporter reporter)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
DistributedCopy.FileBlockIndex	createKey()
WritableByteArray	createValue()
long	getPos()
float	getProgress()
boolean	next(DistributedCopy.FileBlockIndex key, WritableByteArray value)

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedCopy.BlockRecordReader

public DistributedCopy.BlockRecordReader(InputSplit split,
                                 JobConf job,
                                 Reporter reporter)
                                  throws java.io.IOException

Throws:

java.io.IOException

Method Detail

createKey

public DistributedCopy.FileBlockIndex createKey()

createValue

public WritableByteArray createValue()

next

public boolean next(DistributedCopy.FileBlockIndex key,
           WritableByteArray value)
             throws java.io.IOException

Throws:

java.io.IOException

getPos

public long getPos()
            throws java.io.IOException

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

getProgress

public float getProgress()
                  throws java.io.IOException

Throws:

java.io.IOException