AvroHdfsTimePartitionedWriter.java 文件源码

java
阅读 24 收藏 0 点赞 0 评论 0

项目:Gobblin 作者:
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());
  }
}
评论列表
文章目录


问题


面经


文章

微信
公众号

扫码关注公众号