org.apache.hadoop.hive.contrib.fileformat.base64

Class Base64TextInputFormat.Base64LineRecordReader

java.lang.Object

org.apache.hadoop.hive.contrib.fileformat.base64.Base64TextInputFormat.Base64LineRecordReader

All Implemented Interfaces:

org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.BytesWritable>

Enclosing class:

Base64TextInputFormat

public static class Base64TextInputFormat.Base64LineRecordReader
extends Object
implements org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.BytesWritable>, org.apache.hadoop.mapred.JobConfigurable

Base64LineRecordReader.

Constructor Summary

Constructors

Constructor and Description
Base64TextInputFormat.Base64LineRecordReader(org.apache.hadoop.mapred.LineRecordReader reader)

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

Constructor Detail

Base64TextInputFormat.Base64LineRecordReader

public Base64TextInputFormat.Base64LineRecordReader(org.apache.hadoop.mapred.LineRecordReader reader)

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.BytesWritable>

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.BytesWritable>

createValue

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

Specified by:

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

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.BytesWritable>

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.BytesWritable>

Throws:

IOException

next

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

Specified by:

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

Throws:

IOException

configure

public void configure(org.apache.hadoop.mapred.JobConf job)

Specified by:

configure in interface org.apache.hadoop.mapred.JobConfigurable