lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

Using FsUtils instead of Files API to extract file extension

Browse Source
This commit is contained in:
Nishith Agarwal
2017-06-29 16:42:58 -07:00
committed by prazanna
parent e5d9b818bc
commit 348250d960
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
hoodie-common/src/main/java/com/uber/hoodie/common/table/timeline/HoodieInstant.java
View File

@@ -18,11 +18,11 @@ package com.uber.hoodie.common.table.timeline;
import com.google.common.io.Files; import com.google.common.io.Files;
import com.uber.hoodie.common.table.HoodieTimeline; import com.uber.hoodie.common.table.HoodieTimeline;
import com.uber.hoodie.common.util.FSUtils;
import org.apache.hadoop.fs.FileStatus; import org.apache.hadoop.fs.FileStatus;
import java.io.Serializable; import java.io.Serializable;
import java.util.Objects; import java.util.Objects;
import java.util.Optional;
/** /**
* A Hoodie Instant represents a action done on a hoodie dataset. * A Hoodie Instant represents a action done on a hoodie dataset.
@@ -42,11 +42,11 @@ public class HoodieInstant implements Serializable {
public HoodieInstant(FileStatus fileStatus) { public HoodieInstant(FileStatus fileStatus) {
// First read the instant timestamp. [==>20170101193025<==].commit // First read the instant timestamp. [==>20170101193025<==].commit
String fileName = fileStatus.getPath().getName(); String fileName = fileStatus.getPath().getName();
String fileExtension = Files.getFileExtension(fileName); String fileExtension = FSUtils.getFileExtension(fileName);
timestamp = fileName.replace("." + fileExtension, ""); timestamp = fileName.replace(fileExtension, "");
// Next read the action for this marker // Next read the action for this marker
action = fileExtension; action = fileExtension.replaceFirst(".", "");
if(action.equals("inflight")) { if(action.equals("inflight")) {
// This is to support backwards compatibility on how in-flight commit files were written // This is to support backwards compatibility on how in-flight commit files were written
// General rule is inflight extension is .<action>.inflight, but for commit it is .inflight // General rule is inflight extension is .<action>.inflight, but for commit it is .inflight