Comment référencer sous-classes de classes Java statiques avec les génériques à Scala

Question

Je le code Java:

public class TestMapper extends AppEngineMapper<Key, Entity, NullWritable, NullWritable> { 
    public TestMapper() { 
    } 
// [... other overriden methods ...] 
     @Override 
     public void setup(Context context) { 
     log.warning("Doing per-worker setup"); 
     } 
} 

... que je suis converti à:

class TestMapper extends AppEngineMapper[Key, Entity, NullWritable, NullWritable] { 
// [... other overriden methods ...] 
     override def setup(context: Context) { 
     log.warning("Doing per-worker setup") 
     } 
} 

Maintenant, le problème réel :

Contexte est définie comme une cl imbriquée ass dans le org.apache.hadoop.mapreduce.Mapper classe: en fait

 public static class Mapper<KEYIN, VALUEIN, KEYOUT, VALUEOUT> { 
    //[... some other methods ...] 
protected void setup(org.apache.hadoop.mapreduce.Mapper<KEYIN,VALUEIN,KEYOUT,VALUEOUT>.Context context) throws java.io.IOException, java.lang.InterruptedException { /* compiled code */ } 
     public class Context extends org.apache.hadoop.mapreduce.MapContext<KEYIN,VALUEIN,KEYOUT,VALUEOUT> { 

     public Context(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.mapreduce.TaskAttemptID conf, org.apache.hadoop.mapreduce.RecordReader<KEYIN,VALUEIN> taskid, org.apache.hadoop.mapreduce.RecordWriter<KEYOUT,VALUEOUT> reader, org.apache.hadoop.mapreduce.OutputCommitter writer, org.apache.hadoop.mapreduce.StatusReporter committer, org.apache.hadoop.mapreduce.InputSplit reporter) throws java.io.IOException, java.lang.InterruptedException { /* compiled code */ } 

     } 

donc je ne peux pas dire ma classe Scala où/ce contexte est. Si Mapper avait pas de génériques que je pourrais faire référence à Contexte via

Mapper#Context 

mais comment puis-je dire que Mapper a Generics?

Mapper[_,_,_,_]#Context 

... ne fonctionne pas.

Answer 1

Vous devez fournir le type exact de base pour votre projection de type, dans votre cas

Mapper[Key, Entity, NullWritable, NullWritable]#Context 

donc primordial setup serait écrit comme

override def setup(context: Mapper[Key, Entity, NullWritable, NullWritable]#Context) 

Utilisation peut être simplifiée par l'introduction d'un alias de type

class TestMapper extends AppEngineMapper[Key, Entity, NullWritable, NullWritable] { 

    type Context = Mapper[Key, Entity, NullWritable, NullWritable]#Context 

    override def setup(context: Context) = { 
     // ... 
    } 
} 

Si vous souhaitez écrire plusieurs mappeurs vous pouvez factoriser cela en un trait qui peut être mélangé dans votre mise en œuvre:

trait SMapper[A,B,C,D] extends Mapper[A,B,C,D] { 
    type Context = Mapper[A,B,C,D]#Context 
} 

class TestMapper extends AppEngineMapper[Key, Entity, NullWritable, NullWritable] 
        with SMapper[Key, Entity, NullWritable, NullWritable] { 
    override def setup(context: Context) = { 
    // ... 
    } 
} 

ou pour Hadoop plaine:

class TestMapper extends SMapper[Key, Entity, NullWritable, NullWritable] { 
    override def setup(context: Context) = { 
    // ... 
    } 
} 

Answer 2

Les problèmes que les gens ont parfois lorsque vous utilisez la réponse acceptée sont dues à un bogue dans Compilateur Scala (link).