org.apache.hadoop.chukwa.inputtools

Class ChukwaInputFormat.ChukwaRecordReader

java.lang.Object

org.apache.hadoop.chukwa.inputtools.ChukwaInputFormat.ChukwaRecordReader

All Implemented Interfaces:

org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text>

Enclosing class:

ChukwaInputFormat

public static class ChukwaInputFormat.ChukwaRecordReader
extends Object
implements org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text>

Field Summary

Fields

Modifier and Type	Field and Description
static String	DATATYPE_PROPERTY
static String	DATATYPE_PROPERTY_DEFAULT

Constructor Summary

Constructors

Constructor and Description
ChukwaRecordReader(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.mapred.FileSplit split)

Method Summary

Modifier and Type	Method and Description
void	close()
org.apache.hadoop.io.LongWritable	createKey()
org.apache.hadoop.io.Text	createValue()
long	getPos()
float	getProgress()
boolean	next(org.apache.hadoop.io.LongWritable key, org.apache.hadoop.io.Text value)

Methods inherited from class java.lang.Object

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

Field Detail

DATATYPE_PROPERTY

public static final String DATATYPE_PROPERTY

See Also:

Constant Field Values

DATATYPE_PROPERTY_DEFAULT

public static final String DATATYPE_PROPERTY_DEFAULT

See Also:

Constant Field Values

Constructor Detail

ChukwaRecordReader

public ChukwaRecordReader(org.apache.hadoop.conf.Configuration conf,
                          org.apache.hadoop.mapred.FileSplit split)
                   throws IOException

Throws:

IOException

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text>

Throws:

IOException

createKey

public org.apache.hadoop.io.LongWritable createKey()

Specified by:

createKey in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text>

createValue

public org.apache.hadoop.io.Text createValue()

Specified by:

createValue in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text>

getPos

public long getPos()
            throws IOException

Specified by:

getPos in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text>

Throws:

IOException

getProgress

public float getProgress()
                  throws IOException

Specified by:

getProgress in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text>

Throws:

IOException

next

public boolean next(org.apache.hadoop.io.LongWritable key,
                    org.apache.hadoop.io.Text value)
             throws IOException

Specified by:

next in interface org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text>

Throws:

IOException