Github user QiangCai commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1991#discussion_r171750725
--- Diff:
processing/src/main/java/org/apache/carbondata/processing/util/CarbonDataProcessorUtil.java
---
@@ -158,6 +160,27 @@ public static void createLocations(String[] locations)
{
return localDataFolderLocArray;
}
+ /**
+ * This method will form the local data folder store location
+ *
+ * @param databaseName
+ * @param tableName
+ * @param taskId
+ * @param partitionId
+ * @param segmentId
+ * @param isCompactionFlow
+ * @param isAltPartitionFlow
+ * @return
+ */
+ public static String[] getLocalDataFolderLocation(String databaseName,
String tableName,
+ String taskId, String partitionId, String segmentId, boolean
isCompactionFlow,
+ boolean isAltPartitionFlow) {
+ CarbonTable carbonTable =
CarbonMetadata.getInstance().getCarbonTable(databaseName, tableName);
+ return getLocalDataFolderLocation(carbonTable, tableName, taskId,
partitionId,
+ segmentId, isCompactionFlow, isAltPartitionFlow);
+ }
+
--- End diff --
fixed
---
