org.apache.storm.windowing

Class WatermarkCountTriggerPolicy<T>

java.lang.Object

org.apache.storm.windowing.WatermarkCountTriggerPolicy<T>

All Implemented Interfaces:

TriggerPolicy<T>

public class WatermarkCountTriggerPolicy<T>
extends Object
implements TriggerPolicy<T>

A trigger policy that tracks event counts and sets the context for eviction policy to evict based on latest watermark time.

Constructor Summary

Constructors

Constructor and Description
WatermarkCountTriggerPolicy(int count, TriggerHandler handler, EvictionPolicy<T> evictionPolicy, WindowManager<T> windowManager)

Method Summary

Modifier and Type	Method and Description
void	reset() resets the trigger policy
void	shutdown() Any clean up could be handled here.
void	start() Starts the trigger policy.
String	toString()
void	track(org.apache.storm.windowing.Event<T> event) Tracks the event and could use this to invoke the trigger.

Methods inherited from class java.lang.Object

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

Constructor Detail

WatermarkCountTriggerPolicy

public WatermarkCountTriggerPolicy(int count,
                                   TriggerHandler handler,
                                   EvictionPolicy<T> evictionPolicy,
                                   WindowManager<T> windowManager)

Method Detail

track

public void track(org.apache.storm.windowing.Event<T> event)

Description copied from interface: TriggerPolicy

Tracks the event and could use this to invoke the trigger.

Specified by:

track in interface TriggerPolicy<T>

Parameters:

event - the input event

reset

public void reset()

Description copied from interface: TriggerPolicy

resets the trigger policy

Specified by:

reset in interface TriggerPolicy<T>

start

public void start()

Description copied from interface: TriggerPolicy

Starts the trigger policy. This can be used during recovery to start the triggers after recovery is complete.

Specified by:

start in interface TriggerPolicy<T>

shutdown

public void shutdown()

Description copied from interface: TriggerPolicy

Any clean up could be handled here.

Specified by:

shutdown in interface TriggerPolicy<T>

toString

public String toString()

Overrides:

toString in class Object