Closed sehyod closed 2 years ago
Add new listSql and aggregateSql methods that take a SparkSession and a table name instead of a Dataframe Add tests for these new methods (The csv are registered as SQL temporary views in the sprak session)
listSql
aggregateSql
SparkSession
Dataframe
Add new
listSql
andaggregateSql
methods that take aSparkSession
and a table name instead of aDataframe
Add tests for these new methods (The csv are registered as SQL temporary views in the sprak session)