org.zephyr.mapreduce.mapper

Class ZephyrBytesWritableMapper

java.lang.Object

org.apache.hadoop.mapred.MapReduceBase

org.zephyr.mapreduce.mapper.ZephyrMapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.BytesWritable>

org.zephyr.mapreduce.mapper.ZephyrBytesWritableMapper

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

public class ZephyrBytesWritableMapper
extends ZephyrMapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.BytesWritable>

Constructor Summary

Constructors

Constructor and Description
ZephyrBytesWritableMapper()

Method Summary

Methods

Modifier and Type	Method and Description
protected java.io.InputStream	getInputStreamFromKeyValue(org.apache.hadoop.io.NullWritable key, org.apache.hadoop.io.BytesWritable value)

Methods inherited from class org.zephyr.mapreduce.mapper.ZephyrMapper

configure, map

Methods inherited from class org.apache.hadoop.mapred.MapReduceBase

close

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Constructor Detail

ZephyrBytesWritableMapper

public ZephyrBytesWritableMapper()

Method Detail

getInputStreamFromKeyValue

protected java.io.InputStream getInputStreamFromKeyValue(org.apache.hadoop.io.NullWritable key,
                                             org.apache.hadoop.io.BytesWritable value)

Specified by:

getInputStreamFromKeyValue in class ZephyrMapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.BytesWritable>