@Override
  public boolean shouldFire(TriggerStateMachine.TriggerContext context) throws Exception {
    return true;
  }
@Test
  public void testShouldFire() throws Exception {
    TriggerStateMachineTester<Integer, IntervalWindow> tester =
        TriggerStateMachineTester.forTrigger(
            ReshuffleTriggerStateMachine.create(), FixedWindows.of(Duration.millis(100)));
    IntervalWindow arbitraryWindow = new IntervalWindow(new Instant(300), new Instant(400));
    assertTrue(tester.shouldFire(arbitraryWindow));
  }