Can something like this help?
public class CIMapper<T extends Cluster> extends
Mapper<WritableComparable<?>,VectorWritable,IntWritable,T> {
...
}
On 12-02-2012 06:48, Jeff Eastman wrote:
I'm wondering how to tease the elephant into accepting any concrete
instance of the interface o.a.m.clustering.Cluster when writing
trained clusters in the cleanup() method of CIMapper. I've gotten the
MR version of the ClusterIterator to get to that point in testing but
it blows chunks with an IOException when I try to pass a
o.a.m.clustering.kmeans.Cluster (I will rename the latter for 0.7).
Seems the MapTask.collect() wants == and not instanceof.
I've talked with Ted about passing Clusters rather than the current
ClusterObservations but don't see how at this point. Any ideas?