Thank you for your quick answer.
It helped me to find an implicit conversion for JavaInputDStream which
takes implicit ClassTag.
Cheers.
On Thu, Dec 17, 2015 at 3:11 PM, Saisai Shao wrote:
> Actually this is a Scala problem. createDirectStream actually requires
> implicit values, which is impli
Actually this is a Scala problem. createDirectStream actually requires
implicit values, which is implied as context bound, Java does not have the
equivalence, so here change the java class to the ClassTag, and make it as
implicit value, it will be used by createDirectStream.
Thanks
Saisai
On Th
Hi,
I am reading spark streaming Kafka code.
In org.apache.spark.streaming.kafka.KafkaUtils file,
the function "createDirectStream" takes key class, value class, etc to
create classTag.
However, they are all implicit. I don't understand why they are implicit.
In fact, I can not find any other ov
