lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Unify Lists import (#1103)

Browse Source
This commit is contained in:
lamber-ken
2019-12-13 13:42:18 +08:00
committed by vinoth chandar
parent a405d3873b
commit f324057b6e
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
hudi-hive/src/main/java/org/apache/hudi/hive/SlashEncodedDayPartitionValueExtractor.java
View File

@@ -18,11 +18,11 @@
package org.apache.hudi.hive; package org.apache.hudi.hive;
import com.beust.jcommander.internal.Lists;
import org.joda.time.DateTime; import org.joda.time.DateTime;
import org.joda.time.format.DateTimeFormat; import org.joda.time.format.DateTimeFormat;
import org.joda.time.format.DateTimeFormatter; import org.joda.time.format.DateTimeFormatter;
import java.util.Collections;
import java.util.List; import java.util.List;
/** /**
@@ -58,6 +58,7 @@ public class SlashEncodedDayPartitionValueExtractor implements PartitionValueExt
int mm = Integer.parseInt(splits[1].contains("=") ? splits[1].split("=")[1] : splits[1]); int mm = Integer.parseInt(splits[1].contains("=") ? splits[1].split("=")[1] : splits[1]);
int dd = Integer.parseInt(splits[2].contains("=") ? splits[2].split("=")[1] : splits[2]); int dd = Integer.parseInt(splits[2].contains("=") ? splits[2].split("=")[1] : splits[2]);
DateTime dateTime = new DateTime(year, mm, dd, 0, 0); DateTime dateTime = new DateTime(year, mm, dd, 0, 0);
return Lists.newArrayList(getDtfOut().print(dateTime));
return Collections.singletonList(getDtfOut().print(dateTime));
} }
} }