Package | Description |
---|---|
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | |
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | |
org.apache.pig.data |
This package contains implementations of Pig specific data types as well as
support functions for reading, writing, and using all Pig data types.
|
org.apache.pig.impl.io |
Modifier and Type | Method and Description |
---|---|
protected void |
PigGenericMapReduce.Reduce.reduce(PigNullableWritable key,
java.lang.Iterable<NullableTuple> tupIter,
org.apache.hadoop.mapreduce.Reducer.Context context)
The reduce function which packages the key and List<Tuple>
into key, Bag<Tuple> after converting Hadoop type key into Pig type.
|
protected void |
PigGenericMapReduce.ReduceWithComparator.reduce(PigNullableWritable key,
java.lang.Iterable<NullableTuple> tupIter,
org.apache.hadoop.mapreduce.Reducer.Context context)
The reduce function which packages the key and List<Tuple>
into key, Bag<Tuple> after converting Hadoop type key into Pig type.
|
protected void |
PigCombiner.Combine.reduce(PigNullableWritable key,
java.lang.Iterable<NullableTuple> tupIter,
org.apache.hadoop.mapreduce.Reducer.Context context)
The reduce function which packages the key and List <Tuple>
into key, Bag<Tuple> after converting Hadoop type key into Pig type.
|
protected void |
DistinctCombiner.Combine.reduce(PigNullableWritable key,
java.lang.Iterable<NullableTuple> tupIter,
org.apache.hadoop.mapreduce.Reducer.Context context)
The reduce function which removes values.
|
Modifier and Type | Method and Description |
---|---|
Tuple |
Packager.getValueTuple(PigNullableWritable keyWritable,
NullableTuple ntup,
int index) |
Tuple |
MultiQueryPackager.getValueTuple(PigNullableWritable keyWritable,
NullableTuple ntup,
int origIndex) |
Tuple |
LitePackager.getValueTuple(PigNullableWritable keyWritable,
NullableTuple ntup,
int index)
Makes use of the superclass method, but this requires an additional
parameter key passed by ReadOnceBag.
|
Tuple |
CombinerPackager.getValueTuple(PigNullableWritable keyWritable,
NullableTuple ntup,
int index) |
Modifier and Type | Method and Description |
---|---|
void |
POPackage.attachInput(PigNullableWritable k,
java.util.Iterator<NullableTuple> inp)
Attaches the required inputs
|
Constructor and Description |
---|
POPackage.POPackageTupleBuffer(int batchSize,
java.lang.Object key,
java.util.Iterator<NullableTuple> iter) |
Modifier and Type | Field and Description |
---|---|
protected java.util.Iterator<NullableTuple> |
ReadOnceBag.tupIter |
Constructor and Description |
---|
ReadOnceBag(Packager pkgr,
java.util.Iterator<NullableTuple> tupIter,
PigNullableWritable keyWritable)
This constructor creates a bag out of an existing iterator
of tuples by taking ownership of the iterator and NOT
copying the elements of the iterator.
|
Constructor and Description |
---|
NullableTuple(NullableTuple copy) |
Copyright © 2007-2012 The Apache Software Foundation