AfterSynchronizedProcessingTime extends OnceTrigger { @Override public Instant getWatermarkThatGuaranteesFiring(BoundedWindow window) { return BoundedWindow.TIMESTAMP_MAX_VALUE; } private  AfterSynchronizedProcessingTime(); static AfterSynchronizedProcessingTime ofFirstElement(); @Override Instant getWatermarkThatGuaranteesFiring(BoundedWindow window); @Override String toString(); @Override boolean equals(@Nullable Object obj); @Override int hashCode();  }
@Test public void testFireDeadline() throws Exception { assertEquals( BoundedWindow.TIMESTAMP_MAX_VALUE, underTest.getWatermarkThatGuaranteesFiring( new IntervalWindow(new Instant(0), new Instant(10)))); }