org.kepler.hadoop.io.output

Class ValueOnlyOutputWriter<K,V>

java.lang.Object

org.apache.hadoop.mapreduce.RecordWriter<K,V>

org.kepler.hadoop.io.output.ValueOnlyOutputWriter<K,V>

public class ValueOnlyOutputWriter<K,V>
extends org.apache.hadoop.mapreduce.RecordWriter<K,V>

This class provides RecordWriter to write key values. It only write values to output.

Author:

Jianwu Wang (jianwu@sdsc.edu)

Field Summary

Fields

Modifier and Type	Field and Description
protected java.io.DataOutputStream	out

Constructor Summary

Constructors

Constructor and Description
ValueOnlyOutputWriter(java.io.DataOutputStream out)
ValueOnlyOutputWriter(java.io.DataOutputStream out, java.lang.String keyValueSeparator)

Method Summary

Modifier and Type	Method and Description
void	close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
void	write(K key, V value)

Methods inherited from class java.lang.Object

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

Field Detail

out

protected java.io.DataOutputStream out

Constructor Detail

ValueOnlyOutputWriter

public ValueOnlyOutputWriter(java.io.DataOutputStream out,
                             java.lang.String keyValueSeparator)

ValueOnlyOutputWriter

public ValueOnlyOutputWriter(java.io.DataOutputStream out)

Method Detail

write

public void write(K key,
                  V value)
           throws java.io.IOException

Specified by:

write in class org.apache.hadoop.mapreduce.RecordWriter<K,V>

Throws:

java.io.IOException

close

public void close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
           throws java.io.IOException

Specified by:

close in class org.apache.hadoop.mapreduce.RecordWriter<K,V>

Throws:

java.io.IOException