org.apache.hadoop.streaming.io

类 RawBytesOutputReader

java.lang.Object

org.apache.hadoop.streaming.io.OutputReader<BytesWritable,BytesWritable>

org.apache.hadoop.streaming.io.RawBytesOutputReader

public class RawBytesOutputReader
extends OutputReader<BytesWritable,BytesWritable>

OutputReader that reads the client's output as raw bytes.

构造器概要

构造器

构造器和说明
RawBytesOutputReader()

方法概要

方法

限定符和类型	方法和说明
BytesWritable	getCurrentKey() Returns the current key.
BytesWritable	getCurrentValue() Returns the current value.
String	getLastOutput() Returns the last output from the client as a String.
void	initialize(PipeMapRed pipeMapRed) Initializes the OutputReader.
boolean	readKeyValue() Read the next key/value pair outputted by the client.

从类继承的方法 java.lang.Object

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

构造器详细资料

RawBytesOutputReader

public RawBytesOutputReader()

方法详细资料

initialize

public void initialize(PipeMapRed pipeMapRed)
                throws IOException

从类复制的说明: OutputReader

Initializes the OutputReader. This method has to be called before calling any of the other methods.

覆盖:

initialize 在类中 OutputReader<BytesWritable,BytesWritable>

抛出:

IOException

readKeyValue

public boolean readKeyValue()
                     throws IOException

从类复制的说明: OutputReader

Read the next key/value pair outputted by the client.

指定者:

readKeyValue 在类中 OutputReader<BytesWritable,BytesWritable>

返回:

true iff a key/value pair was read

抛出:

IOException

getCurrentKey

public BytesWritable getCurrentKey()
                            throws IOException

从类复制的说明: OutputReader

Returns the current key.

指定者:

getCurrentKey 在类中 OutputReader<BytesWritable,BytesWritable>

抛出:

IOException

getCurrentValue

public BytesWritable getCurrentValue()
                              throws IOException

从类复制的说明: OutputReader

Returns the current value.

指定者:

getCurrentValue 在类中 OutputReader<BytesWritable,BytesWritable>

抛出:

IOException

getLastOutput

public String getLastOutput()

从类复制的说明: OutputReader

Returns the last output from the client as a String.

指定者:

getLastOutput 在类中 OutputReader<BytesWritable,BytesWritable>