List of saveHWMark() Examples

Examples of saveHWMark()

krati.util.SourceWaterMarks.saveHWMark()
Saves the high water mark of a source. This method has the same functionality as {@link #setHWMScn(String,long)}. @param source - the source @param hwm - the high water mark

Examples of krati.util.SourceWaterMarks.saveHWMark()

        swm.setLWMScn(source1, scn);
        swm.setHWMScn(source1, scn);
        assertEquals(swm.getHWMScn(source1), swm.getLWMScn(source1));


        scn = System.currentTimeMillis() + counter++;
        swm.saveHWMark(source1, scn);
        assertTrue(swm.getLWMScn(source1) < swm.getHWMScn(source1));


        scn = System.currentTimeMillis() + counter++;
        swm.setWaterMarks(source1, scn, scn);
        assertEquals(scn, swm.getLWMScn(source1));

View Full Code Here

Examples of krati.util.SourceWaterMarks.saveHWMark()

        swm.setWaterMarks(source1, scn, scn);
        assertEquals(scn, swm.getLWMScn(source1));
        assertEquals(swm.getLWMScn(source1), swm.getHWMScn(source1));


        scn = System.currentTimeMillis() + counter++;
        swm.saveHWMark(source1, scn);
        assertTrue(swm.getLWMScn(source1) < swm.getHWMScn(source1));


        swm.syncWaterMarks();
        assertEquals(swm.getHWMScn(source1), swm.getLWMScn(source1));

View Full Code Here

Examples of krati.util.SourceWaterMarks.saveHWMark()

        assertEquals(swm.getHWMScn(source2), swm.getLWMScn(source2));


        assertEquals(2, swm.sources().size());


        scn = System.currentTimeMillis() + counter++;
        swm.saveHWMark(source1, scn);
        swm.saveHWMark(source2, scn);
        assertTrue(swm.getLWMScn(source1) < swm.getHWMScn(source1));
        assertTrue(swm.getLWMScn(source2) < swm.getHWMScn(source2));


        swm.syncWaterMarks();

View Full Code Here

Examples of krati.util.SourceWaterMarks.saveHWMark()


        assertEquals(2, swm.sources().size());


        scn = System.currentTimeMillis() + counter++;
        swm.saveHWMark(source1, scn);
        swm.saveHWMark(source2, scn);
        assertTrue(swm.getLWMScn(source1) < swm.getHWMScn(source1));
        assertTrue(swm.getLWMScn(source2) < swm.getHWMScn(source2));


        swm.syncWaterMarks();
        assertEquals(swm.getHWMScn(source1), swm.getLWMScn(source1));

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.