xuchuanyin commented on a change in pull request #3574: [CARBONDATA-3503]
Optimize Carbon SparkExtensions
URL: https://github.com/apache/carbondata/pull/3574#discussion_r368287460
##########
File path:
core/src/main/java/org/apache/carbondata/core/statusmanager/SegmentStatusManager.java
##########
@@ -1100,6 +1101,62 @@ public static void
deleteLoadsAndUpdateMetadata(CarbonTable carbonTable, boolean
}
}
+ public static void truncateTable(CarbonTable carbonTable)
+ throws ConcurrentOperationException, IOException {
+ ICarbonLock carbonTableStatusLock = CarbonLockFactory.getCarbonLockObj(
+ carbonTable.getAbsoluteTableIdentifier(), LockUsage.TABLE_STATUS_LOCK);
+ boolean locked = false;
+ try {
+ // Update load metadate file after cleaning deleted nodes
+ locked = carbonTableStatusLock.lockWithRetries();
+ if (locked) {
+ LOG.info("Table status lock has been successfully acquired.");
+ LoadMetadataDetails[] listOfLoadFolderDetailsArray =
+ SegmentStatusManager.readLoadMetadata(
+ CarbonTablePath.getMetadataPath(carbonTable.getTablePath()));
+ for (LoadMetadataDetails listOfLoadFolderDetails :
listOfLoadFolderDetailsArray) {
+ boolean writing;
+ switch (listOfLoadFolderDetails.getSegmentStatus()) {
+ case INSERT_IN_PROGRESS:
+ writing = true;
+ break;
+ case INSERT_OVERWRITE_IN_PROGRESS:
+ writing = true;
+ break;
+ case STREAMING:
+ writing = true;
+ break;
+ default:
+ writing = false;
+ }
+ if (writing) {
+ throw new ConcurrentOperationException(carbonTable, "insert",
"truncate");
+ }
+ }
Review comment:
can be optimized to reduce lines of code
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
