public class HDFRecordReader
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
class |
HDFRecordReader.NASAIterator |
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DatasetName
Configuration for name of the dataset to read from HDF file
|
static java.lang.String |
ProjectorClass
The class used to project NASA points upon read
|
static java.lang.String |
SkipFillValue
The configuration entry for skipping the fill value
|
Constructor and Description |
---|
HDFRecordReader(Configuration job,
FileSplit split,
java.lang.String datasetName,
boolean skipFillValue)
Initializes the HDF reader to read a specific dataset from the given HDF
file.
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
NASADataset |
createKey() |
java.lang.Iterable<NASAShape> |
createValue() |
static Dataset |
findDataset(Group root,
java.lang.String datasetName,
boolean matchAny) |
long |
getPos() |
float |
getProgress() |
boolean |
next(NASADataset dataset,
java.lang.Iterable<NASAShape> value) |
protected boolean |
nextObject(NASADataset key,
NASAShape shape) |
public static final java.lang.String DatasetName
public static final java.lang.String SkipFillValue
public static final java.lang.String ProjectorClass
public HDFRecordReader(Configuration job, FileSplit split, java.lang.String datasetName, boolean skipFillValue) throws java.io.IOException
job
- - Job configurationsplit
- - A file split pointing to the HDF filedatasetName
- - Name of the dataset to read (case insensitive)java.lang.Exception
java.io.IOException
public static Dataset findDataset(Group root, java.lang.String datasetName, boolean matchAny)
split
- datasetName
- root
- matchAny
- protected boolean nextObject(NASADataset key, NASAShape shape) throws java.io.IOException
java.io.IOException
public boolean next(NASADataset dataset, java.lang.Iterable<NASAShape> value) throws java.io.IOException
java.io.IOException
public NASADataset createKey()
public java.lang.Iterable<NASAShape> createValue()
public long getPos() throws java.io.IOException
java.io.IOException
public void close() throws java.io.IOException
java.io.IOException
public float getProgress() throws java.io.IOException
java.io.IOException