Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2612#discussion_r208211297
--- Diff:
core/src/main/java/org/apache/carbondata/core/statusmanager/SegmentUpdateStatusManager.java
---
@@ -779,6 +779,32 @@ public UpdateVO getInvalidTimestampRange(String
segmentId) {
}
return range;
}
+
+ /**
+ * Returns the invalid timestamp range of a segment.
+ * @return
+ */
+ public List<UpdateVO> getInvalidTimestampRange() {
+ List<UpdateVO> ranges = new ArrayList<UpdateVO>();
+ for (LoadMetadataDetails segment : segmentDetails) {
+ if (!(segment.getSegmentStatus().equals(SegmentStatus.SUCCESS) ||
+
segment.getSegmentStatus().equals(SegmentStatus.LOAD_PARTIAL_SUCCESS))) {
--- End diff --
Please refer SegmentStatusManager for checking the invalid segments
---
