org.apache.samza.operators.triggers

Interface Trigger<M>

Type Parameters:

M - the type of the incoming message

All Superinterfaces:

java.io.Serializable

All Known Subinterfaces:

TimeBasedTrigger<M>

All Known Implementing Classes:

AnyTrigger, CountTrigger, RepeatingTrigger, TimeSinceFirstMessageTrigger, TimeSinceLastMessageTrigger, TimeTrigger

@InterfaceStability.Unstable
public interface Trigger<M>
extends java.io.Serializable

Marker interface for all triggers. The firing of a trigger indicates the completion of a window pane.

Use the Triggers APIs to create a Trigger.