org.apache.beam.runners.spark.util

Class TimerUtils

java.lang.Object

org.apache.beam.runners.spark.util.TimerUtils

public class TimerUtils
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
TimerUtils()

Method Summary

Modifier and Type	Method and Description
static <W extends BoundedWindow> void	dropExpiredTimers(SparkTimerInternals sparkTimerInternals, WindowingStrategy<?,W> windowingStrategy)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TimerUtils

public TimerUtils()

Method Detail

dropExpiredTimers

public static <W extends BoundedWindow> void dropExpiredTimers(SparkTimerInternals sparkTimerInternals,
                                                               WindowingStrategy<?,W> windowingStrategy)