Package | Description |
---|---|
com.google.appengine.tools.mapreduce | |
com.google.appengine.tools.mapreduce.impl | |
com.google.appengine.tools.mapreduce.outputs |
Constructor and Description |
---|
MapReduceSpecification.Builder(Input<I> input,
Mapper<I,K,V> mapper,
Reducer<K,V,O> reducer,
Output<O,R> output) |
MapSpecification.Builder(Input<I> input,
MapOnlyMapper<I,O> mapper,
Output<O,R> output) |
Modifier and Type | Class and Description |
---|---|
class |
GoogleCloudStorageMapOutput<K,V>
An
Output that is used for the map stage. |
class |
GoogleCloudStorageMergeOutput
Defines the way data is written out by the merging stage.
|
class |
GoogleCloudStorageSortOutput
Defines the way data is written out by the sorter.
|
Modifier and Type | Method and Description |
---|---|
static Output |
InProcessUtil.getOutput(MapReduceSpecification spec) |
static Output |
InProcessUtil.getOutput(MapSpecification spec) |
Constructor and Description |
---|
WorkerController(String mrJobId,
Counters initialCounters,
Output<O,R> output,
String resultPromiseHandle) |
Modifier and Type | Class and Description |
---|---|
class |
BigQueryGoogleCloudStorageStoreOutput<O>
An
Output that writes files in Google cloud storage using a format compatible with
bigquery ingestion. |
class |
BlobFileOutput
An
Output that writes bytes to a set of blob files, one per shard. |
class |
DatastoreOutput
An
Output that writes Entity s to the Datastore. |
class |
GoogleCloudStorageFileOutput
An
Output that writes bytes to a set of Cloud Storage files, one per shard. |
class |
GoogleCloudStorageLevelDbOutput
An composition of
GoogleCloudStorageFileOutput with
GoogleCloudStorageLevelDbOutput that pads blocks to GCS write boundaries on end of slice. |
class |
InMemoryOutput<O>
An
Output that collects all values in memory and returns them on
InMemoryOutput.finish(java.util.Collection<? extends com.google.appengine.tools.mapreduce.OutputWriter<O>>) . |
class |
LevelDbOutput<R>
An
Output that writes LevelDb records. |
class |
MarshallingOutput<O,R>
An
Output that marshalls records. |
class |
NoOutput<O,R>
An
Output that throws an exception whenever an attempt is made to
write a value. |
class |
SizeSegmentedGoogleCloudStorageFileOutput
An
Output that writes files to GCS segmented by specified size limit. |
class |
StringOutput<O,R>
An output that accepts objects, invokes
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 . |
Constructor and Description |
---|
LevelDbOutput(Output<ByteBuffer,R> sink) |
MarshallingOutput(Output<ByteBuffer,R> sink,
Marshaller<O> marshaller) |
StringOutput(com.google.common.base.Function<O,String> fn,
String terminator,
String charsetName,
Output<ByteBuffer,R> sink) |
StringOutput(String terminator,
Output<ByteBuffer,R> sink) |
StringOutput(String terminator,
String charsetName,
Output<ByteBuffer,R> sink) |
Copyright © 2015 Google. All rights reserved.