斯卡拉。制作类通用

Question

我有这样的代码，一遍又一遍地出现在我的项目为每个类型的类，我们序列化的Avro

class FooKryoRegistrator extends KryoRegistrator { 
    override def registerClasses(kryo: Kryo) { 
    kryo.register(classOf[Foo], SpecificRecordBinarySerializer(classTag[Foo]))  
    kryo.register(classOf[GenericData.Array[_]], new SpecificInstanceCollectionSerializer(classOf[java.util.ArrayList[_]])) 
    } 
} 

现在，而不必写这Registrator类为每个实体（富，Bar，Baz .....）在我的项目中，我认为这会更好。所以，我没有

class GenericKryoRegistrator[T] extends KryoRegistrator { 
    override def registerClasses(kryo: Kryo) { 
    kryo.register(classOf[T], SpecificRecordBinarySerializer(classTag[T]))  
    kryo.register(classOf[GenericData.Array[_]], new SpecificInstanceCollectionSerializer(classOf[java.util.ArrayList[_]])) 
    } 
} 

，但我得到一个编译时错误

class type required but T found 

我GOOGLE了这个错误，我发现我应该使用，而不是类ClassTag的建议。所以我改变了实施

class GenericKryoRegistrator[T] extends KryoRegistrator { 
    override def registerClasses(kryo: Kryo) { 
    kryo.register(classTag[T].runtimeClass, SpecificRecordBinarySerializer(classTag[T]))  
    kryo.register(classOf[GenericData.Array[_]], new SpecificInstanceCollectionSerializer(classOf[java.util.ArrayList[_]])) 
    } 
} 

，但现在它说

No ClassTag available for T 

Answer 1

如果你把类标签作为一个隐含参数到您的类，然后你可以使用它：

class GenericKryoRegistrator[T] (implicit ct: ClassTag[T]) extends KryoRegistrator { 
    override def registerClasses(kryo: Kryo) { 
    kryo.register(ct.runtimeClass, SpecificRecordBinarySerializer(ct)) 
    kryo.register(classOf[GenericData.Array[_]], new SpecificInstanceCollectionSerializer(classOf[java.util.ArrayList[_]])) 
    } 
}