@Internal @FunctionalInterface public interface ProcessingTimeCallback
void onProcessingTime(long timestamp) throws Exception
If the triggering is delayed for whatever reason (trigger timer was blocked, JVM stalled due to a garbage collection), the timestamp supplied to this function will still be the original timestamp for which the trigger was scheduled.
timestamp- The timestamp for which the trigger event was scheduled.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.