...
Specifically, for suppress processors, we could override this method and have insertNullRecord call the actual process() method with a null key and value (with time.milliseconds() being the stream record time). When the suppress processor receives this record, it will retain a timestamp field which stores when the last time a null record was inserted. In this manner, we are able to track roughly how much time has passed within a suppress processor without having to insert an actual Time instance as field.
...