org.apache.hadoop.streaming.io

类 TextOutputReader

java.lang.Object

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

org.apache.hadoop.streaming.io.TextOutputReader

public class TextOutputReader
extends OutputReader<Text,Text>

OutputReader that reads the client's output as text.

构造器概要

构造器

构造器和说明
TextOutputReader()

方法概要

方法

限定符和类型	方法和说明
Text	getCurrentKey() Returns the current key.
Text	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

构造器详细资料

TextOutputReader

public TextOutputReader()

方法详细资料

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<Text,Text>

抛出:

IOException

readKeyValue

public boolean readKeyValue()
                     throws IOException

从类复制的说明: OutputReader

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

指定者:

readKeyValue 在类中 OutputReader<Text,Text>

返回:

true iff a key/value pair was read

抛出:

IOException

getCurrentKey

public Text getCurrentKey()
                   throws IOException

从类复制的说明: OutputReader

Returns the current key.

指定者:

getCurrentKey 在类中 OutputReader<Text,Text>

抛出:

IOException

getCurrentValue

public Text getCurrentValue()
                     throws IOException

从类复制的说明: OutputReader

Returns the current value.

指定者:

getCurrentValue 在类中 OutputReader<Text,Text>

抛出:

IOException

getLastOutput

public String getLastOutput()

从类复制的说明: OutputReader

Returns the last output from the client as a String.

指定者:

getLastOutput 在类中 OutputReader<Text,Text>