private Optional<Long> getEarliestAllowedTimestamp() {
if (!this.properties.contains(TIME_PARTITIONED_WRITER_MAX_TIME_AGO)) {
return Optional.<Long> absent();
} else {
DateTime currentTime = new DateTime(this.timeZone);
PeriodFormatter periodFormatter = getPeriodFormatter();
String maxTimeAgoStr = this.properties.getProp(TIME_PARTITIONED_WRITER_MAX_TIME_AGO);
Period maxTimeAgo = periodFormatter.parsePeriod(maxTimeAgoStr);
return Optional.of(currentTime.minus(maxTimeAgo).getMillis());
}
}
AvroHdfsTimePartitionedWriter.java 文件源码
java
阅读 24
收藏 0
点赞 0
评论 0
项目:Gobblin
作者:
评论列表
文章目录