| Modifier and Type | Method and Description |
|---|---|
static PigNullableWritable |
HDataType.getWritableComparable(String className) |
static PigNullableWritable |
HDataType.getWritableComparableTypes(byte type) |
static PigNullableWritable |
HDataType.getWritableComparableTypes(Object o,
byte keyType) |
| Modifier and Type | Method and Description |
|---|---|
static byte |
HDataType.findTypeFromNullableWritable(PigNullableWritable o) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
PigGenericMapReduce.Reduce.reduce(PigNullableWritable key,
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,
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,
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,
Iterable<NullableTuple> tupIter,
org.apache.hadoop.mapreduce.Reducer.Context context)
The reduce function which removes values.
|
| Modifier and Type | Method and Description |
|---|---|
abstract org.apache.hadoop.mapreduce.Mapper.Context |
PigGenericMapBase.getIllustratorContext(org.apache.hadoop.conf.Configuration conf,
DataBag input,
List<Pair<PigNullableWritable,org.apache.hadoop.io.Writable>> output,
org.apache.hadoop.mapreduce.InputSplit split) |
abstract org.apache.hadoop.mapreduce.Reducer.Context |
PigGenericMapReduce.Reduce.getIllustratorContext(org.apache.hadoop.mapred.jobcontrol.Job job,
List<Pair<PigNullableWritable,org.apache.hadoop.io.Writable>> input,
POPackage pkg)
Get reducer's illustrator context
|
| Modifier and Type | Field and Description |
|---|---|
static Map<PigNullableWritable,DiscreteProbabilitySampleGenerator> |
WeightedRangePartitioner.weightedParts |
| Modifier and Type | Method and Description |
|---|---|
int |
WeightedRangePartitioner.getPartition(PigNullableWritable key,
org.apache.hadoop.io.Writable value,
int numPartitions) |
int |
SkewedPartitioner.getPartition(PigNullableWritable wrappedKey,
org.apache.hadoop.io.Writable value,
int numPartitions) |
int |
SecondaryKeyPartitioner.getPartition(PigNullableWritable key,
org.apache.hadoop.io.Writable value,
int numPartitions) |
| Modifier and Type | Method and Description |
|---|---|
void |
POPackage.attachInput(PigNullableWritable k,
Iterator<NullableTuple> inp)
Attaches the required inputs
|
void |
POMultiQueryPackage.attachInput(PigNullableWritable k,
Iterator<NullableTuple> inp) |
| Modifier and Type | Class and Description |
|---|---|
class |
NullableBag |
class |
NullableBigDecimalWritable |
class |
NullableBigIntegerWritable |
class |
NullableBooleanWritable |
class |
NullableBytesWritable |
class |
NullableDateTimeWritable |
class |
NullableDoubleWritable |
class |
NullableFloatWritable |
class |
NullableIntWritable |
class |
NullableLongWritable |
class |
NullablePartitionWritable
NullablePartitionWritable is an adaptor class around PigNullableWritable that adds a partition
index to the class.
|
class |
NullableText |
class |
NullableTuple |
class |
NullableUnknownWritable
This class can be used when data type is 'Unknown' and
there is a need for PigNullableWritable object.
|
| Modifier and Type | Method and Description |
|---|---|
PigNullableWritable |
NullablePartitionWritable.getKey() |
| Modifier and Type | Method and Description |
|---|---|
void |
NullablePartitionWritable.setKey(PigNullableWritable k) |
| Constructor and Description |
|---|
NullablePartitionWritable(PigNullableWritable k) |
Copyright © 2007-2012 The Apache Software Foundation