org.apache.hadoop.streaming.io

类 OutputReader<K,V>

java.lang.Object

org.apache.hadoop.streaming.io.OutputReader<K,V>

直接已知子类:

RawBytesOutputReader, TextOutputReader, TypedBytesOutputReader

public abstract class OutputReader<K,V>
extends Object

Abstract base for classes that read the client's output.

构造器概要

构造器

构造器和说明
OutputReader()

方法概要

方法

限定符和类型	方法和说明
abstract K	getCurrentKey() Returns the current key.
abstract V	getCurrentValue() Returns the current value.
abstract String	getLastOutput() Returns the last output from the client as a String.
void	initialize(PipeMapRed pipeMapRed) Initializes the OutputReader.
abstract 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

构造器详细资料

OutputReader

public OutputReader()

方法详细资料

initialize

public void initialize(PipeMapRed pipeMapRed)
                throws IOException

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

抛出:

IOException

readKeyValue

public abstract boolean readKeyValue()
                              throws IOException

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

返回:

true iff a key/value pair was read

抛出:

IOException

getCurrentKey

public abstract K getCurrentKey()
                         throws IOException

Returns the current key.

抛出:

IOException

getCurrentValue

public abstract V getCurrentValue()
                           throws IOException

Returns the current value.

抛出:

IOException

getLastOutput

public abstract String getLastOutput()

Returns the last output from the client as a String.