Hi all,
L set the scheme for DataStreamReader but when I print the scheme.It just
printed:
root
|--value:string (nullable=true)
My code is
val line = ss.readStream.format("socket")
.option("ip",xxx)
.option("port",xxx)
.scheme(StructField("name",StringType??::(StructField("age", IntegerType))).load
line.printSchema
My spark version is 2.1.0.
I want the printSchema prints the schema I set in the code.How should I do
please?
And my original target is the received data from socket is handled as schema
directly.What should I do please?
thanks
Fei Shao
