com.google.appengine.tools.mapreduce.outputs

Class MarshallingOutputWriter<O>

java.lang.Object

com.google.appengine.tools.mapreduce.OutputWriter<O>

com.google.appengine.tools.mapreduce.outputs.ForwardingOutputWriter<O>

com.google.appengine.tools.mapreduce.outputs.MarshallingOutputWriter<O>

Type Parameters:

O - the type of OutputWriter that this will become. (The type of the values that will be written to this class)

All Implemented Interfaces:

Serializable

public class MarshallingOutputWriter<O>
extends ForwardingOutputWriter<O>

An OutputWriter that marshalls records.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MarshallingOutputWriter(OutputWriter<ByteBuffer> writer, Marshaller<? super O> marshaller)

Method Summary

Methods

Modifier and Type	Method and Description
protected OutputWriter<ByteBuffer>	getDelegate()
void	write(O value) Writes a value to the output.

Methods inherited from class com.google.appengine.tools.mapreduce.outputs.ForwardingOutputWriter

allowSliceRetry, beginShard, beginSlice, endShard, endSlice, estimateMemoryRequirement, getContext, setContext

Methods inherited from class com.google.appengine.tools.mapreduce.OutputWriter

cleanup, close, open

Methods inherited from class java.lang.Object

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

Constructor Detail

MarshallingOutputWriter

public MarshallingOutputWriter(OutputWriter<ByteBuffer> writer,
                       Marshaller<? super O> marshaller)

Method Detail

getDelegate

protected OutputWriter<ByteBuffer> getDelegate()

Specified by:

getDelegate in class ForwardingOutputWriter<O>

write

public void write(O value)
           throws IOException

Description copied from class: OutputWriter

Writes a value to the output.

Specified by:

write in class OutputWriter<O>

Throws:

IOException