Hi cheers,
Would you like write samw code please?
I check the select method, i do not know how to cast it and how to set the
value.deserialize.
Thanks
---Original---
From: "Szuromi Tam??s"<trom...@gmail.com>
Date: 2017/7/24 16:32:52
To: "??????????"<1427357...@qq.com>;
Cc: "user"<user@spark.apache.org>;
Subject: Re: how to convert the binary from kafak to srring pleaae
Hi,
You can cast it to string in a select or you can set the value.deserializer
parameter for kafka.
cheers,
2017-07-24 4:44 GMT+02:00 ?????????? <1427357...@qq.com>:
Hi all
I want to change the binary from kafka to string. Would you like help me please?
val df = ss.readStream.format("kafka").option("kafka.bootstrap.server","xxxx")
.option("subscribe","xxxx")
.load
val value = df.select("value")
value.writeStream
.outputMode("append")
.format("console")
.start()
.awaitTermination()
Above code outputs result like:
+--------+
|value|
+---------+
|[61,61]|
+---------+
61 is character a receiced from kafka.
I want to print [a,a] or aa.
How should I do please?
