com.github.panhongan.util.hadoop

类 FirstKeyIntPartitioner

java.lang.Object

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

com.github.panhongan.util.hadoop.FirstKeyIntPartitioner

所有已实现的接口:

org.apache.hadoop.mapred.JobConfigurable, org.apache.hadoop.mapred.Partitioner<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

public class FirstKeyIntPartitioner
extends org.apache.hadoop.mapreduce.Partitioner<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
implements org.apache.hadoop.mapred.Partitioner<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

构造器概要

构造器

构造器和说明
FirstKeyIntPartitioner()

方法概要

方法

限定符和类型	方法和说明
void	configure(org.apache.hadoop.mapred.JobConf arg0)
int	getPartition(org.apache.hadoop.io.Text key, org.apache.hadoop.io.Text value, int numReduceTasks)

从类继承的方法 java.lang.Object

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

构造器详细资料

FirstKeyIntPartitioner

public FirstKeyIntPartitioner()

方法详细资料

getPartition

public int getPartition(org.apache.hadoop.io.Text key,
               org.apache.hadoop.io.Text value,
               int numReduceTasks)

指定者:

getPartition 在接口中 org.apache.hadoop.mapred.Partitioner<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

指定者:

getPartition 在类中 org.apache.hadoop.mapreduce.Partitioner<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>

configure

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

指定者:

configure 在接口中 org.apache.hadoop.mapred.JobConfigurable