@Override
  public void cancel() {
    if (cancellable != null) {
      cancellable.cancel();
    }
  }
Implementation class for a {@link TimeSinceFirstMessageTrigger}
@param <M> the type of the incoming message
samza-core/src/main/java/org/apache/samza/operators/triggers/TimeSinceFirstMessageTriggerImpl.java