Hi all,

I want to create an empty rdd and partition it

val  buffer: RDD[(K, (V, Int))] = base.context.emptyRDD[(K, (V,
Int))].partitionBy(new HashPartitioner(5))
but got Error: No ClassTag available for K

scala needs at runtime to have information about K , but how to solve this?

Thanks in advance.

Tenghuan

Reply via email to