斯卡拉。製作類通用

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[_]])) 
    } 
}