ProcessTableFunction.OnTimerContext (Confluent Flink Table API for Java)

All Superinterfaces:: ProcessTableFunction.Context

Enclosing class:: ProcessTableFunction<T>

@PublicEvolving public static interface ProcessTableFunction.OnTimerContext extends ProcessTableFunction.Context

Special ProcessTableFunction.Context that is available when the onTimer() method is called.

Method Summary

Modifier and Type

Method

Description

String

currentTimer()

Returns the name of the timer currently being fired, if the timer is a named timer (i.e.

Methods inherited from interface org.apache.flink.table.functions.ProcessTableFunction.Context
clearAll, clearAllState, clearAllTimers, clearState, getChangelogMode, tableSemanticsFor, timeContext

Method Details
- currentTimer
  
  String currentTimer()
  
  Returns the name of the timer currently being fired, if the timer is a named timer (i.e. registered using ProcessTableFunction.TimeContext.registerOnTime(String, Object)).
  Note: The time of the firing timer is available via ProcessTableFunction.Context.timeContext(Class).
  
  Returns:
  
  the timer's name, or null if the timer is unnamed (i.e. registered using ProcessTableFunction.TimeContext.registerOnTime(Object))