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

Class PigMapReduce.Reduce

java.lang.Object

org.apache.hadoop.mapreduce.Reducer<PigNullableWritable,NullableTuple,PigNullableWritable,org.apache.hadoop.io.Writable>

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

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

Direct Known Subclasses:

PigGenericMapReduce.ReduceWithComparator, PigMapReduceCounter.PigReduceCounter

Enclosing class:

PigMapReduce

public static class PigMapReduce.Reduce
extends PigGenericMapReduce.Reduce

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	PigMapReduce.Reduce.IllustratorContextImpl

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

org.apache.hadoop.mapreduce.Reducer.Context

Field Summary

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

errorInReduce, initialized, log, outputCollector, pack, rp, stores

Constructor Summary

Constructors

Constructor and Description
Reduce()

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.mapreduce.Reducer.Context	getIllustratorContext(org.apache.hadoop.mapred.jobcontrol.Job job, List<Pair<PigNullableWritable,org.apache.hadoop.io.Writable>> input, POPackage pkg) Get reducer's illustrator context
POPackage	getPack(org.apache.hadoop.mapreduce.Reducer.Context context)
boolean	inIllustrator(org.apache.hadoop.mapreduce.Reducer.Context context)

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

cleanup, processOnePackageOutput, reduce, runPipeline, setReducePlan, setup

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

run

Methods inherited from class java.lang.Object

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

Constructor Detail

Reduce

public Reduce()

Method Detail

getIllustratorContext

public org.apache.hadoop.mapreduce.Reducer.Context getIllustratorContext(org.apache.hadoop.mapred.jobcontrol.Job job,
                                                                         List<Pair<PigNullableWritable,org.apache.hadoop.io.Writable>> input,
                                                                         POPackage pkg)
                                                                  throws IOException,
                                                                         InterruptedException

Get reducer's illustrator context

Specified by:

getIllustratorContext in class PigGenericMapReduce.Reduce

Parameters:

input - Input buffer as output by maps

pkg - package

Returns:

reducer's illustrator context

Throws:

IOException

InterruptedException

inIllustrator

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

Specified by:

inIllustrator in class PigGenericMapReduce.Reduce

getPack

public POPackage getPack(org.apache.hadoop.mapreduce.Reducer.Context context)

Specified by:

getPack in class PigGenericMapReduce.Reduce