edu.umn.cs.spatialHadoop.nasa

Class HDFRecordReader3<S extends NASAShape>

java.lang.Object

edu.umn.cs.spatialHadoop.nasa.HDFRecordReader3<S>

public class HDFRecordReader3<S extends NASAShape>
extends 

A record reader for HDF files with the new mapreduce interface

Author:

Ahmed Eldawy

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	HDFRecordReader3.NASAIterator

Constructor Summary

Constructors

Constructor and Description
HDFRecordReader3()

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
static Dataset	findDataset(Group root, java.lang.String datasetName, boolean matchAny)
NASADataset	getCurrentKey()
java.lang.Iterable<S>	getCurrentValue()
float	getProgress()
void	initialize(InputSplit split, Configuration conf)
void	initialize(InputSplit split, TaskAttemptContext context)
boolean	nextKeyValue()
protected boolean	nextObject(NASADataset key, NASAShape shape) Reads next NASA object from the array

Methods inherited from class java.lang.Object

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

Constructor Detail

HDFRecordReader3

public HDFRecordReader3()

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)

getCurrentKey

public NASADataset getCurrentKey()
                          throws java.io.IOException,
                                 java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

getCurrentValue

public java.lang.Iterable<S> 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

nextKeyValue

public boolean nextKeyValue()
                     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

nextObject

protected boolean nextObject(NASADataset key,
                 NASAShape shape)
                      throws java.io.IOException

Reads next NASA object from the array

Parameters:

key -

shape -

Returns:

Throws:

java.io.IOException

findDataset

public static Dataset findDataset(Group root,
                  java.lang.String datasetName,
                  boolean matchAny)

Parameters:

split -

datasetName -

root -

matchAny -

Returns: