| Interface | Description |
|---|---|
| Context |
MapReduce context.
|
| Counter |
Counter is an integer variable that is aggregated across multiple shards.
|
| Counters |
Collection of all counters.
|
| MapOnlyMapperContext<O> |
Context for
MapOnlyMapper execution. |
| MapperContext<K,V> |
A context for mapper execution.
|
| MapReduceResult<R> |
Result of a
MapReduceJob or MapJob. |
| ReducerContext<O> |
Context for
Reducer execution. |
| ShardContext |
Context for each shard.
|
| Sharder |
Used to determine which shard an item belongs to.
|
| WorkerContext<O> |
Context for each worker (mapper or reducer) shard.
|
| Class | Description |
|---|---|
| BigQueryMarshaller<T> |
An implementation of this class should serialize the objects of type T into newline separated
json as expected by the bigquery load jobs.
|
| CounterNames |
Built-in counter names.
|
| DatastoreMutationPool |
DatastoreMutationPool allows you to pool datastore operations such that they
are applied in batches, requiring fewer datastore API calls.
|
| DatastoreMutationPool.Params |
DatastoreMutationPool params.
|
| DatastoreMutationPool.Params.Builder |
DatastoreMutationPool Params builder.
|
| GoogleCloudStorageFileSet |
An ordered list of files in GCS.
|
| Input<I> |
Input is the data source specification for the job.
|
| InputReader<I> |
Reads data from an input source.
|
| KeyValue<K,V> |
Key-value pair.
|
| MapJob<I,O,R> |
A Pipeline job that runs a map jobs.
|
| MapOnlyMapper<I,O> |
Map function for Map only jobs.
|
| Mapper<I,K,V> |
Map function for MapReduce computations.
|
| MapReduceJob<I,K,V,O,R> |
A Pipeline job that runs a MapReduce.
|
| MapReduceServlet |
Servlet for all MapReduce API related functions.
|
| MapReduceSettings |
Settings that affect how a MapReduce is executed.
|
| MapReduceSettings.Builder | |
| MapReduceSpecification<I,K,V,O,R> |
Specification for a MapReduce job.
|
| MapReduceSpecification.Builder<I,K,V,O,R> | |
| MapSettings |
Settings that affect how a Map job is executed.
|
| MapSettings.Builder | |
| MapSpecification<I,O,R> |
Specification for a map-only job.
|
| MapSpecification.Builder<I,O,R> | |
| Marshaller<T> |
Turns objects of type
T into bytes and back. |
| Marshallers |
Some
Marshallers and related utilities. |
| Output<O,R> |
Defines where output should go.
|
| OutputWriter<O> |
Writes key-value pairs.
|
| Reducer<K,V,O> |
Reduce function for use in MapReduce.
|
| ReducerInput<V> |
Enumerates the reducer's input values for a given key.
|
| Worker<C extends WorkerContext<?>> |
| Enum | Description |
|---|---|
| BigQueryFieldMode |
The supported bigquery field modes.
|
| Exception | Description |
|---|---|
| CorruptDataException |
The exception generated if any of the data appears to be corrupt.
|
| MapReduceJobException |
An exception that is thrown upon MapReduceJob failure.
|
| Annotation Type | Description |
|---|---|
| BigQueryDataField |
Annotation to provide additional information related to BigQuery data fields.
|
| BigQueryIgnore |
A annotation for fields that should not be part of the bigquery output.
|
Copyright © 2015 Google. All rights reserved.