Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1496#discussion_r150824372
--- Diff:
integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/dataload/TestLoadDataFrame.scala
---
@@ -199,6 +202,61 @@ class TestLoadDataFrame extends QueryTest with
BeforeAndAfterAll {
)
}
+ private def getSortColumnValue(tableName: String) = {
+ val desc = sql(s"desc formatted $tableName")
+ val sortColumnRow = desc.collect.find(r =>
+ r(0).asInstanceOf[String].trim.equalsIgnoreCase("SORT_COLUMNS")
+ )
+ assert(sortColumnRow.isDefined)
+ sortColumnRow.get.get(1).asInstanceOf[String].split(",")
+ .map(_.trim.toLowerCase).filter(_.length > 0)
+ }
+
+ private def getDefaultWriter(tableName: String) = {
--- End diff --
add output type in function signature
---
