public interface AbsentPreStateProcessor extends SchedulingProcessor, PartitionCreationListener
Modifier and Type | Method and Description |
---|---|
void |
updateLastArrivalTime(long timestamp)
Update the timestamp of the event arrived to this processor and met the filter conditions.
|
getScheduler, setScheduler
getNextProcessor, process, process, setNextProcessor, setToLast
partitionCreated
Copyright © 2019. All rights reserved.