Partition分区案例实操
import org.apache.hadoop.io.Text;import org.apache.hadoop.mapreduce.Partitioner;//这里的kv是mapper输出的kvpublic class ProvincePartitioner extends Partitioner<Text,FlowBean> { public int getPa...