Github user xubo245 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2959#discussion_r237039743
--- 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
- */
+ /**
+ * Return true if the specified sql statement will hit the datamap
+ * This API is for test purpose only
+ */
@InterfaceAudience.Developer(Array("DataMap"))
def isDataMapHit(sqlStatement: String, dataMapName: String): Boolean = {
// explain command will output the dataMap information only if
enable.query.statistics = true
val message = sql(s"EXPLAIN $sqlStatement").collect()
message(0).getString(0).contains(dataMapName)
}
- /**
- * Run SparkSQL directly
- */
+ /**
--- End diff --
no need to change, please keep the original format
---
