Package org.apache.nutch.parse

Class ParseSegment.ParseSegmentPartitioner

java.lang.Object

org.apache.hadoop.mapreduce.Partitioner<Text,NutchWritable>

org.apache.nutch.parse.ParseSegment.ParseSegmentPartitioner

Enclosing class:

ParseSegment

public static class ParseSegment.ParseSegmentPartitioner
extends Partitioner<Text,NutchWritable>

Sends LATENCY_KEY to partition 0 so one reducer merges all TDigests.

Constructor Summary

Constructors

Constructor	Description
ParseSegmentPartitioner()

Method Summary

Modifier and Type	Method	Description
int	getPartition(Text key, NutchWritable value, int numPartitions)

Methods inherited from class java.lang.Object

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

Constructor Details

ParseSegmentPartitioner

public ParseSegmentPartitioner()

Method Details

getPartition

public int getPartition(Text key,
 NutchWritable value,
 int numPartitions)

Specified by:

getPartition in class Partitioner<Text,NutchWritable>