Github user xubo245 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2959#discussion_r237039754
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/CarbonSession.scala ---
@@ -80,32 +81,32 @@ class CarbonSession(@transient val sc: SparkContext,
new CarbonSession(sparkContext, Some(sharedState), useHiveMetaStore)
}
- /**
- * Run search mode if enabled, otherwise run SparkSQL
- */
+ /**
+ * Run search mode if enabled, otherwise run SparkSQL
+ */
override def sql(sqlText: String): DataFrame = {
withProfiler(
sqlText,
(qe, sse) => {
- new Dataset[Row](self, qe, RowEncoder(qe.analyzed.schema))
+ new Dataset[Row](self, qe, RowEncoder(qe.analyzed.schema))
}
)
}
- /**
- * Return true if the specified sql statement will hit the datamap
- * This API is for test purpose only
- */
+ /**
--- End diff --
no need to change, please keep the original format
---
