Package | Description |
---|---|
com.google.appengine.tools.mapreduce | |
com.google.appengine.tools.mapreduce.impl | |
com.google.appengine.tools.mapreduce.inputs |
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) |
MapSpecification.Builder(Input<I> input,
MapOnlyMapper<I,Void> mapper)
A builder for map job using
NoOutput as output. |
Modifier and Type | Class and Description |
---|---|
class |
GoogleCloudStorageMergeInput
Defines the way the data is read in by the merger.
|
class |
GoogleCloudStorageReduceInput<K,V>
Defines the way the data is read in by the reducer.
|
class |
GoogleCloudStorageSortInput
Defines the way the data is read in by the Sort phase.
|
Modifier and Type | Method and Description |
---|---|
static Input |
InProcessUtil.getInput(MapReduceSpecification spec) |
static Input |
InProcessUtil.getInput(MapSpecification spec) |
Modifier and Type | Class and Description |
---|---|
class |
BlobstoreInput
BlobstoreLineInput shards files in Blobstore on separator boundaries.
|
class |
ConsecutiveLongInput
Produces all longs in a given interval.
|
class |
DatastoreInput
An input to read entities of a specified kind from the datastore.
|
class |
DatastoreKeyInput
An input to read entity keys of a specified kind from the datastore.
|
class |
GoogleCloudStorageLevelDbInput
GoogleCloudStorageLevelDbInput creates LevelDbInputReaders to read input written out by
LevelDbOutput to files in
Google Cloud Storage. |
class |
GoogleCloudStorageLineInput
CloudStorageLineInput shards files in Cloud Storage on separator boundries.
|
class |
InMemoryInput<I>
An input that returns values already in memory.
|
class |
LogInput
Reads RequestLogs from the App Engine Logs API
|
class |
NoInput<I>
An
Input that does not produce any values. |
class |
RandomLongInput
An input that produce random values.
|
class |
UnmarshallingInput<I>
An
Input that unmarshalls records. |
Constructor and Description |
---|
UnmarshallingInput(Input<ByteBuffer> input,
Marshaller<I> marshaller) |
Copyright © 2015 Google. All rights reserved.