public static interface ProcessFunction.OnTimerContext extends ProcessFunction.Context
ProcessFunction.onTimer(long, OnTimerContext, Collector)
.Modifier and Type | Method and Description |
---|---|
TimeDomain |
timeDomain()
The
TimeDomain of the firing timer. |
timerService, timestamp
TimeDomain timeDomain()
TimeDomain
of the firing timer.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.