In spark 2.0 there is an addtional parameter of type ClassTag<T>  in the
broadcast method of the sparkContext

What is this variable and how to do broadcast now?

here is my exisitng code with 2.0.0-preview
Broadcast<Map<String, Long>> b = jsc.broadcast(u.collectAsMap());

what changes needs to be done in 2.0 for this
Broadcast<Map<String, Long>> b = jsc.broadcast(u.collectAsMap(), *??* );

Please help

Rohit

Reply via email to