docs: protected void start() {
      if (waterMarkEventGenerator != null) {
        LOG.fine("Starting waterMarkEventGenerator");
        waterMarkEventGenerator.start();
      }
      LOG.fine("Starting trigger policy");
      triggerPolicy.start();
    }