@Test public void testGetDeltaNumForNextWatermark() { Assert.assertEquals(this.simpleWatermark.getDeltaNumForNextWatermark(), 1); }
@Override public int getDeltaNumForNextWatermark() { return deltaForNextWatermark; }
SimpleWatermark implements Watermark { @Override public int getDeltaNumForNextWatermark() { return deltaForNextWatermark; } }
SimpleWatermark implements Watermark { @Override public int getDeltaNumForNextWatermark() { return deltaForNextWatermark; } SimpleWatermark(String watermarkColumn, String watermarkFormat); }
SimpleWatermark implements Watermark { @Override public int getDeltaNumForNextWatermark() { return deltaForNextWatermark; } 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 int getDeltaNumForNextWatermark() { return deltaForNextWatermark; } 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);  }