public BaseWindowedBolt < T > ingestionTimeWindow ( Time size , Time slide ) { long s = size . toMilliseconds ( ) ; long l = slide . toMilliseconds ( ) ; ensurePositiveTime ( s , l ) ; ensureSizeGreaterThanSlide ( s , l ) ; setSizeAndSlide ( s , l ) ; this . windowAssigner = SlidingIngestionTimeWindows . of ( s , l ) ; return this ; }
define a sliding ingestion time window