This is an automated email from the ASF dual-hosted git repository.
suvasude pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-gobblin.git
The following commit(s) were added to refs/heads/master by this push:
new 28d3d7b [GOBBLIN-919] Using apache commons Pair API
28d3d7b is described below
commit 28d3d7b5b07b82d86452f0e423559f104a383152
Author: vbohra <[email protected]>
AuthorDate: Fri Oct 18 17:10:36 2019 -0700
[GOBBLIN-919] Using apache commons Pair API
Closes #2773 from vikrambohra/fixPair2
---
.../data/management/copy/UnixTimestampRecursiveCopyableDataset.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/UnixTimestampRecursiveCopyableDataset.java
b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/UnixTimestampRecursiveCopyableDataset.java
index 81613ab..9c0ab84 100644
---
a/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/UnixTimestampRecursiveCopyableDataset.java
+++
b/gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/UnixTimestampRecursiveCopyableDataset.java
@@ -26,6 +26,8 @@ import java.util.TreeMap;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
+import org.apache.commons.lang3.tuple.ImmutablePair;
+import org.apache.commons.lang3.tuple.Pair;
import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
@@ -38,8 +40,6 @@ import org.joda.time.format.PeriodFormatter;
import org.joda.time.format.PeriodFormatterBuilder;
import org.testng.collections.Lists;
-import javafx.util.Pair;
-
import org.apache.gobblin.util.PathUtils;
import org.apache.gobblin.util.filters.AndPathFilter;
@@ -130,7 +130,7 @@ public class UnixTimestampRecursiveCopyableDataset extends
RecursiveCopyableData
String rootPath = relativePath.substring(0,
relativePath.indexOf(timestampStr));
Long unixTimestamp = Long.parseLong(timestampStr);
LocalDate localDate = new
LocalDateTime(unixTimestamp,dateTimeZone).toLocalDate();
- Pair<String, LocalDate> key = new Pair<>(rootPath, localDate);
+ Pair<String, LocalDate> key = new ImmutablePair<>(rootPath, localDate);
if (!pathTimestampFilesMap.containsKey(key)) {
pathTimestampFilesMap.put(key, new TreeMap<Long, List<FileStatus>>());
}