org.kepler.hadoop.io.input

Class TokenRecordReader

java.lang.Object

org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,TokenWritable>

org.kepler.hadoop.io.input.TokenRecordReader

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class TokenRecordReader
extends org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,TokenWritable>

Hadoop RecordReader for Ptolemy tokens.

Author:

Daniel Crawl

Constructor Summary

Constructors

Constructor and Description
TokenRecordReader()

Method Summary

Modifier and Type	Method and Description
void	close() Close the reader.
org.apache.hadoop.io.NullWritable	getCurrentKey() Get the key.
TokenWritable	getCurrentValue() Get the token writable.
float	getProgress() Get the progress.
void	initialize(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) Initialize the record reader with a split.
boolean	nextKeyValue() If another key value can be read, returns true.

Methods inherited from class java.lang.Object

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

Constructor Detail

TokenRecordReader

public TokenRecordReader()

Method Detail

initialize

public void initialize(org.apache.hadoop.mapreduce.InputSplit split,
                       org.apache.hadoop.mapreduce.TaskAttemptContext context)
                throws java.io.IOException,
                       java.lang.InterruptedException

Initialize the record reader with a split.

Specified by:

initialize in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,TokenWritable>

Throws:

java.io.IOException

java.lang.InterruptedException

nextKeyValue

public boolean nextKeyValue()
                     throws java.io.IOException,
                            java.lang.InterruptedException

If another key value can be read, returns true.

Specified by:

nextKeyValue in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,TokenWritable>

Throws:

java.io.IOException

java.lang.InterruptedException

getCurrentKey

public org.apache.hadoop.io.NullWritable getCurrentKey()
                                                throws java.io.IOException,
                                                       java.lang.InterruptedException

Get the key. In this class returns Null.

Specified by:

getCurrentKey in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,TokenWritable>

Throws:

java.io.IOException

java.lang.InterruptedException

getCurrentValue

public TokenWritable getCurrentValue()
                              throws java.io.IOException,
                                     java.lang.InterruptedException

Get the token writable.

Specified by:

getCurrentValue in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,TokenWritable>

Throws:

java.io.IOException

java.lang.InterruptedException

getProgress

public float getProgress()
                  throws java.io.IOException,
                         java.lang.InterruptedException

Get the progress.

Specified by:

getProgress in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,TokenWritable>

Throws:

java.io.IOException

java.lang.InterruptedException

close

public void close()
           throws java.io.IOException

Close the reader.

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in class org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,TokenWritable>

Throws:

java.io.IOException