org.apache.hadoop.streaming.io
Class TextInputWriter
java.lang.Object
org.apache.hadoop.streaming.io.InputWriter<Object,Object>
org.apache.hadoop.streaming.io.TextInputWriter
- Direct Known Subclasses:
- KeyOnlyTextInputWriter
public class TextInputWriter
- extends InputWriter<Object,Object>
InputWriter that writes the client's input as text.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
clientOut
protected DataOutput clientOut
TextInputWriter
public TextInputWriter()
initialize
public void initialize(PipeMapRed pipeMapRed)
throws IOException
- Description copied from class:
InputWriter
- Initializes the InputWriter. This method has to be called before calling
any of the other methods.
- Overrides:
initialize
in class InputWriter<Object,Object>
- Throws:
IOException
writeKey
public void writeKey(Object key)
throws IOException
- Description copied from class:
InputWriter
- Writes an input key.
- Specified by:
writeKey
in class InputWriter<Object,Object>
- Throws:
IOException
writeValue
public void writeValue(Object value)
throws IOException
- Description copied from class:
InputWriter
- Writes an input value.
- Specified by:
writeValue
in class InputWriter<Object,Object>
- Throws:
IOException
writeUTF8
protected void writeUTF8(Object object)
throws IOException
- Throws:
IOException
Copyright © 2014 Apache Software Foundation. All Rights Reserved.