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
Marshaller s 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.