@PublicEvolving public interface ProcessingTimeService
ProcessingTimeService.ProcessingTimeCallback
when firing.Modifier and Type | Interface and Description |
---|---|
static interface |
ProcessingTimeService.ProcessingTimeCallback
A callback that can be registered via
registerTimer(long, ProcessingTimeCallback) . |
Modifier and Type | Method and Description |
---|---|
long |
getCurrentProcessingTime()
Returns the current processing time.
|
ScheduledFuture<?> |
registerTimer(long timestamp,
ProcessingTimeService.ProcessingTimeCallback target)
Registers a task to be executed when (processing) time is
timestamp . |
long getCurrentProcessingTime()
ScheduledFuture<?> registerTimer(long timestamp, ProcessingTimeService.ProcessingTimeCallback target)
timestamp
.timestamp
- Time when the task is to be executed (in processing time)target
- The task to be executedCopyright © 2014–2023 The Apache Software Foundation. All rights reserved.