AfterSynchronizedProcessingTime extends OnceTrigger { @Override protected Trigger getContinuationTrigger(List<Trigger> continuationTriggers) { return this; } 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 testContinuation() throws Exception { assertEquals(underTest, underTest.getContinuationTrigger()); }