@Override
  public LongWatermark getExpectedHighWatermark(Partition partition, long tableProcessTime, long partitionProcessTime) {
    return new LongWatermark(this.expectedHighWatermarks.getPartitionWatermark(tableKey(partition.getTable()),
        partitionKey(partition)));
  }
@ Override public LongWatermark getExpectedHighWatermark ( Partition partition , long tableProcessTime , long partitionProcessTime ) { return new LongWatermark ( this . expectedHighWatermarks . getPartitionWatermark ( tableKey ( partition . getTable ( ) ) , partitionKey ( partition ) ) ) ; }
Get the expected high watermark for this partition
{@inheritDoc}
@see org.apache.gobblin.data.management.conversion.hive.watermarker.HiveSourceWatermarker#getExpectedHighWatermark(org.apache.hadoop.hive.ql.metadata.Partition, long, long)