Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2488#discussion_r203248300
--- Diff:
core/src/main/java/org/apache/carbondata/core/util/CarbonUtil.java ---
@@ -3231,4 +3232,54 @@ private static int
unsetLocalDictForComplexColumns(List<ColumnSchema> allColumns
}
return columnLocalDictGenMap;
}
+
+ /**
+ * This method get the carbon file format version
+ *
+ * @param carbonTable
+ * carbon Table
+ */
+ public static ColumnarFormatVersion getFormatVersion(CarbonTable
carbonTable)
+ throws IOException {
+ String storePath = null;
+ // if the carbontable is support flat folder
+ boolean supportFlatFolder = carbonTable.isSupportFlatFolder();
+ if (supportFlatFolder) {
+ storePath = carbonTable.getTablePath();
--- End diff --
It does not work for partition tables.
---
