Hi All,

 have the following code and I am not sure what's wrong with it? I cannot call dataset.toJSON() (which returns a DataSet) ? I am using spark 2.2.0 so I am wondering if there is any work around?

 Dataset<String> ds = newDS.toJSON().map(()->{some function that returns a string});
 StreamingQuery query = ds.writeStream().start();
 query.awaitTermination();