InputReader
for reading, after possibly having gone
through serialization and deserialization.
Output
that writes bytes to a set of blob files, one per shard.
OutputWriter
that writes bytes to a blob file that it creates.
limit
(exclusive).
Output
that writes
Entity
s to the Datastore.
emit(KeyValue.of(key, value))
getContext().emit(value)
InputReader
for serialization.
MapReduceResult.getOutputResult()
.
null
.
Output
's
StringOutput.finish(java.util.Collection<? extends com.google.appengine.tools.mapreduce.OutputWriter<O>>)
method returns.
InputReader
delegates to another implementation.
b
between
b.position()
and
b.limit()
.
Marshaller
for
ByteBuffer
.
Counter
with the given name.
Counters
object for doing simple aggregate calculations.
Marshaller
for
Integers
s that uses a more
efficient representation than
Marshallers.getSerializationMarshaller()
.
Marshaller
for key-value pairs based on
keyMarshaller
and
valueMarshaller
.
Marshaller
for key-values pairs based on
keyMarshaller
and
valueMarshaller
.
Marshaller
for
Long
s that uses a more efficient
representation than
Marshallers.getSerializationMarshaller()
.
Output.finish(java.util.Collection<? extends com.google.appengine.tools.mapreduce.OutputWriter<O>>)
or
null
if completed unsuccessfully.
Marshaller
that uses Java Serialization.
Marshaller
for
String
s.
Marshaller
for
Void
.
Output
that writes bytes to a set of Cloud Storage files, one per shard.
OutputWriter
that writes bytes to a GCS file that it creates.
LevelDbOutput
to files in
Google Cloud Storage.
GoogleCloudStorageFileOutput
with
GoogleCloudStorageLevelDbOutput
that pads blocks to GCS write boundaries on end of slice.
GoogleCloudStorageLevelDbOutputWriter
and
GoogleCloudStorageFileOutputWriter
that pads blocks to GCS write boundaries on end of
slice.
Counter
with the given name by
delta
.
Counter
with the given name by 1.
Output
that collects all values in memory and returns them on
InMemoryOutput.finish(java.util.Collection<? extends com.google.appengine.tools.mapreduce.OutputWriter<O>>)
.
Output
that writes LevelDb records.
MapOnlyMapper
execution.
MapReduceJob
or
MapJob
.
NoOutput
as output.
T
into bytes and back.
Marshaller
s and related utilities.
Output
that marshalls records.
OutputWriter
that marshalls records.
NoSuchElementException
when there is no more input data.
NoSuchElementException
when there is no more input data.
Input
that does not produce any values.
Output
that throws an exception whenever an attempt is made to
write a value.
MapJob
instead.
PeekingInputReader.next()
next.
InputReader
that allows peeking at records without consuming them.
Worker.getContext()
to emit output to the
Output
of the MapReduce.
Reducer
execution.
mapper
using
MapOnlyMapper.forMapper(Mapper)
.
KeyValue
s out to a number of output writers each corresponding to a different
shard A sharder and an Output object are provided in the constructor.
MapJob
with the given parameters in a new Pipeline.
MapReduceJob
with the given parameters in a new Pipeline.
Object.toString()
(or an arbitrary
other String-valued
Function
that is
Serializable
) on them,
adds an optional terminator, encodes the resulting String according to a
Charset
, and writes the result to an underlying
Output
.
ByteBuffer
b
with a serialized representation
of
object
between
b.position()
and
b.limit()
.
Input
that unmarshalls records.
InputReader
that unmarshals records.
Copyright © 2011 Google Inc. All Rights Reserved.