@Test
public void createHighWaterMark() {

    final KyloCatalogClient client = Mockito.mock(KyloCatalogClient.class);
    // Test creating high water mark
    final MockJdbcDataSetProvider provider = new MockJdbcDataSetProvider();
    final JdbcHighWaterMark highWaterMark = provider.createHighWaterMark("mockWaterMark", client);
    Assert.assertEquals("mockWaterMark", highWaterMark.getName());
    Assert.assertNull("Expected initial value to be null", highWaterMark.getValue());
    // Test adding a value
    highWaterMark.accumulate(1525014303000L);
    Mockito.verify(client).setHighWaterMarks(Collections.singletonMap("mockWaterMark", "2018-04-29T15:05:03"));
}