org.apache.pig.backend.hadoop.executionengine.mapReduceLayer

Class PigMapBase

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.Text,Tuple,PigNullableWritable,org.apache.hadoop.io.Writable>

org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapBase

org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapBase

Direct Known Subclasses:

PigGenericMapReduce.Map, PigGenericMapReduce.MapWithComparator, PigMapOnly.Map, PigMapReduceCounter.PigMapCounter

public abstract class PigMapBase
extends PigGenericMapBase

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	PigMapBase.IllustratorContext

Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Mapper

org.apache.hadoop.mapreduce.Mapper.Context

Field Summary

Fields inherited from class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapBase

errorInMap, keyType, mp, stores, tf

Constructor Summary

Constructors

Constructor and Description
PigMapBase()

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.mapreduce.Mapper.Context	getIllustratorContext(org.apache.hadoop.conf.Configuration conf, DataBag input, List<Pair<PigNullableWritable,org.apache.hadoop.io.Writable>> output, org.apache.hadoop.mapreduce.InputSplit split) Get mapper's illustrator context
boolean	inIllustrator(org.apache.hadoop.mapreduce.Mapper.Context context)

Methods inherited from class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapBase

cleanup, collect, getKeyType, map, runPipeline, setKeyType, setMapPlan, setup

Methods inherited from class org.apache.hadoop.mapreduce.Mapper

run

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PigMapBase

public PigMapBase()

Method Detail

getIllustratorContext

public org.apache.hadoop.mapreduce.Mapper.Context getIllustratorContext(org.apache.hadoop.conf.Configuration conf,
                                                                        DataBag input,
                                                                        List<Pair<PigNullableWritable,org.apache.hadoop.io.Writable>> output,
                                                                        org.apache.hadoop.mapreduce.InputSplit split)
                                                                 throws IOException,
                                                                        InterruptedException

Get mapper's illustrator context

Specified by:

getIllustratorContext in class PigGenericMapBase

Parameters:

conf - Configuration

input - Input bag to serve as data source

output - Map output buffer

split - the split

Returns:

Illustrator's context

Throws:

IOException

InterruptedException

inIllustrator

public boolean inIllustrator(org.apache.hadoop.mapreduce.Mapper.Context context)

Specified by:

inIllustrator in class PigGenericMapBase