我写了一个代码,它将直接将数据从 mysql 加载到数据集格式
Dataset<Row> sourceDataView = spark.read().format("jdbc")
.option("url", url).option("driver", driver)
.option("dbtable", "t_data_master").load()
.where(jnCond).select(srcColSel)
我能够以 ResultSet 形式获得查询的结果输出,但不能以 Dataset 形式获得。如何实现数据集类型的查询结果输出?