org.apache.hadoop.chukwa.extraction.archive

Class ChukwaArchiveDailyPartitioner<K,V>

java.lang.Object

org.apache.hadoop.chukwa.extraction.archive.ChukwaArchiveDailyPartitioner<K,V>

All Implemented Interfaces:

org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Partitioner<ChukwaArchiveKey,ChunkImpl>

public class ChukwaArchiveDailyPartitioner<K,V>
extends Object
implements org.apache.hadoop.mapred.Partitioner<ChukwaArchiveKey,ChunkImpl>

Constructor Summary

Constructors

Constructor and Description
ChukwaArchiveDailyPartitioner()

Method Summary

Modifier and Type	Method and Description
void	configure(org.apache.hadoop.mapred.JobConf arg0)
int	getPartition(ChukwaArchiveKey key, ChunkImpl chunl, int numReduceTasks)

Methods inherited from class java.lang.Object

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

Constructor Detail

ChukwaArchiveDailyPartitioner

public ChukwaArchiveDailyPartitioner()

Method Detail

configure

public void configure(org.apache.hadoop.mapred.JobConf arg0)

Specified by:

configure in interface org.apache.hadoop.mapred.JobConfigurable

getPartition

public int getPartition(ChukwaArchiveKey key,
                        ChunkImpl chunl,
                        int numReduceTasks)

Specified by:

getPartition in interface org.apache.hadoop.mapred.Partitioner<ChukwaArchiveKey,ChunkImpl>