com.google.appengine.tools.mapreduce.inputs

Class GoogleCloudStorageLevelDbInput

java.lang.Object

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

com.google.appengine.tools.mapreduce.inputs.GoogleCloudStorageLevelDbInput

All Implemented Interfaces:

Serializable

public final class GoogleCloudStorageLevelDbInput
extends Input<ByteBuffer>

GoogleCloudStorageLevelDbInput creates LevelDbInputReaders to read input written out by LevelDbOutput to files in Google Cloud Storage.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GoogleCloudStorageLevelDbInput(GoogleCloudStorageFileSet files)
GoogleCloudStorageLevelDbInput(GoogleCloudStorageFileSet files, int bufferSize)

Method Summary

Methods

Modifier and Type	Method and Description
List<InputReader<ByteBuffer>>	createReaders() Returns a list of readers for this input.

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

getContext

Methods inherited from class java.lang.Object

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

Constructor Detail

GoogleCloudStorageLevelDbInput

public GoogleCloudStorageLevelDbInput(GoogleCloudStorageFileSet files)

GoogleCloudStorageLevelDbInput

public GoogleCloudStorageLevelDbInput(GoogleCloudStorageFileSet files,
                              int bufferSize)

Parameters:

files - The set of files to create readers for. One reader per file.

bufferSize - The size of the buffer used for each file.

Method Detail

createReaders

public List<InputReader<ByteBuffer>> createReaders()

Description copied from class: Input

Returns a list of readers for this input. It is the Input's responsibility to determine an appropriate number of readers to split into. This could be specified by the user or determined algorithmically. The number of input readers returned determines the number of map shards.

Specified by:

createReaders in class Input<ByteBuffer>