org.apache.samza.operators.triggers

Interface TimeBasedTrigger<M>

Type Parameters:

M - the type of the incoming message

All Superinterfaces:

java.io.Serializable, Trigger<M>

All Known Implementing Classes:

TimeSinceFirstMessageTrigger, TimeSinceLastMessageTrigger, TimeTrigger

@InterfaceStability.Unstable
public interface TimeBasedTrigger<M>
extends Trigger<M>

A Trigger whose firing logic is determined by a time duration.

Use the Triggers APIs to create a Trigger.

Method Summary

Modifier and Type	Method and Description
java.time.Duration	getDuration()

Method Detail

getDuration

java.time.Duration getDuration()