edu.iu.dsc.tws.task.window.event

Class WatermarkEventGenerator<T>

java.lang.Object

edu.iu.dsc.tws.task.window.event.WatermarkEventGenerator<T>

All Implemented Interfaces:

java.lang.Runnable

public class WatermarkEventGenerator<T>
extends java.lang.Object
implements java.lang.Runnable

Constructor Summary

Constructors

Constructor and Description
WatermarkEventGenerator(WindowManager<T> winManager, long eventLagTime, long interval, java.util.Set<GlobalStreamId> inputStreams)

Method Summary

Modifier and Type	Method and Description
void	run()
void	shutdown()
void	start()
boolean	track(GlobalStreamId globalStreamId, long timestamp)
boolean	track(long time)

Methods inherited from class java.lang.Object

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

Constructor Detail

WatermarkEventGenerator

public WatermarkEventGenerator(WindowManager<T> winManager,
                               long eventLagTime,
                               long interval,
                               java.util.Set<GlobalStreamId> inputStreams)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

track

public boolean track(long time)

track

public boolean track(GlobalStreamId globalStreamId,
                     long timestamp)

start

public void start()

shutdown

public void shutdown()