public static interface CoProcessFunction.OnTimerContext extends CoProcessFunction.Context
CoProcessFunction.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.