Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1837#discussion_r163760950
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/hive/CarbonRelation.scala
---
@@ -215,8 +214,19 @@ case class CarbonRelation(
carbonTable.getCarbonTableIdentifier).getPath
val fileType = FileFactory.getFileType(tablePath)
if (FileFactory.isFileExist(tablePath, fileType)) {
+ // get the valid segments
+ val segments = new
SegmentStatusManager(carbonTable.getAbsoluteTableIdentifier)
+ .getValidAndInvalidSegments.getValidSegments.asScala
+ var size = 0L
+ // for each segment calculate the size
+ segments.foreach {validSeg =>
+ size = size +
+
FileFactory.getDirectorySize(CarbonTablePath.getSegmentPath(tablePath,
validSeg))
--- End diff --
Please format as below
```
size = size + FileFactory.getDirectorySize(
CarbonTablePath.getSegmentPath(tablePath, validSeg))
```
---
