org.apache.hadoop.chukwa.analysis.salsa.fsm

Class FSMIntermedEntryPartitioner

java.lang.Object

org.apache.hadoop.chukwa.analysis.salsa.fsm.FSMIntermedEntryPartitioner

All Implemented Interfaces:

org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Partitioner<ChukwaRecordKey,FSMIntermedEntry>

public class FSMIntermedEntryPartitioner
extends Object
implements org.apache.hadoop.mapred.Partitioner<ChukwaRecordKey,FSMIntermedEntry>

Constructor Summary

Constructors

Constructor and Description
FSMIntermedEntryPartitioner()

Method Summary

Methods

Modifier and Type	Method and Description
void	configure(org.apache.hadoop.mapred.JobConf job)
int	getPartition(ChukwaRecordKey key, FSMIntermedEntry val, int numPartitions)

Methods inherited from class java.lang.Object

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

Constructor Detail

FSMIntermedEntryPartitioner

public FSMIntermedEntryPartitioner()

Method Detail

getPartition

public int getPartition(ChukwaRecordKey key,
               FSMIntermedEntry val,
               int numPartitions)

Specified by:

getPartition in interface org.apache.hadoop.mapred.Partitioner<ChukwaRecordKey,FSMIntermedEntry>

configure

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

Specified by:

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