public class GoraReducer<K1,V1,K2,V2 extends Persistent>
extends org.apache.hadoop.mapreduce.Reducer<K1,V1,K2,V2>
Reducer
s.Constructor and Description |
---|
GoraReducer() |
Modifier and Type | Method and Description |
---|---|
static <K1,V1,K2,V2 extends Persistent> |
initReducerJob(org.apache.hadoop.mapreduce.Job job,
Class<? extends DataStore<K2,V2>> dataStoreClass,
Class<K2> keyClass,
Class<V2> persistentClass,
Class<? extends GoraReducer<K1,V1,K2,V2>> reducerClass,
boolean reuseObjects)
Initializes the Reducer, and sets output parameters for the job.
|
static <K1,V1,K2,V2 extends Persistent> |
initReducerJob(org.apache.hadoop.mapreduce.Job job,
DataStore<K2,V2> dataStore,
Class<? extends GoraReducer<K1,V1,K2,V2>> reducerClass)
Initializes the Reducer, and sets output parameters for the job.
|
static <K1,V1,K2,V2 extends Persistent> |
initReducerJob(org.apache.hadoop.mapreduce.Job job,
DataStore<K2,V2> dataStore,
Class<? extends GoraReducer<K1,V1,K2,V2>> reducerClass,
boolean reuseObjects)
Initializes the Reducer, and sets output parameters for the job.
|
public static <K1,V1,K2,V2 extends Persistent> void initReducerJob(org.apache.hadoop.mapreduce.Job job, Class<? extends DataStore<K2,V2>> dataStoreClass, Class<K2> keyClass, Class<V2> persistentClass, Class<? extends GoraReducer<K1,V1,K2,V2>> reducerClass, boolean reuseObjects)
job
- the job to set the properties fordataStoreClass
- the datastore classkeyClass
- output key classpersistentClass
- output value classreducerClass
- the reducer class extending GoraReducerreuseObjects
- whether to reuse objects in serializationpublic static <K1,V1,K2,V2 extends Persistent> void initReducerJob(org.apache.hadoop.mapreduce.Job job, DataStore<K2,V2> dataStore, Class<? extends GoraReducer<K1,V1,K2,V2>> reducerClass)
job
- the job to set the properties fordataStore
- the datastore as the outputreducerClass
- the reducer class extending GoraReducerpublic static <K1,V1,K2,V2 extends Persistent> void initReducerJob(org.apache.hadoop.mapreduce.Job job, DataStore<K2,V2> dataStore, Class<? extends GoraReducer<K1,V1,K2,V2>> reducerClass, boolean reuseObjects)
job
- the job to set the properties fordataStore
- the datastore as the outputreducerClass
- the reducer class extending GoraReducerreuseObjects
- whether to reuse objects in serializationCopyright © 2010-2014 The Apache Software Foundation. All Rights Reserved.