APISonar


gobblin.source.extractor.watermark.WatermarkType.DATE

> gobblin > source > extractor > watermark > WatermarkType > DATE
gobblin APIs source APIs extractor APIs watermark APIs WatermarkType APIs DATE APIs

Example 1
private int getUpdatedInterval(int inputInterval, ExtractType extractType, WatermarkType watermarkType) {
    LOG.debug("Getting updated interval");
    if ((extractType == ExtractType.SNAPSHOT && watermarkType == WatermarkType.DATE)) {
      return inputInterval * 24;
    } else if (extractType == ExtractType.APPEND_DAILY) {
      return (inputInterval < 1 ? 1 : inputInterval) * 24;
    } else {
      return inputInterval;
    }
  }