public class GoraMapper<K1,V1 extends Persistent,K2,V2>
extends org.apache.hadoop.mapreduce.Mapper<K1,V1,K2,V2>
Mapper
s.Constructor and Description |
---|
GoraMapper() |
Modifier and Type | Method and Description |
---|---|
static <K1,V1 extends Persistent,K2,V2> |
initMapperJob(org.apache.hadoop.mapreduce.Job job,
Class<? extends DataStore<K1,V1>> dataStoreClass,
Class<K1> inKeyClass,
Class<V1> inValueClass,
Class<K2> outKeyClass,
Class<V2> outValueClass,
Class<? extends GoraMapper> mapperClass,
boolean reuseObjects)
Initializes the Mapper, and sets input parameters for the job.
|
static <K1,V1 extends Persistent,K2,V2> |
initMapperJob(org.apache.hadoop.mapreduce.Job job,
Class<? extends DataStore<K1,V1>> dataStoreClass,
Class<K1> inKeyClass,
Class<V1> inValueClass,
Class<K2> outKeyClass,
Class<V2> outValueClass,
Class<? extends GoraMapper> mapperClass,
Class<? extends org.apache.hadoop.mapreduce.Partitioner> partitionerClass,
boolean reuseObjects)
Initializes the Mapper, and sets input parameters for the job.
|
static <K1,V1 extends Persistent,K2,V2> |
initMapperJob(org.apache.hadoop.mapreduce.Job job,
DataStore<K1,V1> dataStore,
Class<K2> outKeyClass,
Class<V2> outValueClass,
Class<? extends GoraMapper> mapperClass,
boolean reuseObjects)
Initializes the Mapper, and sets input parameters for the job
|
static <K1,V1 extends Persistent,K2,V2> |
initMapperJob(org.apache.hadoop.mapreduce.Job job,
Query<K1,V1> query,
DataStore<K1,V1> dataStore,
Class<K2> outKeyClass,
Class<V2> outValueClass,
Class<? extends GoraMapper> mapperClass,
boolean reuseObjects)
Initializes the Mapper, and sets input parameters for the job
|
static <K1,V1 extends Persistent,K2,V2> |
initMapperJob(org.apache.hadoop.mapreduce.Job job,
Query<K1,V1> query,
DataStore<K1,V1> dataStore,
Class<K2> outKeyClass,
Class<V2> outValueClass,
Class<? extends GoraMapper> mapperClass,
Class<? extends org.apache.hadoop.mapreduce.Partitioner> partitionerClass,
boolean reuseObjects)
Initializes the Mapper, and sets input parameters for the job
|
public static <K1,V1 extends Persistent,K2,V2> void initMapperJob(org.apache.hadoop.mapreduce.Job job, Class<? extends DataStore<K1,V1>> dataStoreClass, Class<K1> inKeyClass, Class<V1> inValueClass, Class<K2> outKeyClass, Class<V2> outValueClass, Class<? extends GoraMapper> mapperClass, Class<? extends org.apache.hadoop.mapreduce.Partitioner> partitionerClass, boolean reuseObjects) throws IOException
job
- the job to set the properties fordataStoreClass
- the datastore classinKeyClass
- Map input key classinValueClass
- Map input value classoutKeyClass
- Map output key classoutValueClass
- Map output value classmapperClass
- the mapper class extending GoraMapperpartitionerClass
- optional partitioner classreuseObjects
- whether to reuse objects in serializationIOException
public static <K1,V1 extends Persistent,K2,V2> void initMapperJob(org.apache.hadoop.mapreduce.Job job, Class<? extends DataStore<K1,V1>> dataStoreClass, Class<K1> inKeyClass, Class<V1> inValueClass, Class<K2> outKeyClass, Class<V2> outValueClass, Class<? extends GoraMapper> mapperClass, boolean reuseObjects) throws IOException
job
- the job to set the properties fordataStoreClass
- the datastore classinKeyClass
- Map input key classinValueClass
- Map input value classoutKeyClass
- Map output key classoutValueClass
- Map output value classmapperClass
- the mapper class extending GoraMapperreuseObjects
- whether to reuse objects in serializationIOException
public static <K1,V1 extends Persistent,K2,V2> void initMapperJob(org.apache.hadoop.mapreduce.Job job, Query<K1,V1> query, DataStore<K1,V1> dataStore, Class<K2> outKeyClass, Class<V2> outValueClass, Class<? extends GoraMapper> mapperClass, Class<? extends org.apache.hadoop.mapreduce.Partitioner> partitionerClass, boolean reuseObjects) throws IOException
job
- the job to set the properties forquery
- the query to get the inputs fromdataStore
- the datastore as the inputoutKeyClass
- Map output key classoutValueClass
- Map output value classmapperClass
- the mapper class extending GoraMapperpartitionerClass
- optional partitioner classreuseObjects
- whether to reuse objects in serializationIOException
public static <K1,V1 extends Persistent,K2,V2> void initMapperJob(org.apache.hadoop.mapreduce.Job job, DataStore<K1,V1> dataStore, Class<K2> outKeyClass, Class<V2> outValueClass, Class<? extends GoraMapper> mapperClass, boolean reuseObjects) throws IOException
job
- the job to set the properties fordataStore
- the datastore as the inputoutKeyClass
- Map output key classoutValueClass
- Map output value classmapperClass
- the mapper class extending GoraMapperreuseObjects
- whether to reuse objects in serializationIOException
public static <K1,V1 extends Persistent,K2,V2> void initMapperJob(org.apache.hadoop.mapreduce.Job job, Query<K1,V1> query, DataStore<K1,V1> dataStore, Class<K2> outKeyClass, Class<V2> outValueClass, Class<? extends GoraMapper> mapperClass, boolean reuseObjects) throws IOException
job
- the job to set the properties forquery
- the query to get the inputs fromdataStore
- the datastore as the inputoutKeyClass
- Map output key classoutValueClass
- Map output value classmapperClass
- the mapper class extending GoraMapperreuseObjects
- whether to reuse objects in serializationIOException
Copyright © 2010-2015 The Apache Software Foundation. All Rights Reserved.