我是spark的新手,我想知道是否有一种方法可以通过 SparkContext
/ SQLContext
API?
我在看astbuilder.scala和sparksqlparser.scala,但看起来它们使用visit回调方法将查询解析为ast,并在ddl.scala中调用不同的函数。
如果没有,你将如何实现一个方法,告诉我们使用spark SQLContext
API?
我是spark的新手,我想知道是否有一种方法可以通过 SparkContext
/ SQLContext
API?
我在看astbuilder.scala和sparksqlparser.scala,但看起来它们使用visit回调方法将查询解析为ast,并在ddl.scala中调用不同的函数。
如果没有,你将如何实现一个方法,告诉我们使用spark SQLContext
API?
暂无答案!
目前还没有任何答案,快来回答吧!