@Test public void testGetWatermarkCondition() { QueryBasedExtractor<?, ?> extractor = null; Assert.assertEquals(COLUMN + " " + GREATER_THAN + " " + Long.MAX_VALUE, this.simpleWatermark.getWatermarkCondition(extractor, Long.MAX_VALUE, GREATER_THAN)); Assert.assertEquals(COLUMN + " null " + Long.MIN_VALUE, this.simpleWatermark.getWatermarkCondition(extractor, Long.MIN_VALUE, null)); }
@Override public String getWatermarkCondition(QueryBasedExtractor<?, ?> extractor, long watermarkValue, String operator) { return Utils.getCoalesceColumnNames(this.watermarkColumn) + " " + operator + " " + watermarkValue; }
SimpleWatermark implements Watermark { @Override public String getWatermarkCondition(QueryBasedExtractor<?, ?> extractor, long watermarkValue, String operator) { return Utils.getCoalesceColumnNames(this.watermarkColumn) + " " + operator + " " + watermarkValue; } }
SimpleWatermark implements Watermark { @Override public String getWatermarkCondition(QueryBasedExtractor<?, ?> extractor, long watermarkValue, String operator) { return Utils.getCoalesceColumnNames(this.watermarkColumn) + " " + operator + " " + watermarkValue; } SimpleWatermark(String watermarkColumn, String watermarkFormat); }
SimpleWatermark implements Watermark { @Override public String getWatermarkCondition(QueryBasedExtractor<?, ?> extractor, long watermarkValue, String operator) { return Utils.getCoalesceColumnNames(this.watermarkColumn) + " " + operator + " " + watermarkValue; } SimpleWatermark(String watermarkColumn, String watermarkFormat); @Override String getWatermarkCondition(QueryBasedExtractor<?, ?> extractor, long watermarkValue, String operator); @Override int getDeltaNumForNextWatermark(); @Override HashMap<Long, Long> getIntervals(long lowWatermarkValue, long highWatermarkValue, long partitionInterval,
      int maxIntervals); static long adjustWatermark(String baseWatermark, int diff); }
SimpleWatermark implements Watermark { @Override public String getWatermarkCondition(QueryBasedExtractor<?, ?> extractor, long watermarkValue, String operator) { return Utils.getCoalesceColumnNames(this.watermarkColumn) + " " + operator + " " + watermarkValue; } SimpleWatermark(String watermarkColumn, String watermarkFormat); @Override String getWatermarkCondition(QueryBasedExtractor<?, ?> extractor, long watermarkValue, String operator); @Override int getDeltaNumForNextWatermark(); @Override HashMap<Long, Long> getIntervals(long lowWatermarkValue, long highWatermarkValue, long partitionInterval,
      int maxIntervals); static long adjustWatermark(String baseWatermark, int diff);  }