org.apache.storm.windowing

Interface TriggerPolicy<T>

All Known Implementing Classes:

CountTriggerPolicy, TimeTriggerPolicy, WatermarkCountTriggerPolicy, WatermarkTimeTriggerPolicy

public interface TriggerPolicy<T>

Triggers the window calculations based on the policy.

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.
void	track(org.apache.storm.windowing.Event<T> event) Tracks the event and could use this to invoke the trigger.

Method Detail

track

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

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

Parameters:

event - the input event

reset

void reset()

resets the trigger policy

start

void start()

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

shutdown

void shutdown()

Any clean up could be handled here.