Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2661#discussion_r213570439
--- Diff:
integration/spark-datasource/src/main/scala/org/apache/spark/sql/carbondata/execution/datasources/CarbonFileIndexReplaceRule.scala
---
@@ -82,4 +82,23 @@ class CarbonFileIndexReplaceRule extends
Rule[LogicalPlan] {
fileIndex
}
}
+
+ /**
+ * Get datafolders recursively
+ */
+ private def getDataFolders(carbonFile: CarbonFile): Seq[CarbonFile] = {
--- End diff --
Is the input CarbonFile a table folder? If so, please rename tableFolder
---