Uses of Class
org.apache.flink.table.runtime.functions.Timer
Packages that use Timer
-
Uses of Timer in org.apache.flink.table.runtime.functions
Methods in org.apache.flink.table.runtime.functions that return types with arguments of type TimerModifier and TypeMethodDescriptionProcessTableFunctionTestHarness.getAllTimers()Returns all timers (both pending and fired), sorted by timestamp then name.ProcessTableFunctionTestHarness.getAllTimers(Row partitionKey) Returns all timers (both pending and fired) for the given partition key.ProcessTableFunctionTestHarness.getFiredTimers()Returns all timers that have fired, in the order they fired.ProcessTableFunctionTestHarness.getFiredTimers(String timerName) Returns all fired timers with the given name.ProcessTableFunctionTestHarness.getFiredTimers(Row partitionKey) Returns all fired timers for the given partition key.ProcessTableFunctionTestHarness.getPendingTimers()Returns all pending (not yet fired) timers, sorted by timestamp then name.ProcessTableFunctionTestHarness.getPendingTimers(String timerName) Returns all pending timers with the given name.ProcessTableFunctionTestHarness.getPendingTimers(Row partitionKey) Returns all pending timers for the given partition key.Methods in org.apache.flink.table.runtime.functions with parameters of type Timer