Hi Avi, do you use processing time timer (timerService().registerProcessingTimeTimer)? why do you need ingestion time? do you set TimeCharacteristic.IngestionTime?
Best, Andrey On Tue, Mar 19, 2019 at 1:11 PM Avi Levi <avi.l...@bluevoyant.com> wrote: > Hi, > Our stream is not based on time sequence and we do not use time based > operations. we do want to clean the state after x days hence we fire timer > event. My problem is that our unit test fires the event immediately (there > is no ingestion time) how can I inject ingestion time ? > > Cheers > Avi > >
