APISonar


org.apache.gobblin.source.extractor.watermark.WatermarkType.DATE

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

Example 1
private static 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;
    }
  }