org.apache.hadoop.mapred
Class TextOutputFormat.LineRecordWriter<K,V>
java.lang.Object
org.apache.hadoop.mapred.TextOutputFormat.LineRecordWriter<K,V>
- All Implemented Interfaces:
- RecordWriter<K,V>
- Enclosing class:
- TextOutputFormat<K,V>
protected static class TextOutputFormat.LineRecordWriter<K,V>
- extends java.lang.Object
- implements RecordWriter<K,V>
Field Summary |
protected java.io.DataOutputStream |
out
|
Method Summary |
void |
close(Reporter reporter)
Close this RecordWriter to future operations. |
void |
write(K key,
V value)
Writes a key/value pair. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
out
protected java.io.DataOutputStream out
TextOutputFormat.LineRecordWriter
public TextOutputFormat.LineRecordWriter(java.io.DataOutputStream out,
java.lang.String keyValueSeparator)
TextOutputFormat.LineRecordWriter
public TextOutputFormat.LineRecordWriter(java.io.DataOutputStream out)
write
public void write(K key,
V value)
throws java.io.IOException
- Description copied from interface:
RecordWriter
- Writes a key/value pair.
- Specified by:
write
in interface RecordWriter<K,V>
- Parameters:
key
- the key to write.value
- the value to write.
- Throws:
java.io.IOException
close
public void close(Reporter reporter)
throws java.io.IOException
- Description copied from interface:
RecordWriter
- Close this
RecordWriter
to future operations.
- Specified by:
close
in interface RecordWriter<K,V>
- Parameters:
reporter
- facility to report progress.
- Throws:
java.io.IOException
Copyright © 2009 The Apache Software Foundation