code: protected void start() {
          if (waterMarkEventGenerator != null) {
              LOG.debug("Starting waterMarkEventGenerator");
              waterMarkEventGenerator.start();
          }
          LOG.debug("Starting trigger policy");
          triggerPolicy.start();
      }
docs: Start the trigger policy and waterMarkEventGenerator if set