public class RawBytesOutputReader extends OutputReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>
Constructor and Description |
---|
RawBytesOutputReader() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.io.BytesWritable |
getCurrentKey()
Returns the current key.
|
org.apache.hadoop.io.BytesWritable |
getCurrentValue()
Returns the current value.
|
java.lang.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.
|
public void initialize(PipeMapRed pipeMapRed) throws java.io.IOException
OutputReader
initialize
in class OutputReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>
java.io.IOException
public boolean readKeyValue() throws java.io.IOException
OutputReader
readKeyValue
in class OutputReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>
java.io.IOException
public org.apache.hadoop.io.BytesWritable getCurrentKey() throws java.io.IOException
OutputReader
getCurrentKey
in class OutputReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>
java.io.IOException
public org.apache.hadoop.io.BytesWritable getCurrentValue() throws java.io.IOException
OutputReader
getCurrentValue
in class OutputReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>
java.io.IOException
public java.lang.String getLastOutput()
OutputReader
getLastOutput
in class OutputReader<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>
Copyright © 2009 The Apache Software Foundation