Uses of Class
com.google.appengine.tools.mapreduce.InputReader

Packages that use InputReader

Package	Description
com.google.appengine.tools.mapreduce
com.google.appengine.tools.mapreduce.impl
com.google.appengine.tools.mapreduce.impl.sort
com.google.appengine.tools.mapreduce.inputs

Uses of InputReader in com.google.appengine.tools.mapreduce

Methods in com.google.appengine.tools.mapreduce that return types with arguments of type InputReader

Modifier and Type	Method and Description
abstract List<? extends InputReader<I>>	Input.createReaders() Returns a list of readers for this input.

Uses of InputReader in com.google.appengine.tools.mapreduce.impl

Methods in com.google.appengine.tools.mapreduce.impl that return InputReader

Modifier and Type	Method and Description
protected abstract InputReader<I>	WorkerShardTask.getInputReader()
InputReader<KeyValue<K,Iterator<V>>>	ReduceShardTask.getInputReader()
InputReader<I>	MapShardTask.getInputReader()
InputReader<I>	MapOnlyShardTask.getInputReader()

Methods in com.google.appengine.tools.mapreduce.impl that return types with arguments of type InputReader

Modifier and Type	Method and Description
List<? extends InputReader<KeyValue<ByteBuffer,Iterator<ByteBuffer>>>>	GoogleCloudStorageMergeInput.createReaders() Creates multiple merging readers for each shard using GoogleCloudStorageMergeInput.createReaderForShard(com.google.appengine.tools.mapreduce.Marshaller<com.google.appengine.tools.mapreduce.KeyValue<java.nio.ByteBuffer, ? extends java.lang.Iterable<java.nio.ByteBuffer>>>, com.google.appengine.tools.mapreduce.GoogleCloudStorageFileSet) below.
List<? extends InputReader<KeyValue<ByteBuffer,ByteBuffer>>>	GoogleCloudStorageSortInput.createReaders()
List<? extends InputReader<KeyValue<K,Iterator<V>>>>	GoogleCloudStorageReduceInput.createReaders()

Constructors in com.google.appengine.tools.mapreduce.impl with parameters of type InputReader

Constructor and Description
MapOnlyShardTask(String mrJobId, int shardNumber, int shardCount, InputReader<I> in, MapOnlyMapper<I,O> mapper, OutputWriter<O> out, long millisPerSlice)
MapShardTask(String mrJobId, int shardNumber, int shardCount, InputReader<I> in, Mapper<I,K,V> mapper, OutputWriter<KeyValue<K,V>> out, long millisPerSlice)
ReduceShardTask(String mrJobId, int shardNumber, int shardCount, InputReader<KeyValue<K,Iterator<V>>> in, Reducer<K,V,O> reducer, OutputWriter<O> out, long millisPerSlice)

Uses of InputReader in com.google.appengine.tools.mapreduce.impl.sort

Methods in com.google.appengine.tools.mapreduce.impl.sort that return InputReader

Modifier and Type	Method and Description
InputReader<KeyValue<ByteBuffer,Iterator<ByteBuffer>>>	MergeShardTask.getInputReader()
InputReader<KeyValue<ByteBuffer,ByteBuffer>>	SortShardTask.getInputReader()

Constructors in com.google.appengine.tools.mapreduce.impl.sort with parameters of type InputReader

Constructor and Description
MergeShardTask(String mrJobId, int shardNumber, int shardCount, InputReader<KeyValue<ByteBuffer,Iterator<ByteBuffer>>> in, OutputWriter<KeyValue<ByteBuffer,List<ByteBuffer>>> out, int sortReadTimeMillis)
SortShardTask(String mrJobId, int shardNumber, int shardCount, InputReader<KeyValue<ByteBuffer,ByteBuffer>> in, SortWorker worker, OutputWriter<KeyValue<ByteBuffer,List<ByteBuffer>>> out, int sortReadTimeMillis)

Uses of InputReader in com.google.appengine.tools.mapreduce.inputs

Subclasses of InputReader in com.google.appengine.tools.mapreduce.inputs

Modifier and Type	Class and Description
class	ConcatenatingInputReader<I> Reads multiple inputs in sequence.
class	DatastoreInputReader An InputReader for Datastore entities.
class	DatastoreKeyInputReader An InputReader for Datastore entity keys.
class	ForwardingInputReader<T> An InputReader delegates to another implementation.
class	GoogleCloudStorageLevelDbInputReader A simple wrapper of LevelDb wrapper for GCS to provide getProgress() and do lazy initialization.
class	LevelDbInputReader Reads LevelDB formatted input.
class	LogInputReader Reads App Engine RequestLogs for a specified time range.
class	PeekingInputReader<T> An InputReader that allows peeking at records without consuming them.
class	UnmarshallingInputReader<T> An InputReader that unmarshals records.

Methods in com.google.appengine.tools.mapreduce.inputs that return InputReader

Modifier and Type	Method and Description
protected abstract InputReader<T>	ForwardingInputReader.getDelegate()

Methods in com.google.appengine.tools.mapreduce.inputs that return types with arguments of type InputReader

Modifier and Type	Method and Description
List<? extends InputReader<com.google.appengine.api.log.RequestLogs>>	LogInput.createReaders()
List<? extends InputReader<I>>	NoInput.createReaders()
List<? extends InputReader<I>>	InMemoryInput.createReaders()
List<InputReader<ByteBuffer>>	GoogleCloudStorageLevelDbInput.createReaders()
List<? extends InputReader<Long>>	ConsecutiveLongInput.createReaders()
List<? extends InputReader<Long>>	RandomLongInput.createReaders()
List<? extends InputReader<byte[]>>	GoogleCloudStorageLineInput.createReaders()
List<InputReader<I>>	UnmarshallingInput.createReaders()
List<? extends InputReader<byte[]>>	BlobstoreInput.createReaders()

Constructors in com.google.appengine.tools.mapreduce.inputs with parameters of type InputReader

Constructor and Description
PeekingInputReader(InputReader<ByteBuffer> reader, Marshaller<T> marshaller)
UnmarshallingInputReader(InputReader<ByteBuffer> reader, Marshaller<T> marshaller)

Constructor parameters in com.google.appengine.tools.mapreduce.inputs with type arguments of type InputReader

Constructor and Description
ConcatenatingInputReader(List<? extends InputReader<I>> readers)