public static ReshuffleTriggerStateMachine create() {
    return new ReshuffleTriggerStateMachine();
  }
@Test
  public void testOnTimer() throws Exception {
    TriggerStateMachineTester<Integer, IntervalWindow> tester =
        TriggerStateMachineTester.forTrigger(
            ReshuffleTriggerStateMachine.create(), FixedWindows.of(Duration.millis(100)));
    IntervalWindow arbitraryWindow = new IntervalWindow(new Instant(100), new Instant(200));
    tester.fireIfShouldFire(arbitraryWindow);
    assertFalse(tester.isMarkedFinished(arbitraryWindow));
  }