com.google.appengine.tools.mapreduce.outputs

Class BlobFileOutputWriter

java.lang.Object

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

com.google.appengine.tools.mapreduce.outputs.BlobFileOutputWriter

All Implemented Interfaces:

Serializable

public final class BlobFileOutputWriter
extends OutputWriter<ByteBuffer>

An OutputWriter that writes bytes to a blob file that it creates.

Author:

ohler@google.com (Christian Ohler)

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BlobFileOutputWriter(String fileName, String mimeType)

Method Summary

Methods

Modifier and Type	Method and Description
void	beginShard() Will be called once before any calls to write.
void	beginSlice() Prepares the writer for writing after possibly having gone through serialization or deserialization.
void	endShard() Called when no more output will be written to this writer.
void	endSlice() Prepares the writer for possible serialization.
com.google.appengine.api.files.AppEngineFile	getFile() Returns the file or null if file was not finalized.
void	write(ByteBuffer bytes) Writes a value to the output.

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

allowSliceRetry, cleanup, close, estimateMemoryRequirement, getContext, open, setContext

Methods inherited from class java.lang.Object

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

Constructor Detail

BlobFileOutputWriter

public BlobFileOutputWriter(String fileName,
                    String mimeType)

Method Detail

beginShard

public void beginShard()
                throws IOException

Description copied from class: OutputWriter

Will be called once before any calls to write. Prepares the writer for processing, after possibly having gone through serialization and deserialization.

Overrides:

beginShard in class OutputWriter<ByteBuffer>

Throws:

IOException - in the event of failure

beginSlice

public void beginSlice()
                throws IOException

Description copied from class: OutputWriter

Prepares the writer for writing after possibly having gone through serialization or deserialization.

Overrides:

beginSlice in class OutputWriter<ByteBuffer>

Throws:

IOException - in the event of failure

write

public void write(ByteBuffer bytes)
           throws IOException

Description copied from class: OutputWriter

Writes a value to the output.

Specified by:

write in class OutputWriter<ByteBuffer>

Throws:

IOException

endSlice

public void endSlice()
              throws IOException

Description copied from class: OutputWriter

Prepares the writer for possible serialization.

Overrides:

endSlice in class OutputWriter<ByteBuffer>

Throws:

IOException - in the event of failure

endShard

public void endShard()

Description copied from class: OutputWriter

Called when no more output will be written to this writer.

Overrides:

endShard in class OutputWriter<ByteBuffer>

getFile

public com.google.appengine.api.files.AppEngineFile getFile()

Returns the file or null if file was not finalized.