public class RepresentativePointsMapper extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.IntWritable,WeightedVectorWritable,org.apache.hadoop.io.IntWritable,WeightedVectorWritable>
Constructor and Description |
---|
RepresentativePointsMapper() |
Modifier and Type | Method and Description |
---|---|
protected void |
cleanup(org.apache.hadoop.mapreduce.Mapper.Context context) |
void |
configure(Map<Integer,List<VectorWritable>> referencePoints,
DistanceMeasure measure) |
static Map<Integer,List<VectorWritable>> |
getRepresentativePoints(org.apache.hadoop.conf.Configuration conf) |
static Map<Integer,List<VectorWritable>> |
getRepresentativePoints(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.Path statePath) |
protected void |
map(org.apache.hadoop.io.IntWritable clusterId,
WeightedVectorWritable point,
org.apache.hadoop.mapreduce.Mapper.Context context) |
static void |
mapPoint(org.apache.hadoop.io.IntWritable clusterId,
WeightedVectorWritable point,
DistanceMeasure measure,
Map<Integer,List<VectorWritable>> representativePoints,
Map<Integer,WeightedVectorWritable> mostDistantPoints) |
protected void |
setup(org.apache.hadoop.mapreduce.Mapper.Context context) |
protected void cleanup(org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
cleanup
in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.IntWritable,WeightedVectorWritable,org.apache.hadoop.io.IntWritable,WeightedVectorWritable>
IOException
InterruptedException
protected void map(org.apache.hadoop.io.IntWritable clusterId, WeightedVectorWritable point, org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
map
in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.IntWritable,WeightedVectorWritable,org.apache.hadoop.io.IntWritable,WeightedVectorWritable>
IOException
InterruptedException
public static void mapPoint(org.apache.hadoop.io.IntWritable clusterId, WeightedVectorWritable point, DistanceMeasure measure, Map<Integer,List<VectorWritable>> representativePoints, Map<Integer,WeightedVectorWritable> mostDistantPoints)
protected void setup(org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
setup
in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.IntWritable,WeightedVectorWritable,org.apache.hadoop.io.IntWritable,WeightedVectorWritable>
IOException
InterruptedException
public void configure(Map<Integer,List<VectorWritable>> referencePoints, DistanceMeasure measure)
public static Map<Integer,List<VectorWritable>> getRepresentativePoints(org.apache.hadoop.conf.Configuration conf)
public static Map<Integer,List<VectorWritable>> getRepresentativePoints(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path statePath)
Copyright © 2008–2017 The Apache Software Foundation. All rights reserved.